Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
16 changes: 8 additions & 8 deletions cli/go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -3,22 +3,22 @@ module github.com/cloudquery/cloudquery/cli
go 1.19

require (
github.com/cloudquery/plugin-sdk v1.36.1
github.com/getsentry/sentry-go v0.17.0
github.com/cloudquery/plugin-sdk v1.37.0
github.com/getsentry/sentry-go v0.18.0
github.com/google/uuid v1.3.0
github.com/rs/zerolog v1.29.0
github.com/schollz/progressbar/v3 v3.13.0
github.com/spf13/cobra v1.6.1
github.com/stretchr/testify v1.8.1
github.com/thoas/go-funk v0.9.3
golang.org/x/exp v0.0.0-20230131160201-f062dba9d201
golang.org/x/exp v0.0.0-20230212135524-a684f29349b6
golang.org/x/sync v0.1.0
google.golang.org/grpc v1.52.3
google.golang.org/grpc v1.53.0
google.golang.org/protobuf v1.28.1
)

require (
github.com/avast/retry-go/v4 v4.3.2 // indirect; indirect // indirect
github.com/avast/retry-go/v4 v4.3.3 // indirect; indirect // indirect
github.com/cpuguy83/go-md2man/v2 v2.0.2 // indirect
github.com/davecgh/go-spew v1.1.1 // indirect
github.com/ghodss/yaml v1.0.0 // indirect
Expand All @@ -33,11 +33,11 @@ require (
github.com/russross/blackfriday/v2 v2.1.0 // indirect
github.com/spf13/cast v1.5.0 // indirect
github.com/spf13/pflag v1.0.5 // indirect
golang.org/x/net v0.5.0 // indirect
golang.org/x/net v0.6.0 // indirect
golang.org/x/sys v0.5.0 // indirect
golang.org/x/term v0.5.0 // indirect
golang.org/x/text v0.6.0 // indirect
google.golang.org/genproto v0.0.0-20230131230820-1c016267d619 // indirect; indirect // indirect
golang.org/x/text v0.7.0 // indirect
google.golang.org/genproto v0.0.0-20230209215440-0dfe4f8abfcc // indirect; indirect // indirect
gopkg.in/yaml.v2 v2.4.0 // indirect
gopkg.in/yaml.v3 v3.0.1 // indirect
)
32 changes: 16 additions & 16 deletions cli/go.sum
Original file line number Diff line number Diff line change
@@ -1,17 +1,17 @@
github.com/avast/retry-go/v4 v4.3.2 h1:x4sTEu3jSwr7zNjya8NTdIN+U88u/jtO/q3OupBoDtM=
github.com/avast/retry-go/v4 v4.3.2/go.mod h1:rg6XFaiuFYII0Xu3RDbZQkxCofFwruZKW8oEF1jpWiU=
github.com/avast/retry-go/v4 v4.3.3 h1:G56Bp6mU0b5HE1SkaoVjscZjlQb0oy4mezwY/cGH19w=
github.com/avast/retry-go/v4 v4.3.3/go.mod h1:rg6XFaiuFYII0Xu3RDbZQkxCofFwruZKW8oEF1jpWiU=
github.com/bradleyjkemp/cupaloy/v2 v2.8.0 h1:any4BmKE+jGIaMpnU8YgH/I2LPiLBufr6oMMlVBbn9M=
github.com/cloudquery/plugin-sdk v1.36.1 h1:EUpvLjJx/uMwA7FYqrgIvFcCNJqOIuz3jaaGdyQvihs=
github.com/cloudquery/plugin-sdk v1.36.1/go.mod h1:GEu6A0vJdV2ty3ssTiX64bPhkxVpnLGpuM1OhDvcHTk=
github.com/cloudquery/plugin-sdk v1.37.0 h1:WLL6sHZKRYCMfynCsUWl41fB3jOWyq77rLrX+v5DXoA=
github.com/cloudquery/plugin-sdk v1.37.0/go.mod h1:anjM5gY7qgJDde9CCIlJbeKuFOxM4BBrFeX1jyU1dxo=
github.com/coreos/go-systemd/v22 v22.3.3-0.20220203105225-a9a7ef127534/go.mod h1:Y58oyj3AT4RCenI/lSvhwexgC+NSVTIJ3seZv2GcEnc=
github.com/cpuguy83/go-md2man/v2 v2.0.2 h1:p1EgwI/C7NhT0JmVkwCD2ZBK8j4aeHQX2pMHHBfMQ6w=
github.com/cpuguy83/go-md2man/v2 v2.0.2/go.mod h1:tgQtvFlXSQOSOSIRvRPT7W67SCa46tRHOmNcaadrF8o=
github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
github.com/frankban/quicktest v1.14.3 h1:FJKSZTDHjyhriyC81FLQ0LY93eSai0ZyR/ZIkd3ZUKE=
github.com/getsentry/sentry-go v0.17.0 h1:UustVWnOoDFHBS7IJUB2QK/nB5pap748ZEp0swnQJak=
github.com/getsentry/sentry-go v0.17.0/go.mod h1:B82dxtBvxG0KaPD8/hfSV+VcHD+Lg/xUS4JuQn1P4cM=
github.com/getsentry/sentry-go v0.18.0 h1:MtBW5H9QgdcJabtZcuJG80BMOwaBpkRDZkxRkNC1sN0=
github.com/getsentry/sentry-go v0.18.0/go.mod h1:Kgon4Mby+FJ7ZWHFUAZgVaIa8sxHtnRJRLTXZr51aKQ=
github.com/ghodss/yaml v1.0.0 h1:wQHKEahhL6wmXdzwWG11gIVCkOv05bNOh+Rxn0yngAk=
github.com/ghodss/yaml v1.0.0/go.mod h1:4dBDuWmgqj2HViK6kFavaiC9ZROes6MMH2rRYeMEF04=
github.com/go-errors/errors v1.4.2 h1:J6MZopCL4uSllY1OfXM374weqZFFItUbrImctkmUxIA=
Expand Down Expand Up @@ -73,10 +73,10 @@ github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKs
github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4=
github.com/thoas/go-funk v0.9.3 h1:7+nAEx3kn5ZJcnDm2Bh23N2yOtweO14bi//dvRtgLpw=
github.com/thoas/go-funk v0.9.3/go.mod h1:+IWnUfUmFO1+WVYQWQtIJHeRRdaIyyYglZN7xzUPe4Q=
golang.org/x/exp v0.0.0-20230131160201-f062dba9d201 h1:BEABXpNXLEz0WxtA+6CQIz2xkg80e+1zrhWyMcq8VzE=
golang.org/x/exp v0.0.0-20230131160201-f062dba9d201/go.mod h1:CxIveKay+FTh1D0yPZemJVgC/95VzuuOLq5Qi4xnoYc=
golang.org/x/net v0.5.0 h1:GyT4nK/YDHSqa1c4753ouYCDajOYKTja9Xb/OHtgvSw=
golang.org/x/net v0.5.0/go.mod h1:DivGGAXEgPSlEBzxGzZI+ZLohi+xUj054jfeKui00ws=
golang.org/x/exp v0.0.0-20230212135524-a684f29349b6 h1:Ic9KukPQ7PegFzHckNiMTQXGgEszA7mY2Fn4ZMtnMbw=
golang.org/x/exp v0.0.0-20230212135524-a684f29349b6/go.mod h1:CxIveKay+FTh1D0yPZemJVgC/95VzuuOLq5Qi4xnoYc=
golang.org/x/net v0.6.0 h1:L4ZwwTvKW9gr0ZMS1yrHD9GZhIuVjOBBnaKH+SPQK0Q=
golang.org/x/net v0.6.0/go.mod h1:2Tu9+aMcznHK/AK1HMvgo6xiTLG5rD5rZLDS+rp2Bjs=
golang.org/x/sync v0.1.0 h1:wsuoTGHzEhffawBOhz5CYhcrV4IdKZbEyZjBMuTp12o=
golang.org/x/sync v0.1.0/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
golang.org/x/sys v0.0.0-20210630005230-0f9fa26af87c/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
Expand All @@ -88,13 +88,13 @@ golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/term v0.4.0/go.mod h1:9P2UbLfCdcvo3p/nzKvsmas4TnlujnuoV9hGgYzW1lQ=
golang.org/x/term v0.5.0 h1:n2a8QNdAb0sZNpU9R1ALUXBbY+w51fCQDN+7EdxNBsY=
golang.org/x/term v0.5.0/go.mod h1:jMB1sMXY+tzblOD4FWmEbocvup2/aLOaQEp7JmGp78k=
golang.org/x/text v0.6.0 h1:3XmdazWV+ubf7QgHSTWeykHOci5oeekaGJBLkrkaw4k=
golang.org/x/text v0.6.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8=
golang.org/x/text v0.7.0 h1:4BRB4x83lYWy72KwLD/qYDuTu7q9PjSagHvijDw7cLo=
golang.org/x/text v0.7.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8=
golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
google.golang.org/genproto v0.0.0-20230131230820-1c016267d619 h1:p0kMzw6AG0JEzd7Z+kXqOiLhC6gjUQTbtS2zR0Q3DbI=
google.golang.org/genproto v0.0.0-20230131230820-1c016267d619/go.mod h1:RGgjbofJ8xD9Sq1VVhDM1Vok1vRONV+rg+CjzG4SZKM=
google.golang.org/grpc v1.52.3 h1:pf7sOysg4LdgBqduXveGKrcEwbStiK2rtfghdzlUYDQ=
google.golang.org/grpc v1.52.3/go.mod h1:pu6fVzoFb+NBYNAvQL08ic+lvB2IojljRYuun5vorUY=
google.golang.org/genproto v0.0.0-20230209215440-0dfe4f8abfcc h1:ijGwO+0vL2hJt5gaygqP2j6PfflOBrRot0IczKbmtio=
google.golang.org/genproto v0.0.0-20230209215440-0dfe4f8abfcc/go.mod h1:RGgjbofJ8xD9Sq1VVhDM1Vok1vRONV+rg+CjzG4SZKM=
google.golang.org/grpc v1.53.0 h1:LAv2ds7cmFV/XTS3XG1NneeENYrXGmorPxsBbptIjNc=
google.golang.org/grpc v1.53.0/go.mod h1:OnIrk0ipVdj4N5d9IUoFUx72/VlD7+jUsHwZgwSMQpw=
google.golang.org/protobuf v1.26.0-rc.1/go.mod h1:jlhhOSvTdKEhbULTjvd4ARK9grFBp09yW+WbY/TyQbw=
google.golang.org/protobuf v1.26.0/go.mod h1:9q0QmTI4eRPtz6boOQmLYwt+qCgq0jsYwAQnmE0givc=
google.golang.org/protobuf v1.28.1 h1:d0NfwRgPtno5B1Wa6L2DAG+KivqkdutMf1UhdNx175w=
Expand Down
36 changes: 22 additions & 14 deletions plugins/destination/azblob/client/client_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,6 @@ const storage_account = "cqdestinationazblob"
const container = "test"

func TestPluginCSV(t *testing.T) {
p := destination.NewPlugin("azblob", "development", New, destination.WithManagedWriter())
spec := Spec{
StorageAccount: storage_account,
Container: container,
Expand All @@ -22,20 +21,24 @@ func TestPluginCSV(t *testing.T) {
},
}
spec.SetDefaults()
destination.PluginTestSuiteRunner(t, p,
destination.PluginTestSuiteRunner(t,
func() *destination.Plugin {
return destination.NewPlugin("azblob", "development", New, destination.WithManagedWriter())
},
spec,
destination.PluginTestSuiteTests{
SkipOverwrite: true,
SkipDeleteStale: true,
SkipSecondAppend: true,
SkipMigrateAppend: true,
SkipMigrateOverwrite: true,
SkipOverwrite: true,
SkipDeleteStale: true,
SkipSecondAppend: true,
SkipMigrateAppend: true,
SkipMigrateOverwrite: true,
SkipMigrateOverwriteForce: true,
SkipMigrateAppendForce: true,
},
)
}

func TestPluginJSON(t *testing.T) {
p := destination.NewPlugin("azblob", "development", New, destination.WithManagedWriter())
spec := Spec{
StorageAccount: storage_account,
Container: container,
Expand All @@ -46,14 +49,19 @@ func TestPluginJSON(t *testing.T) {
},
}
spec.SetDefaults()
destination.PluginTestSuiteRunner(t, p,
destination.PluginTestSuiteRunner(t,
func() *destination.Plugin {
return destination.NewPlugin("azblob", "development", New, destination.WithManagedWriter())
},
spec,
destination.PluginTestSuiteTests{
SkipOverwrite: true,
SkipDeleteStale: true,
SkipSecondAppend: true,
SkipMigrateAppend: true,
SkipMigrateOverwrite: true,
SkipOverwrite: true,
SkipDeleteStale: true,
SkipSecondAppend: true,
SkipMigrateAppend: true,
SkipMigrateOverwrite: true,
SkipMigrateOverwriteForce: true,
SkipMigrateAppendForce: true,
},
)
}
2 changes: 1 addition & 1 deletion plugins/destination/azblob/go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ require (
github.com/Azure/azure-sdk-for-go/sdk/azidentity v1.2.1
github.com/Azure/azure-sdk-for-go/sdk/storage/azblob v0.6.1
github.com/cloudquery/filetypes v1.4.0
github.com/cloudquery/plugin-sdk v1.36.0
github.com/cloudquery/plugin-sdk v1.36.3
github.com/google/uuid v1.3.0
github.com/rs/zerolog v1.29.0
)
Expand Down
4 changes: 2 additions & 2 deletions plugins/destination/azblob/go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -163,8 +163,8 @@ github.com/chzyer/test v0.0.0-20180213035817-a1ea475d72b1/go.mod h1:Q3SI9o4m/ZMn
github.com/client9/misspell v0.3.4/go.mod h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDkc90ppPyw=
github.com/cloudquery/filetypes v1.4.0 h1:+cB6NtydOVB08o4b9qRJ4fVSfLnM3evLJk4TFxUWjhY=
github.com/cloudquery/filetypes v1.4.0/go.mod h1:AsMAvfqBOqjJOC11L+zkURuoa3GLyB6wKtBJRODKDlY=
github.com/cloudquery/plugin-sdk v1.36.0 h1:kp7jvQnU7CVNk77jBKNzBQ7NRuy+6+1U5UtnJYQrGnM=
github.com/cloudquery/plugin-sdk v1.36.0/go.mod h1:GEu6A0vJdV2ty3ssTiX64bPhkxVpnLGpuM1OhDvcHTk=
github.com/cloudquery/plugin-sdk v1.36.3 h1:mAkgE5SzsEVWuFCuiHRrUNg/6r7v9rolkNwDF3g6+sw=
github.com/cloudquery/plugin-sdk v1.36.3/go.mod h1:GEu6A0vJdV2ty3ssTiX64bPhkxVpnLGpuM1OhDvcHTk=
github.com/cncf/udpa/go v0.0.0-20191209042840-269d4d468f6f/go.mod h1:M8M6+tZqaGXZJjfX53e64911xZQV5JYwmTeXPW+k8Sc=
github.com/cncf/udpa/go v0.0.0-20200629203442-efcf912fb354/go.mod h1:WmhPx2Nbnhtbo57+VJT5O0JRkEi1Wbu0z5j0R8u5Hbk=
github.com/cncf/udpa/go v0.0.0-20201120205902-5459f2c99403/go.mod h1:WmhPx2Nbnhtbo57+VJT5O0JRkEi1Wbu0z5j0R8u5Hbk=
Expand Down
12 changes: 8 additions & 4 deletions plugins/destination/bigquery/client/client_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -8,15 +8,19 @@ import (
)

func TestPlugin(t *testing.T) {
p := destination.NewPlugin("bigquery", "development", New, destination.WithManagedWriter())
destination.PluginTestSuiteRunner(t, p,
destination.PluginTestSuiteRunner(t,
func() *destination.Plugin {
return destination.NewPlugin("bigquery", "development", New, destination.WithManagedWriter())
},
Spec{
ProjectID: os.Getenv("BIGQUERY_PROJECT_ID"),
DatasetID: os.Getenv("BIGQUERY_DATASET_ID"),
TimePartitioning: "none",
},
destination.PluginTestSuiteTests{
SkipOverwrite: true,
SkipMigrateOverwrite: true,
SkipOverwrite: true,
SkipMigrateOverwrite: true,
SkipMigrateOverwriteForce: true,
SkipMigrateAppendForce: true,
})
}
2 changes: 1 addition & 1 deletion plugins/destination/bigquery/go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ go 1.19

require (
cloud.google.com/go/bigquery v1.44.0
github.com/cloudquery/plugin-sdk v1.36.0
github.com/cloudquery/plugin-sdk v1.36.3
github.com/rs/zerolog v1.29.0
golang.org/x/sync v0.1.0
google.golang.org/api v0.107.0
Expand Down
4 changes: 2 additions & 2 deletions plugins/destination/bigquery/go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -53,8 +53,8 @@ github.com/chzyer/logex v1.1.10/go.mod h1:+Ywpsq7O8HXn0nuIou7OrIPyXbp3wmkHB+jjWR
github.com/chzyer/readline v0.0.0-20180603132655-2972be24d48e/go.mod h1:nSuG5e5PlCu98SY8svDHJxuZscDgtXS6KTTbou5AhLI=
github.com/chzyer/test v0.0.0-20180213035817-a1ea475d72b1/go.mod h1:Q3SI9o4m/ZMnBNeIyt5eFwwo7qiLfzFZmjNmxjkiQlU=
github.com/client9/misspell v0.3.4/go.mod h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDkc90ppPyw=
github.com/cloudquery/plugin-sdk v1.36.0 h1:kp7jvQnU7CVNk77jBKNzBQ7NRuy+6+1U5UtnJYQrGnM=
github.com/cloudquery/plugin-sdk v1.36.0/go.mod h1:GEu6A0vJdV2ty3ssTiX64bPhkxVpnLGpuM1OhDvcHTk=
github.com/cloudquery/plugin-sdk v1.36.3 h1:mAkgE5SzsEVWuFCuiHRrUNg/6r7v9rolkNwDF3g6+sw=
github.com/cloudquery/plugin-sdk v1.36.3/go.mod h1:GEu6A0vJdV2ty3ssTiX64bPhkxVpnLGpuM1OhDvcHTk=
github.com/cncf/udpa/go v0.0.0-20191209042840-269d4d468f6f/go.mod h1:M8M6+tZqaGXZJjfX53e64911xZQV5JYwmTeXPW+k8Sc=
github.com/cncf/udpa/go v0.0.0-20201120205902-5459f2c99403/go.mod h1:WmhPx2Nbnhtbo57+VJT5O0JRkEi1Wbu0z5j0R8u5Hbk=
github.com/coreos/go-systemd v0.0.0-20190321100706-95778dfbb74e/go.mod h1:F5haX7vjVVG0kc13fIWeqUViNPyEJxv/OmvnBo0Yme4=
Expand Down
11 changes: 8 additions & 3 deletions plugins/destination/elasticsearch/client/client_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -12,10 +12,15 @@ func TestPlugin(t *testing.T) {
if address == "" {
address = "http://localhost:9200"
}
p := destination.NewPlugin("elasticsearch", "development", New, destination.WithManagedWriter())
destination.PluginTestSuiteRunner(t, p,
destination.PluginTestSuiteRunner(t,
func() *destination.Plugin {
return destination.NewPlugin("elasticsearch", "development", New, destination.WithManagedWriter())
},
Spec{
Addresses: []string{address},
},
destination.PluginTestSuiteTests{})
destination.PluginTestSuiteTests{
SkipMigrateOverwriteForce: true,
SkipMigrateAppendForce: true,
})
}
2 changes: 1 addition & 1 deletion plugins/destination/elasticsearch/go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ go 1.19

require (
github.com/cenkalti/backoff/v4 v4.2.0
github.com/cloudquery/plugin-sdk v1.36.0
github.com/cloudquery/plugin-sdk v1.36.3
github.com/elastic/go-elasticsearch/v8 v8.6.0
github.com/rs/zerolog v1.29.0
github.com/segmentio/fasthash v1.0.3
Expand Down
4 changes: 2 additions & 2 deletions plugins/destination/elasticsearch/go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -42,8 +42,8 @@ github.com/chzyer/logex v1.1.10/go.mod h1:+Ywpsq7O8HXn0nuIou7OrIPyXbp3wmkHB+jjWR
github.com/chzyer/readline v0.0.0-20180603132655-2972be24d48e/go.mod h1:nSuG5e5PlCu98SY8svDHJxuZscDgtXS6KTTbou5AhLI=
github.com/chzyer/test v0.0.0-20180213035817-a1ea475d72b1/go.mod h1:Q3SI9o4m/ZMnBNeIyt5eFwwo7qiLfzFZmjNmxjkiQlU=
github.com/client9/misspell v0.3.4/go.mod h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDkc90ppPyw=
github.com/cloudquery/plugin-sdk v1.36.0 h1:kp7jvQnU7CVNk77jBKNzBQ7NRuy+6+1U5UtnJYQrGnM=
github.com/cloudquery/plugin-sdk v1.36.0/go.mod h1:GEu6A0vJdV2ty3ssTiX64bPhkxVpnLGpuM1OhDvcHTk=
github.com/cloudquery/plugin-sdk v1.36.3 h1:mAkgE5SzsEVWuFCuiHRrUNg/6r7v9rolkNwDF3g6+sw=
github.com/cloudquery/plugin-sdk v1.36.3/go.mod h1:GEu6A0vJdV2ty3ssTiX64bPhkxVpnLGpuM1OhDvcHTk=
github.com/cncf/udpa/go v0.0.0-20191209042840-269d4d468f6f/go.mod h1:M8M6+tZqaGXZJjfX53e64911xZQV5JYwmTeXPW+k8Sc=
github.com/cncf/udpa/go v0.0.0-20201120205902-5459f2c99403/go.mod h1:WmhPx2Nbnhtbo57+VJT5O0JRkEi1Wbu0z5j0R8u5Hbk=
github.com/coreos/go-systemd v0.0.0-20190321100706-95778dfbb74e/go.mod h1:F5haX7vjVVG0kc13fIWeqUViNPyEJxv/OmvnBo0Yme4=
Expand Down
51 changes: 30 additions & 21 deletions plugins/destination/file/client/client_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,55 +7,64 @@ import (
)

func TestPluginCSV(t *testing.T) {
p := destination.NewPlugin("file", "development", New, destination.WithManagedWriter())

destination.PluginTestSuiteRunner(t, p,
destination.PluginTestSuiteRunner(t,
func() *destination.Plugin {
return destination.NewPlugin("file", "development", New, destination.WithManagedWriter())
},
Spec{
Directory: t.TempDir(),
Format: FormatTypeCSV,
NoRotate: true,
},
destination.PluginTestSuiteTests{
SkipOverwrite: true,
SkipDeleteStale: true,
SkipMigrateAppend: true,
SkipMigrateOverwrite: true,
SkipOverwrite: true,
SkipDeleteStale: true,
SkipMigrateAppend: true,
SkipMigrateOverwrite: true,
SkipMigrateOverwriteForce: true,
SkipMigrateAppendForce: true,
},
)
}

func TestPluginJSON(t *testing.T) {
p := destination.NewPlugin("file", "development", New, destination.WithManagedWriter())

destination.PluginTestSuiteRunner(t, p,
destination.PluginTestSuiteRunner(t,
func() *destination.Plugin {
return destination.NewPlugin("file", "development", New, destination.WithManagedWriter())
},
Spec{
Directory: t.TempDir(),
Format: FormatTypeJSON,
NoRotate: true,
},
destination.PluginTestSuiteTests{
SkipOverwrite: true,
SkipDeleteStale: true,
SkipMigrateOverwrite: true,
SkipOverwrite: true,
SkipDeleteStale: true,
SkipMigrateOverwrite: true,
SkipMigrateOverwriteForce: true,
SkipMigrateAppendForce: true,
},
)
}

func TestPluginParquet(t *testing.T) {
p := destination.NewPlugin("file", "development", New, destination.WithManagedWriter())

destination.PluginTestSuiteRunner(t, p,
destination.PluginTestSuiteRunner(t,
func() *destination.Plugin {
return destination.NewPlugin("file", "development", New, destination.WithManagedWriter())
},
Spec{
Directory: t.TempDir(),
Format: FormatTypeParquet,
NoRotate: true,
},
destination.PluginTestSuiteTests{
SkipOverwrite: true,
SkipDeleteStale: true,
SkipSecondAppend: true,
SkipMigrateAppend: true,
SkipMigrateOverwrite: true,
SkipOverwrite: true,
SkipDeleteStale: true,
SkipSecondAppend: true,
SkipMigrateAppend: true,
SkipMigrateOverwrite: true,
SkipMigrateOverwriteForce: true,
SkipMigrateAppendForce: true,
},
)
}
2 changes: 1 addition & 1 deletion plugins/destination/file/go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@ go 1.19

require (
github.com/cloudquery/filetypes v1.4.0
github.com/cloudquery/plugin-sdk v1.36.0
github.com/cloudquery/plugin-sdk v1.36.3
github.com/google/uuid v1.3.0
github.com/rs/zerolog v1.29.0
)
Expand Down
4 changes: 2 additions & 2 deletions plugins/destination/file/go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -153,8 +153,8 @@ github.com/chzyer/test v0.0.0-20180213035817-a1ea475d72b1/go.mod h1:Q3SI9o4m/ZMn
github.com/client9/misspell v0.3.4/go.mod h1:qj6jICC3Q7zFZvVWo7KLAzC3yx5G7kyvSDkc90ppPyw=
github.com/cloudquery/filetypes v1.4.0 h1:+cB6NtydOVB08o4b9qRJ4fVSfLnM3evLJk4TFxUWjhY=
github.com/cloudquery/filetypes v1.4.0/go.mod h1:AsMAvfqBOqjJOC11L+zkURuoa3GLyB6wKtBJRODKDlY=
github.com/cloudquery/plugin-sdk v1.36.0 h1:kp7jvQnU7CVNk77jBKNzBQ7NRuy+6+1U5UtnJYQrGnM=
github.com/cloudquery/plugin-sdk v1.36.0/go.mod h1:GEu6A0vJdV2ty3ssTiX64bPhkxVpnLGpuM1OhDvcHTk=
github.com/cloudquery/plugin-sdk v1.36.3 h1:mAkgE5SzsEVWuFCuiHRrUNg/6r7v9rolkNwDF3g6+sw=
github.com/cloudquery/plugin-sdk v1.36.3/go.mod h1:GEu6A0vJdV2ty3ssTiX64bPhkxVpnLGpuM1OhDvcHTk=
github.com/cncf/udpa/go v0.0.0-20191209042840-269d4d468f6f/go.mod h1:M8M6+tZqaGXZJjfX53e64911xZQV5JYwmTeXPW+k8Sc=
github.com/cncf/udpa/go v0.0.0-20200629203442-efcf912fb354/go.mod h1:WmhPx2Nbnhtbo57+VJT5O0JRkEi1Wbu0z5j0R8u5Hbk=
github.com/cncf/udpa/go v0.0.0-20201120205902-5459f2c99403/go.mod h1:WmhPx2Nbnhtbo57+VJT5O0JRkEi1Wbu0z5j0R8u5Hbk=
Expand Down
Loading