Skip to content

Commit

Permalink
Upgrade Transfer.
Browse files Browse the repository at this point in the history
  • Loading branch information
Tang8330 committed Sep 5, 2024
1 parent d57db14 commit aaecca2
Show file tree
Hide file tree
Showing 3 changed files with 9 additions and 9 deletions.
2 changes: 1 addition & 1 deletion go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ go 1.23.0

require (
github.com/DataDog/datadog-go/v5 v5.5.0
github.com/artie-labs/transfer v1.26.28
github.com/artie-labs/transfer v1.26.29
github.com/aws/aws-sdk-go-v2 v1.30.3
github.com/aws/aws-sdk-go-v2/config v1.27.27
github.com/aws/aws-sdk-go-v2/credentials v1.17.27
Expand Down
4 changes: 2 additions & 2 deletions go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -93,8 +93,8 @@ github.com/apache/thrift v0.0.0-20181112125854-24918abba929/go.mod h1:cp2SuWMxlE
github.com/apache/thrift v0.14.2/go.mod h1:cp2SuWMxlEZw2r+iP2GNCdIi4C1qmUzdZFSVb+bacwQ=
github.com/apache/thrift v0.17.0 h1:cMd2aj52n+8VoAtvSvLn4kDC3aZ6IAkBuqWQ2IDu7wo=
github.com/apache/thrift v0.17.0/go.mod h1:OLxhMRJxomX+1I/KUw03qoV3mMz16BwaKI+d4fPBx7Q=
github.com/artie-labs/transfer v1.26.28 h1:xNPSc08jqaRa3Rrtk1kYeiC8NolngWv1o/fqXrCsKzc=
github.com/artie-labs/transfer v1.26.28/go.mod h1:+a/UhlQVRIpdz3muS1yhSvyX42RQL0LHOdovGZfEsDE=
github.com/artie-labs/transfer v1.26.29 h1:oqyeGX1nAIbD1PEZ7/FUSUHLGycKnP456Mbpw4Wgjxs=
github.com/artie-labs/transfer v1.26.29/go.mod h1:+a/UhlQVRIpdz3muS1yhSvyX42RQL0LHOdovGZfEsDE=
github.com/aws/aws-sdk-go v1.30.19/go.mod h1:5zCpMtNQVjRREroY7sYe8lOMRSxkhG6MZveU8YkpAk0=
github.com/aws/aws-sdk-go-v2 v1.16.12/go.mod h1:C+Ym0ag2LIghJbXhfXZ0YEEp49rBWowxKzJLUoob0ts=
github.com/aws/aws-sdk-go-v2 v1.30.3 h1:jUeBtG0Ih+ZIFH0F4UkmL9w3cSpaMv9tYYDbzILP8dY=
Expand Down
12 changes: 6 additions & 6 deletions lib/debezium/converters/time_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -97,8 +97,8 @@ func TestMicroTimeConverter_Convert(t *testing.T) {
assert.NoError(t, err)
transferValue, err := parseUsingTransfer(converter, value.(int64))
assert.NoError(t, err)
assert.Equal(t, time.Date(1970, time.January, 1, 1, 2, 3, 0, time.UTC), transferValue.Time)
assert.Equal(t, ext.TimeKindType, transferValue.NestedKind.Type)
assert.Equal(t, time.Date(1970, time.January, 1, 1, 2, 3, 0, time.UTC), transferValue.GetTime())
assert.Equal(t, ext.TimeKindType, transferValue.GetNestedKind().Type)
}
}

Expand Down Expand Up @@ -207,8 +207,8 @@ func TestDateConverter_Convert(t *testing.T) {
assert.NoError(t, err)
transferValue, err := parseUsingTransfer(converter, int64(value.(int32)))
assert.NoError(t, err)
assert.Equal(t, time.Date(2023, time.May, 3, 0, 0, 0, 0, time.UTC), transferValue.Time)
assert.Equal(t, ext.DateKindType, transferValue.NestedKind.Type)
assert.Equal(t, time.Date(2023, time.May, 3, 0, 0, 0, 0, time.UTC), transferValue.GetTime())
assert.Equal(t, ext.DateKindType, transferValue.GetNestedKind().Type)
}
}

Expand Down Expand Up @@ -259,8 +259,8 @@ func TestMicroTimestampConverter_Convert(t *testing.T) {
assert.NoError(t, err)
transferValue, err := parseUsingTransfer(converter, value.(int64))
assert.NoError(t, err)
assert.Equal(t, timeValue, transferValue.Time)
assert.Equal(t, ext.DateTimeKindType, transferValue.NestedKind.Type)
assert.Equal(t, timeValue, transferValue.GetTime())
assert.Equal(t, ext.DateTimeKindType, transferValue.GetNestedKind().Type)
}
}

Expand Down

0 comments on commit aaecca2

Please sign in to comment.