From 28298290545934d5b39c97c51200469df9e9a596 Mon Sep 17 00:00:00 2001 From: Robin Tang Date: Thu, 5 Sep 2024 11:26:09 -0700 Subject: [PATCH] Upgrade Transfer. (#485) --- go.mod | 2 +- go.sum | 4 ++-- lib/debezium/converters/time_test.go | 12 ++++++------ 3 files changed, 9 insertions(+), 9 deletions(-) diff --git a/go.mod b/go.mod index b32a4849..1eb8edde 100644 --- a/go.mod +++ b/go.mod @@ -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 diff --git a/go.sum b/go.sum index 9130c731..024e130f 100644 --- a/go.sum +++ b/go.sum @@ -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= diff --git a/lib/debezium/converters/time_test.go b/lib/debezium/converters/time_test.go index c0c237b1..6380d1a8 100644 --- a/lib/debezium/converters/time_test.go +++ b/lib/debezium/converters/time_test.go @@ -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) } } @@ -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) } } @@ -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) } }