From c1a8fa36a101cea16e7daa416899dd6a985b4017 Mon Sep 17 00:00:00 2001 From: CloudQuery Bot <102256036+cq-bot@users.noreply.github.com> Date: Tue, 17 Dec 2024 10:35:36 +0200 Subject: [PATCH] fix: Generate Go Code from `plugin-pb` (#449) This PR was created by a scheduled workflow to regenerate the Go code from `plugin-pb`. --- pb/base/v0/base.pb.go | 67 ++--- pb/destination/v0/destination.pb.go | 113 ++++---- pb/destination/v1/destination.pb.go | 136 +++++---- pb/discovery/v0/discovery.pb.go | 17 +- pb/discovery/v1/discovery.pb.go | 17 +- pb/plugin/v3/plugin.pb.go | 431 ++++++++++++++-------------- pb/source/v0/source.pb.go | 127 ++++---- pb/source/v1/source.pb.go | 138 +++++---- pb/source/v2/source.pb.go | 141 +++++---- 9 files changed, 562 insertions(+), 625 deletions(-) diff --git a/pb/base/v0/base.pb.go b/pb/base/v0/base.pb.go index 6b0304b..5d491db 100644 --- a/pb/base/v0/base.pb.go +++ b/pb/base/v0/base.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.35.2 +// protoc-gen-go v1.36.0 // protoc v4.23.4 // source: plugin-pb/base/v0/base.proto @@ -21,9 +21,9 @@ const ( ) type GetName struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetName) Reset() { @@ -57,9 +57,9 @@ func (*GetName) Descriptor() ([]byte, []int) { } type GetVersion struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetVersion) Reset() { @@ -93,9 +93,9 @@ func (*GetVersion) Descriptor() ([]byte, []int) { } type GetProtocolVersion struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetProtocolVersion) Reset() { @@ -129,9 +129,9 @@ func (*GetProtocolVersion) Descriptor() ([]byte, []int) { } type Configure struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Configure) Reset() { @@ -165,9 +165,9 @@ func (*Configure) Descriptor() ([]byte, []int) { } type GetName_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetName_Request) Reset() { @@ -201,11 +201,10 @@ func (*GetName_Request) Descriptor() ([]byte, []int) { } type GetName_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` unknownFields protoimpl.UnknownFields - - Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` + sizeCache protoimpl.SizeCache } func (x *GetName_Response) Reset() { @@ -246,9 +245,9 @@ func (x *GetName_Response) GetName() string { } type GetVersion_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetVersion_Request) Reset() { @@ -282,11 +281,10 @@ func (*GetVersion_Request) Descriptor() ([]byte, []int) { } type GetVersion_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` unknownFields protoimpl.UnknownFields - - Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` + sizeCache protoimpl.SizeCache } func (x *GetVersion_Response) Reset() { @@ -327,9 +325,9 @@ func (x *GetVersion_Response) GetVersion() string { } type GetProtocolVersion_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetProtocolVersion_Request) Reset() { @@ -363,11 +361,10 @@ func (*GetProtocolVersion_Request) Descriptor() ([]byte, []int) { } type GetProtocolVersion_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Version uint64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"` unknownFields protoimpl.UnknownFields - - Version uint64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"` + sizeCache protoimpl.SizeCache } func (x *GetProtocolVersion_Response) Reset() { @@ -408,13 +405,12 @@ func (x *GetProtocolVersion_Response) GetVersion() uint64 { } type Configure_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // Holds information such as credentials, regions, accounts, etc' // Marshalled spec.SourceSpec or spec.DestinationSpec - Config []byte `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"` + Config []byte `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Configure_Request) Reset() { @@ -455,11 +451,10 @@ func (x *Configure_Request) GetConfig() []byte { } type Configure_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` unknownFields protoimpl.UnknownFields - - Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` + sizeCache protoimpl.SizeCache } func (x *Configure_Response) Reset() { diff --git a/pb/destination/v0/destination.pb.go b/pb/destination/v0/destination.pb.go index 9fec6d8..f765a67 100644 --- a/pb/destination/v0/destination.pb.go +++ b/pb/destination/v0/destination.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.35.2 +// protoc-gen-go v1.36.0 // protoc v4.23.4 // source: plugin-pb/destination/v0/destination.proto @@ -23,9 +23,9 @@ const ( ) type Migrate struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Migrate) Reset() { @@ -59,9 +59,9 @@ func (*Migrate) Descriptor() ([]byte, []int) { } type Write struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Write) Reset() { @@ -95,9 +95,9 @@ func (*Write) Descriptor() ([]byte, []int) { } type Write2 struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Write2) Reset() { @@ -131,9 +131,9 @@ func (*Write2) Descriptor() ([]byte, []int) { } type Close struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Close) Reset() { @@ -167,9 +167,9 @@ func (*Close) Descriptor() ([]byte, []int) { } type DeleteStale struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *DeleteStale) Reset() { @@ -203,9 +203,9 @@ func (*DeleteStale) Descriptor() ([]byte, []int) { } type GetDestinationMetrics struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetDestinationMetrics) Reset() { @@ -239,13 +239,12 @@ func (*GetDestinationMetrics) Descriptor() ([]byte, []int) { } type Migrate_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` + Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` + Tables []byte `protobuf:"bytes,3,opt,name=tables,proto3" json:"tables,omitempty"` unknownFields protoimpl.UnknownFields - - Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` - Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` - Tables []byte `protobuf:"bytes,3,opt,name=tables,proto3" json:"tables,omitempty"` + sizeCache protoimpl.SizeCache } func (x *Migrate_Request) Reset() { @@ -300,9 +299,9 @@ func (x *Migrate_Request) GetTables() []byte { } type Migrate_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Migrate_Response) Reset() { @@ -336,14 +335,13 @@ func (*Migrate_Response) Descriptor() ([]byte, []int) { } type Write_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // marshalled *schema.Resources - Resource []byte `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"` - Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"` - Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` + Resource []byte `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"` + Source string `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"` + Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Write_Request) Reset() { @@ -398,11 +396,10 @@ func (x *Write_Request) GetTimestamp() *timestamppb.Timestamp { } type Write_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + FailedWrites uint64 `protobuf:"varint,1,opt,name=failed_writes,json=failedWrites,proto3" json:"failed_writes,omitempty"` unknownFields protoimpl.UnknownFields - - FailedWrites uint64 `protobuf:"varint,1,opt,name=failed_writes,json=failedWrites,proto3" json:"failed_writes,omitempty"` + sizeCache protoimpl.SizeCache } func (x *Write_Response) Reset() { @@ -443,10 +440,7 @@ func (x *Write_Response) GetFailedWrites() uint64 { } type Write2_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"` Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // marshaled schema.Tables @@ -454,7 +448,9 @@ type Write2_Request struct { // marshalled *schema.Resources Resource []byte `protobuf:"bytes,4,opt,name=resource,proto3" json:"resource,omitempty"` // marshalled specs.Source - SourceSpec []byte `protobuf:"bytes,5,opt,name=source_spec,json=sourceSpec,proto3" json:"source_spec,omitempty"` + SourceSpec []byte `protobuf:"bytes,5,opt,name=source_spec,json=sourceSpec,proto3" json:"source_spec,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Write2_Request) Reset() { @@ -523,9 +519,9 @@ func (x *Write2_Request) GetSourceSpec() []byte { } type Write2_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Write2_Response) Reset() { @@ -559,9 +555,9 @@ func (*Write2_Response) Descriptor() ([]byte, []int) { } type Close_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Close_Request) Reset() { @@ -595,9 +591,9 @@ func (*Close_Request) Descriptor() ([]byte, []int) { } type Close_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Close_Response) Reset() { @@ -631,13 +627,12 @@ func (*Close_Response) Descriptor() ([]byte, []int) { } type DeleteStale_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"` + Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` + Tables []byte `protobuf:"bytes,3,opt,name=tables,proto3" json:"tables,omitempty"` unknownFields protoimpl.UnknownFields - - Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"` - Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` - Tables []byte `protobuf:"bytes,3,opt,name=tables,proto3" json:"tables,omitempty"` + sizeCache protoimpl.SizeCache } func (x *DeleteStale_Request) Reset() { @@ -692,11 +687,10 @@ func (x *DeleteStale_Request) GetTables() []byte { } type DeleteStale_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + FailedDeletes uint64 `protobuf:"varint,1,opt,name=failed_deletes,json=failedDeletes,proto3" json:"failed_deletes,omitempty"` unknownFields protoimpl.UnknownFields - - FailedDeletes uint64 `protobuf:"varint,1,opt,name=failed_deletes,json=failedDeletes,proto3" json:"failed_deletes,omitempty"` + sizeCache protoimpl.SizeCache } func (x *DeleteStale_Response) Reset() { @@ -737,9 +731,9 @@ func (x *DeleteStale_Response) GetFailedDeletes() uint64 { } type GetDestinationMetrics_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetDestinationMetrics_Request) Reset() { @@ -773,12 +767,11 @@ func (*GetDestinationMetrics_Request) Descriptor() ([]byte, []int) { } type GetDestinationMetrics_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // marshalled json of plugins.DestinationMetrics - Metrics []byte `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"` + Metrics []byte `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetDestinationMetrics_Response) Reset() { diff --git a/pb/destination/v1/destination.pb.go b/pb/destination/v1/destination.pb.go index d8492a3..bc6c722 100644 --- a/pb/destination/v1/destination.pb.go +++ b/pb/destination/v1/destination.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.35.2 +// protoc-gen-go v1.36.0 // protoc v4.23.4 // source: plugin-pb/destination/v1/destination.proto @@ -22,9 +22,9 @@ const ( ) type GetName struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetName) Reset() { @@ -58,9 +58,9 @@ func (*GetName) Descriptor() ([]byte, []int) { } type GetVersion struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetVersion) Reset() { @@ -94,9 +94,9 @@ func (*GetVersion) Descriptor() ([]byte, []int) { } type Configure struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Configure) Reset() { @@ -130,9 +130,9 @@ func (*Configure) Descriptor() ([]byte, []int) { } type Migrate struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Migrate) Reset() { @@ -166,9 +166,9 @@ func (*Migrate) Descriptor() ([]byte, []int) { } type Write struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Write) Reset() { @@ -202,9 +202,9 @@ func (*Write) Descriptor() ([]byte, []int) { } type Close struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Close) Reset() { @@ -238,9 +238,9 @@ func (*Close) Descriptor() ([]byte, []int) { } type DeleteStale struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *DeleteStale) Reset() { @@ -274,9 +274,9 @@ func (*DeleteStale) Descriptor() ([]byte, []int) { } type GetDestinationMetrics struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetDestinationMetrics) Reset() { @@ -310,9 +310,9 @@ func (*GetDestinationMetrics) Descriptor() ([]byte, []int) { } type GetName_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetName_Request) Reset() { @@ -346,11 +346,10 @@ func (*GetName_Request) Descriptor() ([]byte, []int) { } type GetName_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` unknownFields protoimpl.UnknownFields - - Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` + sizeCache protoimpl.SizeCache } func (x *GetName_Response) Reset() { @@ -391,9 +390,9 @@ func (x *GetName_Response) GetName() string { } type GetVersion_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetVersion_Request) Reset() { @@ -427,11 +426,10 @@ func (*GetVersion_Request) Descriptor() ([]byte, []int) { } type GetVersion_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` unknownFields protoimpl.UnknownFields - - Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` + sizeCache protoimpl.SizeCache } func (x *GetVersion_Response) Reset() { @@ -472,13 +470,12 @@ func (x *GetVersion_Response) GetVersion() string { } type Configure_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // Holds information such as credentials, regions, accounts, etc' // Marshalled spec.SourceSpec or spec.DestinationSpec - Config []byte `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"` + Config []byte `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Configure_Request) Reset() { @@ -519,9 +516,9 @@ func (x *Configure_Request) GetConfig() []byte { } type Configure_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Configure_Response) Reset() { @@ -555,13 +552,12 @@ func (*Configure_Response) Descriptor() ([]byte, []int) { } type Migrate_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` + Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` + Tables [][]byte `protobuf:"bytes,3,rep,name=tables,proto3" json:"tables,omitempty"` unknownFields protoimpl.UnknownFields - - Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` - Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` - Tables [][]byte `protobuf:"bytes,3,rep,name=tables,proto3" json:"tables,omitempty"` + sizeCache protoimpl.SizeCache } func (x *Migrate_Request) Reset() { @@ -616,9 +612,9 @@ func (x *Migrate_Request) GetTables() [][]byte { } type Migrate_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Migrate_Response) Reset() { @@ -652,10 +648,7 @@ func (*Migrate_Response) Descriptor() ([]byte, []int) { } type Write_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"` Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // marshaled arrow.schema @@ -663,7 +656,9 @@ type Write_Request struct { // marshalled *schema.Resources Resource []byte `protobuf:"bytes,4,opt,name=resource,proto3" json:"resource,omitempty"` // marshalled specs.Source - SourceSpec []byte `protobuf:"bytes,5,opt,name=source_spec,json=sourceSpec,proto3" json:"source_spec,omitempty"` + SourceSpec []byte `protobuf:"bytes,5,opt,name=source_spec,json=sourceSpec,proto3" json:"source_spec,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Write_Request) Reset() { @@ -732,9 +727,9 @@ func (x *Write_Request) GetSourceSpec() []byte { } type Write_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Write_Response) Reset() { @@ -768,9 +763,9 @@ func (*Write_Response) Descriptor() ([]byte, []int) { } type Close_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Close_Request) Reset() { @@ -804,9 +799,9 @@ func (*Close_Request) Descriptor() ([]byte, []int) { } type Close_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Close_Response) Reset() { @@ -840,13 +835,12 @@ func (*Close_Response) Descriptor() ([]byte, []int) { } type DeleteStale_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"` + Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` + Tables [][]byte `protobuf:"bytes,3,rep,name=tables,proto3" json:"tables,omitempty"` unknownFields protoimpl.UnknownFields - - Source string `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"` - Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` - Tables [][]byte `protobuf:"bytes,3,rep,name=tables,proto3" json:"tables,omitempty"` + sizeCache protoimpl.SizeCache } func (x *DeleteStale_Request) Reset() { @@ -901,11 +895,10 @@ func (x *DeleteStale_Request) GetTables() [][]byte { } type DeleteStale_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + FailedDeletes uint64 `protobuf:"varint,1,opt,name=failed_deletes,json=failedDeletes,proto3" json:"failed_deletes,omitempty"` unknownFields protoimpl.UnknownFields - - FailedDeletes uint64 `protobuf:"varint,1,opt,name=failed_deletes,json=failedDeletes,proto3" json:"failed_deletes,omitempty"` + sizeCache protoimpl.SizeCache } func (x *DeleteStale_Response) Reset() { @@ -946,9 +939,9 @@ func (x *DeleteStale_Response) GetFailedDeletes() uint64 { } type GetDestinationMetrics_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetDestinationMetrics_Request) Reset() { @@ -982,12 +975,11 @@ func (*GetDestinationMetrics_Request) Descriptor() ([]byte, []int) { } type GetDestinationMetrics_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // marshalled json of plugins.DestinationMetrics - Metrics []byte `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"` + Metrics []byte `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetDestinationMetrics_Response) Reset() { diff --git a/pb/discovery/v0/discovery.pb.go b/pb/discovery/v0/discovery.pb.go index 70dd03e..3df3137 100644 --- a/pb/discovery/v0/discovery.pb.go +++ b/pb/discovery/v0/discovery.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.35.2 +// protoc-gen-go v1.36.0 // protoc v4.23.4 // source: plugin-pb/discovery/v0/discovery.proto @@ -21,9 +21,9 @@ const ( ) type GetVersions struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetVersions) Reset() { @@ -57,9 +57,9 @@ func (*GetVersions) Descriptor() ([]byte, []int) { } type GetVersions_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetVersions_Request) Reset() { @@ -93,11 +93,10 @@ func (*GetVersions_Request) Descriptor() ([]byte, []int) { } type GetVersions_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Versions []string `protobuf:"bytes,1,rep,name=versions,proto3" json:"versions,omitempty"` unknownFields protoimpl.UnknownFields - - Versions []string `protobuf:"bytes,1,rep,name=versions,proto3" json:"versions,omitempty"` + sizeCache protoimpl.SizeCache } func (x *GetVersions_Response) Reset() { diff --git a/pb/discovery/v1/discovery.pb.go b/pb/discovery/v1/discovery.pb.go index 7f6fefc..9234b15 100644 --- a/pb/discovery/v1/discovery.pb.go +++ b/pb/discovery/v1/discovery.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.35.2 +// protoc-gen-go v1.36.0 // protoc v4.23.4 // source: plugin-pb/discovery/v1/discovery.proto @@ -21,9 +21,9 @@ const ( ) type GetVersions struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetVersions) Reset() { @@ -57,9 +57,9 @@ func (*GetVersions) Descriptor() ([]byte, []int) { } type GetVersions_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetVersions_Request) Reset() { @@ -93,11 +93,10 @@ func (*GetVersions_Request) Descriptor() ([]byte, []int) { } type GetVersions_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Versions []int32 `protobuf:"varint,1,rep,packed,name=versions,proto3" json:"versions,omitempty"` unknownFields protoimpl.UnknownFields - - Versions []int32 `protobuf:"varint,1,rep,packed,name=versions,proto3" json:"versions,omitempty"` + sizeCache protoimpl.SizeCache } func (x *GetVersions_Response) Reset() { diff --git a/pb/plugin/v3/plugin.pb.go b/pb/plugin/v3/plugin.pb.go index ea16929..57aab94 100644 --- a/pb/plugin/v3/plugin.pb.go +++ b/pb/plugin/v3/plugin.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.35.2 +// protoc-gen-go v1.36.0 // protoc v4.23.4 // source: plugin-pb/plugin/v3/plugin.proto @@ -111,9 +111,9 @@ func (PredicatesGroup_GroupingType) EnumDescriptor() ([]byte, []int) { } type GetName struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetName) Reset() { @@ -147,9 +147,9 @@ func (*GetName) Descriptor() ([]byte, []int) { } type GetVersion struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetVersion) Reset() { @@ -183,9 +183,9 @@ func (*GetVersion) Descriptor() ([]byte, []int) { } type GetSpecSchema struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetSpecSchema) Reset() { @@ -219,9 +219,9 @@ func (*GetSpecSchema) Descriptor() ([]byte, []int) { } type Init struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Init) Reset() { @@ -255,9 +255,9 @@ func (*Init) Descriptor() ([]byte, []int) { } type GetTables struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetTables) Reset() { @@ -291,9 +291,9 @@ func (*GetTables) Descriptor() ([]byte, []int) { } type Sync struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Sync) Reset() { @@ -327,9 +327,9 @@ func (*Sync) Descriptor() ([]byte, []int) { } type Read struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Read) Reset() { @@ -363,12 +363,11 @@ func (*Read) Descriptor() ([]byte, []int) { } type TableRelation struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` + ParentTable string `protobuf:"bytes,2,opt,name=parent_table,json=parentTable,proto3" json:"parent_table,omitempty"` unknownFields protoimpl.UnknownFields - - TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` - ParentTable string `protobuf:"bytes,2,opt,name=parent_table,json=parentTable,proto3" json:"parent_table,omitempty"` + sizeCache protoimpl.SizeCache } func (x *TableRelation) Reset() { @@ -416,14 +415,13 @@ func (x *TableRelation) GetParentTable() string { } type Predicate struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Operator Predicate_Operator `protobuf:"varint,1,opt,name=operator,proto3,enum=cloudquery.plugin.v3.Predicate_Operator" json:"operator,omitempty"` - Column string `protobuf:"bytes,2,opt,name=column,proto3" json:"column,omitempty"` + state protoimpl.MessageState `protogen:"open.v1"` + Operator Predicate_Operator `protobuf:"varint,1,opt,name=operator,proto3,enum=cloudquery.plugin.v3.Predicate_Operator" json:"operator,omitempty"` + Column string `protobuf:"bytes,2,opt,name=column,proto3" json:"column,omitempty"` // marshalled arrow.Record - Record []byte `protobuf:"bytes,3,opt,name=record,proto3" json:"record,omitempty"` + Record []byte `protobuf:"bytes,3,opt,name=record,proto3" json:"record,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Predicate) Reset() { @@ -478,12 +476,11 @@ func (x *Predicate) GetRecord() []byte { } type PredicatesGroup struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + GroupingType PredicatesGroup_GroupingType `protobuf:"varint,1,opt,name=grouping_type,json=groupingType,proto3,enum=cloudquery.plugin.v3.PredicatesGroup_GroupingType" json:"grouping_type,omitempty"` + Predicates []*Predicate `protobuf:"bytes,2,rep,name=predicates,proto3" json:"predicates,omitempty"` unknownFields protoimpl.UnknownFields - - GroupingType PredicatesGroup_GroupingType `protobuf:"varint,1,opt,name=grouping_type,json=groupingType,proto3,enum=cloudquery.plugin.v3.PredicatesGroup_GroupingType" json:"grouping_type,omitempty"` - Predicates []*Predicate `protobuf:"bytes,2,rep,name=predicates,proto3" json:"predicates,omitempty"` + sizeCache protoimpl.SizeCache } func (x *PredicatesGroup) Reset() { @@ -531,9 +528,9 @@ func (x *PredicatesGroup) GetPredicates() []*Predicate { } type Write struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Write) Reset() { @@ -567,9 +564,9 @@ func (*Write) Descriptor() ([]byte, []int) { } type Transform struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Transform) Reset() { @@ -603,9 +600,9 @@ func (*Transform) Descriptor() ([]byte, []int) { } type TransformSchema struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *TransformSchema) Reset() { @@ -639,9 +636,9 @@ func (*TransformSchema) Descriptor() ([]byte, []int) { } type Close struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Close) Reset() { @@ -675,9 +672,9 @@ func (*Close) Descriptor() ([]byte, []int) { } type TestConnection struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *TestConnection) Reset() { @@ -711,9 +708,9 @@ func (*TestConnection) Descriptor() ([]byte, []int) { } type GetName_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetName_Request) Reset() { @@ -747,11 +744,10 @@ func (*GetName_Request) Descriptor() ([]byte, []int) { } type GetName_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` unknownFields protoimpl.UnknownFields - - Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` + sizeCache protoimpl.SizeCache } func (x *GetName_Response) Reset() { @@ -792,9 +788,9 @@ func (x *GetName_Response) GetName() string { } type GetVersion_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetVersion_Request) Reset() { @@ -828,11 +824,10 @@ func (*GetVersion_Request) Descriptor() ([]byte, []int) { } type GetVersion_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` unknownFields protoimpl.UnknownFields - - Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` + sizeCache protoimpl.SizeCache } func (x *GetVersion_Response) Reset() { @@ -873,9 +868,9 @@ func (x *GetVersion_Response) GetVersion() string { } type GetSpecSchema_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetSpecSchema_Request) Reset() { @@ -909,13 +904,12 @@ func (*GetSpecSchema_Request) Descriptor() ([]byte, []int) { } type GetSpecSchema_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // Should be a valid JSON schema for the plugin spec. // See https://json-schema.org for more details. - JsonSchema *string `protobuf:"bytes,1,opt,name=json_schema,json=jsonSchema,proto3,oneof" json:"json_schema,omitempty"` + JsonSchema *string `protobuf:"bytes,1,opt,name=json_schema,json=jsonSchema,proto3,oneof" json:"json_schema,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetSpecSchema_Response) Reset() { @@ -956,13 +950,12 @@ func (x *GetSpecSchema_Response) GetJsonSchema() string { } type Init_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Spec []byte `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` // Internal plugin-specific spec + NoConnection bool `protobuf:"varint,2,opt,name=no_connection,json=noConnection,proto3" json:"no_connection,omitempty"` // A flag to indicate plugins should skip establishing a connection + InvocationId string `protobuf:"bytes,3,opt,name=invocation_id,json=invocationId,proto3" json:"invocation_id,omitempty"` // unique execution_id that will identify the invocation (sync, migrate etc) unknownFields protoimpl.UnknownFields - - Spec []byte `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` // Internal plugin-specific spec - NoConnection bool `protobuf:"varint,2,opt,name=no_connection,json=noConnection,proto3" json:"no_connection,omitempty"` // A flag to indicate plugins should skip establishing a connection - InvocationId string `protobuf:"bytes,3,opt,name=invocation_id,json=invocationId,proto3" json:"invocation_id,omitempty"` // unique execution_id that will identify the invocation (sync, migrate etc) + sizeCache protoimpl.SizeCache } func (x *Init_Request) Reset() { @@ -1017,9 +1010,9 @@ func (x *Init_Request) GetInvocationId() string { } type Init_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Init_Response) Reset() { @@ -1053,13 +1046,12 @@ func (*Init_Response) Descriptor() ([]byte, []int) { } type GetTables_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Tables []string `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"` - SkipTables []string `protobuf:"bytes,2,rep,name=skip_tables,json=skipTables,proto3" json:"skip_tables,omitempty"` - SkipDependentTables bool `protobuf:"varint,3,opt,name=skip_dependent_tables,json=skipDependentTables,proto3" json:"skip_dependent_tables,omitempty"` + state protoimpl.MessageState `protogen:"open.v1"` + Tables []string `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"` + SkipTables []string `protobuf:"bytes,2,rep,name=skip_tables,json=skipTables,proto3" json:"skip_tables,omitempty"` + SkipDependentTables bool `protobuf:"varint,3,opt,name=skip_dependent_tables,json=skipDependentTables,proto3" json:"skip_dependent_tables,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetTables_Request) Reset() { @@ -1114,12 +1106,11 @@ func (x *GetTables_Request) GetSkipDependentTables() bool { } type GetTables_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // marshalled []arrow.Schema - Tables [][]byte `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"` + Tables [][]byte `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetTables_Response) Reset() { @@ -1160,12 +1151,11 @@ func (x *GetTables_Response) GetTables() [][]byte { } type Sync_MessageInsert struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // marshalled arrow.Record - Record []byte `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"` + Record []byte `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Sync_MessageInsert) Reset() { @@ -1206,12 +1196,11 @@ func (x *Sync_MessageInsert) GetRecord() []byte { } type Sync_MessageMigrateTable struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // marshalled arrow.Schema - Table []byte `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"` + Table []byte `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Sync_MessageMigrateTable) Reset() { @@ -1252,13 +1241,12 @@ func (x *Sync_MessageMigrateTable) GetTable() []byte { } type Sync_MessageDeleteRecord struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` - WhereClause []*PredicatesGroup `protobuf:"bytes,2,rep,name=where_clause,json=whereClause,proto3" json:"where_clause,omitempty"` - TableRelations []*TableRelation `protobuf:"bytes,3,rep,name=table_relations,json=tableRelations,proto3" json:"table_relations,omitempty"` + state protoimpl.MessageState `protogen:"open.v1"` + TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` + WhereClause []*PredicatesGroup `protobuf:"bytes,2,rep,name=where_clause,json=whereClause,proto3" json:"where_clause,omitempty"` + TableRelations []*TableRelation `protobuf:"bytes,3,rep,name=table_relations,json=tableRelations,proto3" json:"table_relations,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Sync_MessageDeleteRecord) Reset() { @@ -1313,14 +1301,13 @@ func (x *Sync_MessageDeleteRecord) GetTableRelations() []*TableRelation { } type Sync_BackendOptions struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // table name to use for state backend TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` // connection path to use for state backend - Connection string `protobuf:"bytes,2,opt,name=connection,proto3" json:"connection,omitempty"` + Connection string `protobuf:"bytes,2,opt,name=connection,proto3" json:"connection,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Sync_BackendOptions) Reset() { @@ -1368,16 +1355,15 @@ func (x *Sync_BackendOptions) GetConnection() string { } type Sync_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Tables []string `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"` - SkipTables []string `protobuf:"bytes,2,rep,name=skip_tables,json=skipTables,proto3" json:"skip_tables,omitempty"` - SkipDependentTables bool `protobuf:"varint,3,opt,name=skip_dependent_tables,json=skipDependentTables,proto3" json:"skip_dependent_tables,omitempty"` - DeterministicCqId bool `protobuf:"varint,4,opt,name=deterministic_cq_id,json=deterministicCqId,proto3" json:"deterministic_cq_id,omitempty"` - Backend *Sync_BackendOptions `protobuf:"bytes,5,opt,name=backend,proto3" json:"backend,omitempty"` - Shard *Sync_Request_Shard `protobuf:"bytes,6,opt,name=shard,proto3,oneof" json:"shard,omitempty"` + state protoimpl.MessageState `protogen:"open.v1"` + Tables []string `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"` + SkipTables []string `protobuf:"bytes,2,rep,name=skip_tables,json=skipTables,proto3" json:"skip_tables,omitempty"` + SkipDependentTables bool `protobuf:"varint,3,opt,name=skip_dependent_tables,json=skipDependentTables,proto3" json:"skip_dependent_tables,omitempty"` + DeterministicCqId bool `protobuf:"varint,4,opt,name=deterministic_cq_id,json=deterministicCqId,proto3" json:"deterministic_cq_id,omitempty"` + Backend *Sync_BackendOptions `protobuf:"bytes,5,opt,name=backend,proto3" json:"backend,omitempty"` + Shard *Sync_Request_Shard `protobuf:"bytes,6,opt,name=shard,proto3,oneof" json:"shard,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Sync_Request) Reset() { @@ -1453,16 +1439,15 @@ func (x *Sync_Request) GetShard() *Sync_Request_Shard { } type Sync_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - // Types that are assignable to Message: + state protoimpl.MessageState `protogen:"open.v1"` + // Types that are valid to be assigned to Message: // // *Sync_Response_MigrateTable // *Sync_Response_Insert // *Sync_Response_DeleteRecord - Message isSync_Response_Message `protobuf_oneof:"message"` + Message isSync_Response_Message `protobuf_oneof:"message"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Sync_Response) Reset() { @@ -1495,30 +1480,36 @@ func (*Sync_Response) Descriptor() ([]byte, []int) { return file_plugin_pb_plugin_v3_plugin_proto_rawDescGZIP(), []int{5, 5} } -func (m *Sync_Response) GetMessage() isSync_Response_Message { - if m != nil { - return m.Message +func (x *Sync_Response) GetMessage() isSync_Response_Message { + if x != nil { + return x.Message } return nil } func (x *Sync_Response) GetMigrateTable() *Sync_MessageMigrateTable { - if x, ok := x.GetMessage().(*Sync_Response_MigrateTable); ok { - return x.MigrateTable + if x != nil { + if x, ok := x.Message.(*Sync_Response_MigrateTable); ok { + return x.MigrateTable + } } return nil } func (x *Sync_Response) GetInsert() *Sync_MessageInsert { - if x, ok := x.GetMessage().(*Sync_Response_Insert); ok { - return x.Insert + if x != nil { + if x, ok := x.Message.(*Sync_Response_Insert); ok { + return x.Insert + } } return nil } func (x *Sync_Response) GetDeleteRecord() *Sync_MessageDeleteRecord { - if x, ok := x.GetMessage().(*Sync_Response_DeleteRecord); ok { - return x.DeleteRecord + if x != nil { + if x, ok := x.Message.(*Sync_Response_DeleteRecord); ok { + return x.DeleteRecord + } } return nil } @@ -1546,12 +1537,11 @@ func (*Sync_Response_Insert) isSync_Response_Message() {} func (*Sync_Response_DeleteRecord) isSync_Response_Message() {} type Sync_Request_Shard struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Num int32 `protobuf:"varint,1,opt,name=num,proto3" json:"num,omitempty"` + Total int32 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"` unknownFields protoimpl.UnknownFields - - Num int32 `protobuf:"varint,1,opt,name=num,proto3" json:"num,omitempty"` - Total int32 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"` + sizeCache protoimpl.SizeCache } func (x *Sync_Request_Shard) Reset() { @@ -1599,12 +1589,11 @@ func (x *Sync_Request_Shard) GetTotal() int32 { } type Read_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // marshalled arrow.Schema - Table []byte `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"` + Table []byte `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Read_Request) Reset() { @@ -1645,12 +1634,11 @@ func (x *Read_Request) GetTable() []byte { } type Read_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // marshalled arrow.Record - Record []byte `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"` + Record []byte `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Read_Response) Reset() { @@ -1691,13 +1679,12 @@ func (x *Read_Response) GetRecord() []byte { } type Write_MessageMigrateTable struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // marshalled arrow.Schema - Table []byte `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"` - MigrateForce bool `protobuf:"varint,2,opt,name=migrate_force,json=migrateForce,proto3" json:"migrate_force,omitempty"` + Table []byte `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"` + MigrateForce bool `protobuf:"varint,2,opt,name=migrate_force,json=migrateForce,proto3" json:"migrate_force,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Write_MessageMigrateTable) Reset() { @@ -1745,12 +1732,11 @@ func (x *Write_MessageMigrateTable) GetMigrateForce() bool { } type Write_MessageInsert struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // marshalled arrow.Record - Record []byte `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"` + Record []byte `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Write_MessageInsert) Reset() { @@ -1791,17 +1777,16 @@ func (x *Write_MessageInsert) GetRecord() []byte { } type Write_MessageDeleteStale struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // marshalled arrow.Schema // // Deprecated: Marked as deprecated in plugin-pb/plugin/v3/plugin.proto. - Table []byte `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"` - SourceName string `protobuf:"bytes,2,opt,name=source_name,json=sourceName,proto3" json:"source_name,omitempty"` - SyncTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=sync_time,json=syncTime,proto3" json:"sync_time,omitempty"` - TableName string `protobuf:"bytes,4,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` + Table []byte `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"` + SourceName string `protobuf:"bytes,2,opt,name=source_name,json=sourceName,proto3" json:"source_name,omitempty"` + SyncTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=sync_time,json=syncTime,proto3" json:"sync_time,omitempty"` + TableName string `protobuf:"bytes,4,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Write_MessageDeleteStale) Reset() { @@ -1864,13 +1849,12 @@ func (x *Write_MessageDeleteStale) GetTableName() string { } type Write_MessageDeleteRecord struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` - WhereClause []*PredicatesGroup `protobuf:"bytes,2,rep,name=where_clause,json=whereClause,proto3" json:"where_clause,omitempty"` - TableRelations []*TableRelation `protobuf:"bytes,3,rep,name=table_relations,json=tableRelations,proto3" json:"table_relations,omitempty"` + state protoimpl.MessageState `protogen:"open.v1"` + TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"` + WhereClause []*PredicatesGroup `protobuf:"bytes,2,rep,name=where_clause,json=whereClause,proto3" json:"where_clause,omitempty"` + TableRelations []*TableRelation `protobuf:"bytes,3,rep,name=table_relations,json=tableRelations,proto3" json:"table_relations,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Write_MessageDeleteRecord) Reset() { @@ -1925,17 +1909,16 @@ func (x *Write_MessageDeleteRecord) GetTableRelations() []*TableRelation { } type Write_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - // Types that are assignable to Message: + state protoimpl.MessageState `protogen:"open.v1"` + // Types that are valid to be assigned to Message: // // *Write_Request_MigrateTable // *Write_Request_Insert // *Write_Request_Delete // *Write_Request_DeleteRecord - Message isWrite_Request_Message `protobuf_oneof:"message"` + Message isWrite_Request_Message `protobuf_oneof:"message"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Write_Request) Reset() { @@ -1968,37 +1951,45 @@ func (*Write_Request) Descriptor() ([]byte, []int) { return file_plugin_pb_plugin_v3_plugin_proto_rawDescGZIP(), []int{10, 4} } -func (m *Write_Request) GetMessage() isWrite_Request_Message { - if m != nil { - return m.Message +func (x *Write_Request) GetMessage() isWrite_Request_Message { + if x != nil { + return x.Message } return nil } func (x *Write_Request) GetMigrateTable() *Write_MessageMigrateTable { - if x, ok := x.GetMessage().(*Write_Request_MigrateTable); ok { - return x.MigrateTable + if x != nil { + if x, ok := x.Message.(*Write_Request_MigrateTable); ok { + return x.MigrateTable + } } return nil } func (x *Write_Request) GetInsert() *Write_MessageInsert { - if x, ok := x.GetMessage().(*Write_Request_Insert); ok { - return x.Insert + if x != nil { + if x, ok := x.Message.(*Write_Request_Insert); ok { + return x.Insert + } } return nil } func (x *Write_Request) GetDelete() *Write_MessageDeleteStale { - if x, ok := x.GetMessage().(*Write_Request_Delete); ok { - return x.Delete + if x != nil { + if x, ok := x.Message.(*Write_Request_Delete); ok { + return x.Delete + } } return nil } func (x *Write_Request) GetDeleteRecord() *Write_MessageDeleteRecord { - if x, ok := x.GetMessage().(*Write_Request_DeleteRecord); ok { - return x.DeleteRecord + if x != nil { + if x, ok := x.Message.(*Write_Request_DeleteRecord); ok { + return x.DeleteRecord + } } return nil } @@ -2032,9 +2023,9 @@ func (*Write_Request_Delete) isWrite_Request_Message() {} func (*Write_Request_DeleteRecord) isWrite_Request_Message() {} type Write_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Write_Response) Reset() { @@ -2068,12 +2059,11 @@ func (*Write_Response) Descriptor() ([]byte, []int) { } type Transform_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // marshalled arrow.Record - Record []byte `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"` + Record []byte `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Transform_Request) Reset() { @@ -2114,12 +2104,11 @@ func (x *Transform_Request) GetRecord() []byte { } type Transform_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // marshalled arrow.Record - Record []byte `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"` + Record []byte `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Transform_Response) Reset() { @@ -2160,12 +2149,11 @@ func (x *Transform_Response) GetRecord() []byte { } type TransformSchema_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // marshalled arrow.Schema - Schema []byte `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"` + Schema []byte `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *TransformSchema_Request) Reset() { @@ -2206,12 +2194,11 @@ func (x *TransformSchema_Request) GetSchema() []byte { } type TransformSchema_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // marshalled arrow.Schema - Schema []byte `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"` + Schema []byte `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *TransformSchema_Response) Reset() { @@ -2252,9 +2239,9 @@ func (x *TransformSchema_Response) GetSchema() []byte { } type Close_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Close_Request) Reset() { @@ -2288,9 +2275,9 @@ func (*Close_Request) Descriptor() ([]byte, []int) { } type Close_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Close_Response) Reset() { @@ -2324,11 +2311,10 @@ func (*Close_Response) Descriptor() ([]byte, []int) { } type TestConnection_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Spec []byte `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` // Internal plugin-specific spec unknownFields protoimpl.UnknownFields - - Spec []byte `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` // Internal plugin-specific spec + sizeCache protoimpl.SizeCache } func (x *TestConnection_Request) Reset() { @@ -2369,13 +2355,12 @@ func (x *TestConnection_Request) GetSpec() []byte { } type TestConnection_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` - FailureCode string `protobuf:"bytes,2,opt,name=failure_code,json=failureCode,proto3" json:"failure_code,omitempty"` - FailureDescription string `protobuf:"bytes,3,opt,name=failure_description,json=failureDescription,proto3" json:"failure_description,omitempty"` + state protoimpl.MessageState `protogen:"open.v1"` + Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` + FailureCode string `protobuf:"bytes,2,opt,name=failure_code,json=failureCode,proto3" json:"failure_code,omitempty"` + FailureDescription string `protobuf:"bytes,3,opt,name=failure_description,json=failureDescription,proto3" json:"failure_description,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *TestConnection_Response) Reset() { diff --git a/pb/source/v0/source.pb.go b/pb/source/v0/source.pb.go index d5610b2..349dc58 100644 --- a/pb/source/v0/source.pb.go +++ b/pb/source/v0/source.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.35.2 +// protoc-gen-go v1.36.0 // protoc v4.23.4 // source: plugin-pb/source/v0/source.proto @@ -23,9 +23,9 @@ const ( ) type Sync struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Sync) Reset() { @@ -59,9 +59,9 @@ func (*Sync) Descriptor() ([]byte, []int) { } type Sync2 struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Sync2) Reset() { @@ -95,9 +95,9 @@ func (*Sync2) Descriptor() ([]byte, []int) { } type GetSyncSummary struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetSyncSummary) Reset() { @@ -131,9 +131,9 @@ func (*GetSyncSummary) Descriptor() ([]byte, []int) { } type GetTables struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetTables) Reset() { @@ -167,9 +167,9 @@ func (*GetTables) Descriptor() ([]byte, []int) { } type GetTablesForSpec struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetTablesForSpec) Reset() { @@ -203,9 +203,9 @@ func (*GetTablesForSpec) Descriptor() ([]byte, []int) { } type GetSourceMetrics struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetSourceMetrics) Reset() { @@ -239,13 +239,12 @@ func (*GetSourceMetrics) Descriptor() ([]byte, []int) { } type Sync_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Spec []byte `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` + state protoimpl.MessageState `protogen:"open.v1"` + Spec []byte `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` // sync timestamp - Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` + Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Sync_Request) Reset() { @@ -293,12 +292,11 @@ func (x *Sync_Request) GetTimestamp() *timestamppb.Timestamp { } type Sync_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // marshalled *schema.Resources - Resource []byte `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"` + Resource []byte `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Sync_Response) Reset() { @@ -339,11 +337,10 @@ func (x *Sync_Response) GetResource() []byte { } type Sync2_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Spec []byte `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` unknownFields protoimpl.UnknownFields - - Spec []byte `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` + sizeCache protoimpl.SizeCache } func (x *Sync2_Request) Reset() { @@ -384,12 +381,11 @@ func (x *Sync2_Request) GetSpec() []byte { } type Sync2_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // marshalled *schema.Resources - Resource []byte `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"` + Resource []byte `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Sync2_Response) Reset() { @@ -430,9 +426,9 @@ func (x *Sync2_Response) GetResource() []byte { } type GetSyncSummary_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetSyncSummary_Request) Reset() { @@ -466,12 +462,11 @@ func (*GetSyncSummary_Request) Descriptor() ([]byte, []int) { } type GetSyncSummary_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // marshalled *schema.SyncSummary - Summary []byte `protobuf:"bytes,1,opt,name=summary,proto3" json:"summary,omitempty"` + Summary []byte `protobuf:"bytes,1,opt,name=summary,proto3" json:"summary,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetSyncSummary_Response) Reset() { @@ -512,9 +507,9 @@ func (x *GetSyncSummary_Response) GetSummary() []byte { } type GetTables_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetTables_Request) Reset() { @@ -548,14 +543,13 @@ func (*GetTables_Request) Descriptor() ([]byte, []int) { } type GetTables_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` - Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` + state protoimpl.MessageState `protogen:"open.v1"` + Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` + Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` // Marshalled []*schema.Table - Tables []byte `protobuf:"bytes,3,opt,name=tables,proto3" json:"tables,omitempty"` + Tables []byte `protobuf:"bytes,3,opt,name=tables,proto3" json:"tables,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetTables_Response) Reset() { @@ -610,12 +604,11 @@ func (x *GetTables_Response) GetTables() []byte { } type GetTablesForSpec_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // Marshalled specs.Source - Spec []byte `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` + Spec []byte `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetTablesForSpec_Request) Reset() { @@ -656,14 +649,13 @@ func (x *GetTablesForSpec_Request) GetSpec() []byte { } type GetTablesForSpec_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` - Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` + state protoimpl.MessageState `protogen:"open.v1"` + Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` + Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` // Marshalled []*schema.Table - Tables []byte `protobuf:"bytes,3,opt,name=tables,proto3" json:"tables,omitempty"` + Tables []byte `protobuf:"bytes,3,opt,name=tables,proto3" json:"tables,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetTablesForSpec_Response) Reset() { @@ -718,9 +710,9 @@ func (x *GetTablesForSpec_Response) GetTables() []byte { } type GetSourceMetrics_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetSourceMetrics_Request) Reset() { @@ -754,12 +746,11 @@ func (*GetSourceMetrics_Request) Descriptor() ([]byte, []int) { } type GetSourceMetrics_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // marshalled json of plugins.SourceMetrics - Metrics []byte `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"` + Metrics []byte `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetSourceMetrics_Response) Reset() { diff --git a/pb/source/v1/source.pb.go b/pb/source/v1/source.pb.go index c210572..6f304b5 100644 --- a/pb/source/v1/source.pb.go +++ b/pb/source/v1/source.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.35.2 +// protoc-gen-go v1.36.0 // protoc v4.23.4 // source: plugin-pb/source/v1/source.proto @@ -67,9 +67,9 @@ func (GenDocs_FORMAT) EnumDescriptor() ([]byte, []int) { } type GetName struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetName) Reset() { @@ -103,9 +103,9 @@ func (*GetName) Descriptor() ([]byte, []int) { } type GetVersion struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetVersion) Reset() { @@ -139,9 +139,9 @@ func (*GetVersion) Descriptor() ([]byte, []int) { } type Init struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Init) Reset() { @@ -175,9 +175,9 @@ func (*Init) Descriptor() ([]byte, []int) { } type GetDynamicTables struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetDynamicTables) Reset() { @@ -211,9 +211,9 @@ func (*GetDynamicTables) Descriptor() ([]byte, []int) { } type Sync struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Sync) Reset() { @@ -247,9 +247,9 @@ func (*Sync) Descriptor() ([]byte, []int) { } type GetTables struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetTables) Reset() { @@ -283,9 +283,9 @@ func (*GetTables) Descriptor() ([]byte, []int) { } type GetMetrics struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetMetrics) Reset() { @@ -319,9 +319,9 @@ func (*GetMetrics) Descriptor() ([]byte, []int) { } type GenDocs struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GenDocs) Reset() { @@ -355,9 +355,9 @@ func (*GenDocs) Descriptor() ([]byte, []int) { } type GetName_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetName_Request) Reset() { @@ -391,11 +391,10 @@ func (*GetName_Request) Descriptor() ([]byte, []int) { } type GetName_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` unknownFields protoimpl.UnknownFields - - Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` + sizeCache protoimpl.SizeCache } func (x *GetName_Response) Reset() { @@ -436,9 +435,9 @@ func (x *GetName_Response) GetName() string { } type GetVersion_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetVersion_Request) Reset() { @@ -472,11 +471,10 @@ func (*GetVersion_Request) Descriptor() ([]byte, []int) { } type GetVersion_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` unknownFields protoimpl.UnknownFields - - Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` + sizeCache protoimpl.SizeCache } func (x *GetVersion_Response) Reset() { @@ -517,12 +515,11 @@ func (x *GetVersion_Response) GetVersion() string { } type Init_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // marshaled specs.Source - Spec []byte `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` + Spec []byte `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Init_Request) Reset() { @@ -563,9 +560,9 @@ func (x *Init_Request) GetSpec() []byte { } type Init_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Init_Response) Reset() { @@ -599,9 +596,9 @@ func (*Init_Response) Descriptor() ([]byte, []int) { } type GetDynamicTables_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetDynamicTables_Request) Reset() { @@ -635,12 +632,11 @@ func (*GetDynamicTables_Request) Descriptor() ([]byte, []int) { } type GetDynamicTables_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // marshaled []*schema.Table - Tables []byte `protobuf:"bytes,1,opt,name=tables,proto3" json:"tables,omitempty"` + Tables []byte `protobuf:"bytes,1,opt,name=tables,proto3" json:"tables,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetDynamicTables_Response) Reset() { @@ -681,9 +677,9 @@ func (x *GetDynamicTables_Response) GetTables() []byte { } type Sync_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Sync_Request) Reset() { @@ -717,12 +713,11 @@ func (*Sync_Request) Descriptor() ([]byte, []int) { } type Sync_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // marshalled *schema.Resources - Resource []byte `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"` + Resource []byte `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Sync_Response) Reset() { @@ -763,9 +758,9 @@ func (x *Sync_Response) GetResource() []byte { } type GetTables_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetTables_Request) Reset() { @@ -799,14 +794,13 @@ func (*GetTables_Request) Descriptor() ([]byte, []int) { } type GetTables_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` - Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` + state protoimpl.MessageState `protogen:"open.v1"` + Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` + Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` // Marshalled []*schema.Table - Tables []byte `protobuf:"bytes,3,opt,name=tables,proto3" json:"tables,omitempty"` + Tables []byte `protobuf:"bytes,3,opt,name=tables,proto3" json:"tables,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetTables_Response) Reset() { @@ -861,9 +855,9 @@ func (x *GetTables_Response) GetTables() []byte { } type GetMetrics_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetMetrics_Request) Reset() { @@ -897,12 +891,11 @@ func (*GetMetrics_Request) Descriptor() ([]byte, []int) { } type GetMetrics_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // marshalled json of plugins.SourceMetrics - Metrics []byte `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"` + Metrics []byte `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetMetrics_Response) Reset() { @@ -943,12 +936,11 @@ func (x *GetMetrics_Response) GetMetrics() []byte { } type GenDocs_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` + Format GenDocs_FORMAT `protobuf:"varint,2,opt,name=format,proto3,enum=cloudquery.source.v1.GenDocs_FORMAT" json:"format,omitempty"` unknownFields protoimpl.UnknownFields - - Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` - Format GenDocs_FORMAT `protobuf:"varint,2,opt,name=format,proto3,enum=cloudquery.source.v1.GenDocs_FORMAT" json:"format,omitempty"` + sizeCache protoimpl.SizeCache } func (x *GenDocs_Request) Reset() { @@ -996,9 +988,9 @@ func (x *GenDocs_Request) GetFormat() GenDocs_FORMAT { } type GenDocs_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GenDocs_Response) Reset() { diff --git a/pb/source/v2/source.pb.go b/pb/source/v2/source.pb.go index 55be6ae..2f9003b 100644 --- a/pb/source/v2/source.pb.go +++ b/pb/source/v2/source.pb.go @@ -1,6 +1,6 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.35.2 +// protoc-gen-go v1.36.0 // protoc v4.23.4 // source: plugin-pb/source/v2/source.proto @@ -68,9 +68,9 @@ func (GenDocs_FORMAT) EnumDescriptor() ([]byte, []int) { } type GetName struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetName) Reset() { @@ -104,9 +104,9 @@ func (*GetName) Descriptor() ([]byte, []int) { } type GetVersion struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetVersion) Reset() { @@ -140,9 +140,9 @@ func (*GetVersion) Descriptor() ([]byte, []int) { } type Init struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Init) Reset() { @@ -176,9 +176,9 @@ func (*Init) Descriptor() ([]byte, []int) { } type GetDynamicTables struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetDynamicTables) Reset() { @@ -212,9 +212,9 @@ func (*GetDynamicTables) Descriptor() ([]byte, []int) { } type Sync struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Sync) Reset() { @@ -248,9 +248,9 @@ func (*Sync) Descriptor() ([]byte, []int) { } type GetTables struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetTables) Reset() { @@ -284,9 +284,9 @@ func (*GetTables) Descriptor() ([]byte, []int) { } type GetMetrics struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetMetrics) Reset() { @@ -320,9 +320,9 @@ func (*GetMetrics) Descriptor() ([]byte, []int) { } type GenDocs struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GenDocs) Reset() { @@ -356,9 +356,9 @@ func (*GenDocs) Descriptor() ([]byte, []int) { } type GetName_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetName_Request) Reset() { @@ -392,11 +392,10 @@ func (*GetName_Request) Descriptor() ([]byte, []int) { } type GetName_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` unknownFields protoimpl.UnknownFields - - Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` + sizeCache protoimpl.SizeCache } func (x *GetName_Response) Reset() { @@ -437,9 +436,9 @@ func (x *GetName_Response) GetName() string { } type GetVersion_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetVersion_Request) Reset() { @@ -473,11 +472,10 @@ func (*GetVersion_Request) Descriptor() ([]byte, []int) { } type GetVersion_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` unknownFields protoimpl.UnknownFields - - Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` + sizeCache protoimpl.SizeCache } func (x *GetVersion_Response) Reset() { @@ -518,12 +516,11 @@ func (x *GetVersion_Response) GetVersion() string { } type Init_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // marshaled specs.Source - Spec []byte `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` + Spec []byte `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Init_Request) Reset() { @@ -564,9 +561,9 @@ func (x *Init_Request) GetSpec() []byte { } type Init_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Init_Response) Reset() { @@ -600,9 +597,9 @@ func (*Init_Response) Descriptor() ([]byte, []int) { } type GetDynamicTables_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetDynamicTables_Request) Reset() { @@ -636,12 +633,11 @@ func (*GetDynamicTables_Request) Descriptor() ([]byte, []int) { } type GetDynamicTables_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // marshaled []*schema.Table - Tables [][]byte `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"` + Tables [][]byte `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetDynamicTables_Response) Reset() { @@ -682,11 +678,10 @@ func (x *GetDynamicTables_Response) GetTables() [][]byte { } type Sync_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + SyncTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=sync_time,json=syncTime,proto3" json:"sync_time,omitempty"` unknownFields protoimpl.UnknownFields - - SyncTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=sync_time,json=syncTime,proto3" json:"sync_time,omitempty"` + sizeCache protoimpl.SizeCache } func (x *Sync_Request) Reset() { @@ -727,12 +722,11 @@ func (x *Sync_Request) GetSyncTime() *timestamppb.Timestamp { } type Sync_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // marshalled *arrow.Records - Resource []byte `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"` + Resource []byte `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *Sync_Response) Reset() { @@ -773,9 +767,9 @@ func (x *Sync_Response) GetResource() []byte { } type GetTables_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetTables_Request) Reset() { @@ -809,14 +803,13 @@ func (*GetTables_Request) Descriptor() ([]byte, []int) { } type GetTables_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - - Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` - Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` + state protoimpl.MessageState `protogen:"open.v1"` + Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` + Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` // Marshalled []arrow.Schema - Tables [][]byte `protobuf:"bytes,3,rep,name=tables,proto3" json:"tables,omitempty"` + Tables [][]byte `protobuf:"bytes,3,rep,name=tables,proto3" json:"tables,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetTables_Response) Reset() { @@ -871,9 +864,9 @@ func (x *GetTables_Response) GetTables() [][]byte { } type GetMetrics_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetMetrics_Request) Reset() { @@ -907,12 +900,11 @@ func (*GetMetrics_Request) Descriptor() ([]byte, []int) { } type GetMetrics_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache - unknownFields protoimpl.UnknownFields - + state protoimpl.MessageState `protogen:"open.v1"` // marshalled json of plugins.SourceMetrics - Metrics []byte `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"` + Metrics []byte `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GetMetrics_Response) Reset() { @@ -953,12 +945,11 @@ func (x *GetMetrics_Response) GetMetrics() []byte { } type GenDocs_Request struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` + Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` + Format GenDocs_FORMAT `protobuf:"varint,2,opt,name=format,proto3,enum=cloudquery.source.v2.GenDocs_FORMAT" json:"format,omitempty"` unknownFields protoimpl.UnknownFields - - Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` - Format GenDocs_FORMAT `protobuf:"varint,2,opt,name=format,proto3,enum=cloudquery.source.v2.GenDocs_FORMAT" json:"format,omitempty"` + sizeCache protoimpl.SizeCache } func (x *GenDocs_Request) Reset() { @@ -1006,9 +997,9 @@ func (x *GenDocs_Request) GetFormat() GenDocs_FORMAT { } type GenDocs_Response struct { - state protoimpl.MessageState - sizeCache protoimpl.SizeCache + state protoimpl.MessageState `protogen:"open.v1"` unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *GenDocs_Response) Reset() {