destination

package
v1.26.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 23, 2024 License: MPL-2.0 Imports: 12 Imported by: 4

Documentation

Index

Constants

View Source 
const (
	Destination_GetName_FullMethodName     = "/cloudquery.destination.v1.Destination/GetName"
	Destination_GetVersion_FullMethodName  = "/cloudquery.destination.v1.Destination/GetVersion"
	Destination_Configure_FullMethodName   = "/cloudquery.destination.v1.Destination/Configure"
	Destination_Migrate_FullMethodName     = "/cloudquery.destination.v1.Destination/Migrate"
	Destination_Write_FullMethodName       = "/cloudquery.destination.v1.Destination/Write"
	Destination_Close_FullMethodName       = "/cloudquery.destination.v1.Destination/Close"
	Destination_DeleteStale_FullMethodName = "/cloudquery.destination.v1.Destination/DeleteStale"
	Destination_GetMetrics_FullMethodName  = "/cloudquery.destination.v1.Destination/GetMetrics"
)

Variables

View Source 
var Destination_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cloudquery.destination.v1.Destination",
	HandlerType: (*DestinationServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetName",
			Handler:    _Destination_GetName_Handler,
		},
		{
			MethodName: "GetVersion",
			Handler:    _Destination_GetVersion_Handler,
		},
		{
			MethodName: "Configure",
			Handler:    _Destination_Configure_Handler,
		},
		{
			MethodName: "Migrate",
			Handler:    _Destination_Migrate_Handler,
		},
		{
			MethodName: "Close",
			Handler:    _Destination_Close_Handler,
		},
		{
			MethodName: "DeleteStale",
			Handler:    _Destination_DeleteStale_Handler,
		},
		{
			MethodName: "GetMetrics",
			Handler:    _Destination_GetMetrics_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Write",
			Handler:       _Destination_Write_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "plugin-pb/destination/v1/destination.proto",
}

Destination_ServiceDesc is the grpc.ServiceDesc for Destination service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_plugin_pb_destination_v1_destination_proto protoreflect.FileDescriptor

Functions

func NewRecordFromBytes added in v1.3.3 

func NewRecordFromBytes(b []byte) (arrow.Record, error)

func NewSchemasFromBytes added in v1.3.0 

func NewSchemasFromBytes(b [][]byte) ([]*arrow.Schema, error)

func RegisterDestinationServer 

func RegisterDestinationServer(s grpc.ServiceRegistrar, srv DestinationServer)

Types

type Close 

type Close struct {
	// contains filtered or unexported fields
}

func (*Close) Descriptor deprecated 

func (*Close) Descriptor() ([]byte, []int)

Deprecated: Use Close.ProtoReflect.Descriptor instead.

func (*Close) ProtoMessage 

func (*Close) ProtoMessage()

func (*Close) ProtoReflect 

func (x *Close) ProtoReflect() protoreflect.Message

func (*Close) Reset 

func (x *Close) Reset()

func (*Close) String 

func (x *Close) String() string

type Close_Request 

type Close_Request struct {
	// contains filtered or unexported fields
}

func (*Close_Request) Descriptor deprecated 

func (*Close_Request) Descriptor() ([]byte, []int)

Deprecated: Use Close_Request.ProtoReflect.Descriptor instead.

func (*Close_Request) ProtoMessage 

func (*Close_Request) ProtoMessage()

func (*Close_Request) ProtoReflect 

func (x *Close_Request) ProtoReflect() protoreflect.Message

func (*Close_Request) Reset 

func (x *Close_Request) Reset()

func (*Close_Request) String 

func (x *Close_Request) String() string

type Close_Response 

type Close_Response struct {
	// contains filtered or unexported fields
}

func (*Close_Response) Descriptor deprecated 

func (*Close_Response) Descriptor() ([]byte, []int)

Deprecated: Use Close_Response.ProtoReflect.Descriptor instead.

func (*Close_Response) ProtoMessage 

func (*Close_Response) ProtoMessage()

func (*Close_Response) ProtoReflect 

func (x *Close_Response) ProtoReflect() protoreflect.Message

func (*Close_Response) Reset 

func (x *Close_Response) Reset()

func (*Close_Response) String 

func (x *Close_Response) String() string

type Configure 

type Configure struct {
	// contains filtered or unexported fields
}

func (*Configure) Descriptor deprecated 

func (*Configure) Descriptor() ([]byte, []int)

Deprecated: Use Configure.ProtoReflect.Descriptor instead.

func (*Configure) ProtoMessage 

func (*Configure) ProtoMessage()

func (*Configure) ProtoReflect 

func (x *Configure) ProtoReflect() protoreflect.Message

func (*Configure) Reset 

func (x *Configure) Reset()

func (*Configure) String 

func (x *Configure) String() string

type Configure_Request 

type Configure_Request struct {

	// 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"`
	// contains filtered or unexported fields
}

func (*Configure_Request) Descriptor deprecated 

func (*Configure_Request) Descriptor() ([]byte, []int)

Deprecated: Use Configure_Request.ProtoReflect.Descriptor instead.

func (*Configure_Request) GetConfig 

func (x *Configure_Request) GetConfig() []byte

func (*Configure_Request) ProtoMessage 

func (*Configure_Request) ProtoMessage()

func (*Configure_Request) ProtoReflect 

func (x *Configure_Request) ProtoReflect() protoreflect.Message

func (*Configure_Request) Reset 

func (x *Configure_Request) Reset()

func (*Configure_Request) String 

func (x *Configure_Request) String() string

type Configure_Response 

type Configure_Response struct {
	// contains filtered or unexported fields
}

func (*Configure_Response) Descriptor deprecated 

func (*Configure_Response) Descriptor() ([]byte, []int)

Deprecated: Use Configure_Response.ProtoReflect.Descriptor instead.

func (*Configure_Response) ProtoMessage 

func (*Configure_Response) ProtoMessage()

func (*Configure_Response) ProtoReflect 

func (x *Configure_Response) ProtoReflect() protoreflect.Message

func (*Configure_Response) Reset 

func (x *Configure_Response) Reset()

func (*Configure_Response) String 

func (x *Configure_Response) String() string

type DeleteStale 

type DeleteStale struct {
	// contains filtered or unexported fields
}

func (*DeleteStale) Descriptor deprecated 

func (*DeleteStale) Descriptor() ([]byte, []int)

Deprecated: Use DeleteStale.ProtoReflect.Descriptor instead.

func (*DeleteStale) ProtoMessage 

func (*DeleteStale) ProtoMessage()

func (*DeleteStale) ProtoReflect 

func (x *DeleteStale) ProtoReflect() protoreflect.Message

func (*DeleteStale) Reset 

func (x *DeleteStale) Reset()

func (*DeleteStale) String 

func (x *DeleteStale) String() string

type DeleteStale_Request 

type DeleteStale_Request struct {
	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"`
	// contains filtered or unexported fields
}

func (*DeleteStale_Request) Descriptor deprecated 

func (*DeleteStale_Request) Descriptor() ([]byte, []int)

Deprecated: Use DeleteStale_Request.ProtoReflect.Descriptor instead.

func (*DeleteStale_Request) GetSource 

func (x *DeleteStale_Request) GetSource() string

func (*DeleteStale_Request) GetTables 

func (x *DeleteStale_Request) GetTables() [][]byte

func (*DeleteStale_Request) GetTimestamp 

func (x *DeleteStale_Request) GetTimestamp() *timestamppb.Timestamp

func (*DeleteStale_Request) ProtoMessage 

func (*DeleteStale_Request) ProtoMessage()

func (*DeleteStale_Request) ProtoReflect 

func (x *DeleteStale_Request) ProtoReflect() protoreflect.Message

func (*DeleteStale_Request) Reset 

func (x *DeleteStale_Request) Reset()

func (*DeleteStale_Request) String 

func (x *DeleteStale_Request) String() string

type DeleteStale_Response 

type DeleteStale_Response struct {
	FailedDeletes uint64 `protobuf:"varint,1,opt,name=failed_deletes,json=failedDeletes,proto3" json:"failed_deletes,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteStale_Response) Descriptor deprecated 

func (*DeleteStale_Response) Descriptor() ([]byte, []int)

Deprecated: Use DeleteStale_Response.ProtoReflect.Descriptor instead.

func (*DeleteStale_Response) GetFailedDeletes 

func (x *DeleteStale_Response) GetFailedDeletes() uint64

func (*DeleteStale_Response) ProtoMessage 

func (*DeleteStale_Response) ProtoMessage()

func (*DeleteStale_Response) ProtoReflect 

func (x *DeleteStale_Response) ProtoReflect() protoreflect.Message

func (*DeleteStale_Response) Reset 

func (x *DeleteStale_Response) Reset()

func (*DeleteStale_Response) String 

func (x *DeleteStale_Response) String() string

type DestinationClient 

type DestinationClient interface {
	// Get the name of the plugin
	GetName(ctx context.Context, in *GetName_Request, opts ...grpc.CallOption) (*GetName_Response, error)
	// Get the current version of the plugin
	GetVersion(ctx context.Context, in *GetVersion_Request, opts ...grpc.CallOption) (*GetVersion_Response, error)
	// Configure the plugin with the given credentials and mode
	Configure(ctx context.Context, in *Configure_Request, opts ...grpc.CallOption) (*Configure_Response, error)
	// Migrate tables to the given plugin version
	Migrate(ctx context.Context, in *Migrate_Request, opts ...grpc.CallOption) (*Migrate_Response, error)
	// Write resources
	Write(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[Write_Request, Write_Response], error)
	// Send signal to flush and close open connections
	Close(ctx context.Context, in *Close_Request, opts ...grpc.CallOption) (*Close_Response, error)
	// DeleteStale deletes stale data that was inserted by a given source
	// and is older than the given timestamp
	DeleteStale(ctx context.Context, in *DeleteStale_Request, opts ...grpc.CallOption) (*DeleteStale_Response, error)
	// Get metrics for the source plugin
	GetMetrics(ctx context.Context, in *GetDestinationMetrics_Request, opts ...grpc.CallOption) (*GetDestinationMetrics_Response, error)
}

DestinationClient is the client API for Destination service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDestinationClient 

func NewDestinationClient(cc grpc.ClientConnInterface) DestinationClient

type DestinationServer 

type DestinationServer interface {
	// Get the name of the plugin
	GetName(context.Context, *GetName_Request) (*GetName_Response, error)
	// Get the current version of the plugin
	GetVersion(context.Context, *GetVersion_Request) (*GetVersion_Response, error)
	// Configure the plugin with the given credentials and mode
	Configure(context.Context, *Configure_Request) (*Configure_Response, error)
	// Migrate tables to the given plugin version
	Migrate(context.Context, *Migrate_Request) (*Migrate_Response, error)
	// Write resources
	Write(grpc.ClientStreamingServer[Write_Request, Write_Response]) error
	// Send signal to flush and close open connections
	Close(context.Context, *Close_Request) (*Close_Response, error)
	// DeleteStale deletes stale data that was inserted by a given source
	// and is older than the given timestamp
	DeleteStale(context.Context, *DeleteStale_Request) (*DeleteStale_Response, error)
	// Get metrics for the source plugin
	GetMetrics(context.Context, *GetDestinationMetrics_Request) (*GetDestinationMetrics_Response, error)
	// contains filtered or unexported methods
}

DestinationServer is the server API for Destination service. All implementations must embed UnimplementedDestinationServer for forward compatibility.

type Destination_WriteClient 

type Destination_WriteClient = grpc.ClientStreamingClient[Write_Request, Write_Response]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Destination_WriteServer 

type Destination_WriteServer = grpc.ClientStreamingServer[Write_Request, Write_Response]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type GetDestinationMetrics 

type GetDestinationMetrics struct {
	// contains filtered or unexported fields
}

func (*GetDestinationMetrics) Descriptor deprecated 

func (*GetDestinationMetrics) Descriptor() ([]byte, []int)

Deprecated: Use GetDestinationMetrics.ProtoReflect.Descriptor instead.

func (*GetDestinationMetrics) ProtoMessage 

func (*GetDestinationMetrics) ProtoMessage()

func (*GetDestinationMetrics) ProtoReflect 

func (x *GetDestinationMetrics) ProtoReflect() protoreflect.Message

func (*GetDestinationMetrics) Reset 

func (x *GetDestinationMetrics) Reset()

func (*GetDestinationMetrics) String 

func (x *GetDestinationMetrics) String() string

type GetDestinationMetrics_Request 

type GetDestinationMetrics_Request struct {
	// contains filtered or unexported fields
}

func (*GetDestinationMetrics_Request) Descriptor deprecated 

func (*GetDestinationMetrics_Request) Descriptor() ([]byte, []int)

Deprecated: Use GetDestinationMetrics_Request.ProtoReflect.Descriptor instead.

func (*GetDestinationMetrics_Request) ProtoMessage 

func (*GetDestinationMetrics_Request) ProtoMessage()

func (*GetDestinationMetrics_Request) ProtoReflect 

func (x *GetDestinationMetrics_Request) ProtoReflect() protoreflect.Message

func (*GetDestinationMetrics_Request) Reset 

func (x *GetDestinationMetrics_Request) Reset()

func (*GetDestinationMetrics_Request) String 

func (x *GetDestinationMetrics_Request) String() string

type GetDestinationMetrics_Response 

type GetDestinationMetrics_Response struct {

	// marshalled json of plugins.DestinationMetrics
	Metrics []byte `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDestinationMetrics_Response) Descriptor deprecated 

func (*GetDestinationMetrics_Response) Descriptor() ([]byte, []int)

Deprecated: Use GetDestinationMetrics_Response.ProtoReflect.Descriptor instead.

func (*GetDestinationMetrics_Response) GetMetrics 

func (x *GetDestinationMetrics_Response) GetMetrics() []byte

func (*GetDestinationMetrics_Response) ProtoMessage 

func (*GetDestinationMetrics_Response) ProtoMessage()

func (*GetDestinationMetrics_Response) ProtoReflect 

func (x *GetDestinationMetrics_Response) ProtoReflect() protoreflect.Message

func (*GetDestinationMetrics_Response) Reset 

func (x *GetDestinationMetrics_Response) Reset()

func (*GetDestinationMetrics_Response) String 

func (x *GetDestinationMetrics_Response) String() string

type GetName 

type GetName struct {
	// contains filtered or unexported fields
}

func (*GetName) Descriptor deprecated 

func (*GetName) Descriptor() ([]byte, []int)

Deprecated: Use GetName.ProtoReflect.Descriptor instead.

func (*GetName) ProtoMessage 

func (*GetName) ProtoMessage()

func (*GetName) ProtoReflect 

func (x *GetName) ProtoReflect() protoreflect.Message

func (*GetName) Reset 

func (x *GetName) Reset()

func (*GetName) String 

func (x *GetName) String() string

type GetName_Request 

type GetName_Request struct {
	// contains filtered or unexported fields
}

func (*GetName_Request) Descriptor deprecated 

func (*GetName_Request) Descriptor() ([]byte, []int)

Deprecated: Use GetName_Request.ProtoReflect.Descriptor instead.

func (*GetName_Request) ProtoMessage 

func (*GetName_Request) ProtoMessage()

func (*GetName_Request) ProtoReflect 

func (x *GetName_Request) ProtoReflect() protoreflect.Message

func (*GetName_Request) Reset 

func (x *GetName_Request) Reset()

func (*GetName_Request) String 

func (x *GetName_Request) String() string

type GetName_Response 

type GetName_Response struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetName_Response) Descriptor deprecated 

func (*GetName_Response) Descriptor() ([]byte, []int)

Deprecated: Use GetName_Response.ProtoReflect.Descriptor instead.

func (*GetName_Response) GetName 

func (x *GetName_Response) GetName() string

func (*GetName_Response) ProtoMessage 

func (*GetName_Response) ProtoMessage()

func (*GetName_Response) ProtoReflect 

func (x *GetName_Response) ProtoReflect() protoreflect.Message

func (*GetName_Response) Reset 

func (x *GetName_Response) Reset()

func (*GetName_Response) String 

func (x *GetName_Response) String() string

type GetVersion 

type GetVersion struct {
	// contains filtered or unexported fields
}

func (*GetVersion) Descriptor deprecated 

func (*GetVersion) Descriptor() ([]byte, []int)

Deprecated: Use GetVersion.ProtoReflect.Descriptor instead.

func (*GetVersion) ProtoMessage 

func (*GetVersion) ProtoMessage()

func (*GetVersion) ProtoReflect 

func (x *GetVersion) ProtoReflect() protoreflect.Message

func (*GetVersion) Reset 

func (x *GetVersion) Reset()

func (*GetVersion) String 

func (x *GetVersion) String() string

type GetVersion_Request 

type GetVersion_Request struct {
	// contains filtered or unexported fields
}

func (*GetVersion_Request) Descriptor deprecated 

func (*GetVersion_Request) Descriptor() ([]byte, []int)

Deprecated: Use GetVersion_Request.ProtoReflect.Descriptor instead.

func (*GetVersion_Request) ProtoMessage 

func (*GetVersion_Request) ProtoMessage()

func (*GetVersion_Request) ProtoReflect 

func (x *GetVersion_Request) ProtoReflect() protoreflect.Message

func (*GetVersion_Request) Reset 

func (x *GetVersion_Request) Reset()

func (*GetVersion_Request) String 

func (x *GetVersion_Request) String() string

type GetVersion_Response 

type GetVersion_Response struct {
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*GetVersion_Response) Descriptor deprecated 

func (*GetVersion_Response) Descriptor() ([]byte, []int)

Deprecated: Use GetVersion_Response.ProtoReflect.Descriptor instead.

func (*GetVersion_Response) GetVersion 

func (x *GetVersion_Response) GetVersion() string

func (*GetVersion_Response) ProtoMessage 

func (*GetVersion_Response) ProtoMessage()

func (*GetVersion_Response) ProtoReflect 

func (x *GetVersion_Response) ProtoReflect() protoreflect.Message

func (*GetVersion_Response) Reset 

func (x *GetVersion_Response) Reset()

func (*GetVersion_Response) String 

func (x *GetVersion_Response) String() string

type Migrate 

type Migrate struct {
	// contains filtered or unexported fields
}

func (*Migrate) Descriptor deprecated 

func (*Migrate) Descriptor() ([]byte, []int)

Deprecated: Use Migrate.ProtoReflect.Descriptor instead.

func (*Migrate) ProtoMessage 

func (*Migrate) ProtoMessage()

func (*Migrate) ProtoReflect 

func (x *Migrate) ProtoReflect() protoreflect.Message

func (*Migrate) Reset 

func (x *Migrate) Reset()

func (*Migrate) String 

func (x *Migrate) String() string

type Migrate_Request 

type Migrate_Request struct {
	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"`
	// contains filtered or unexported fields
}

func (*Migrate_Request) Descriptor deprecated 

func (*Migrate_Request) Descriptor() ([]byte, []int)

Deprecated: Use Migrate_Request.ProtoReflect.Descriptor instead.

func (*Migrate_Request) GetName 

func (x *Migrate_Request) GetName() string

func (*Migrate_Request) GetTables 

func (x *Migrate_Request) GetTables() [][]byte

func (*Migrate_Request) GetVersion 

func (x *Migrate_Request) GetVersion() string

func (*Migrate_Request) ProtoMessage 

func (*Migrate_Request) ProtoMessage()

func (*Migrate_Request) ProtoReflect 

func (x *Migrate_Request) ProtoReflect() protoreflect.Message

func (*Migrate_Request) Reset 

func (x *Migrate_Request) Reset()

func (*Migrate_Request) String 

func (x *Migrate_Request) String() string

type Migrate_Response 

type Migrate_Response struct {
	// contains filtered or unexported fields
}

func (*Migrate_Response) Descriptor deprecated 

func (*Migrate_Response) Descriptor() ([]byte, []int)

Deprecated: Use Migrate_Response.ProtoReflect.Descriptor instead.

func (*Migrate_Response) ProtoMessage 

func (*Migrate_Response) ProtoMessage()

func (*Migrate_Response) ProtoReflect 

func (x *Migrate_Response) ProtoReflect() protoreflect.Message

func (*Migrate_Response) Reset 

func (x *Migrate_Response) Reset()

func (*Migrate_Response) String 

func (x *Migrate_Response) String() string

type UnimplementedDestinationServer 

type UnimplementedDestinationServer struct{}

UnimplementedDestinationServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedDestinationServer) Close 

func (UnimplementedDestinationServer) Close(context.Context, *Close_Request) (*Close_Response, error)

func (UnimplementedDestinationServer) Configure 

func (UnimplementedDestinationServer) Configure(context.Context, *Configure_Request) (*Configure_Response, error)

func (UnimplementedDestinationServer) DeleteStale 

func (UnimplementedDestinationServer) DeleteStale(context.Context, *DeleteStale_Request) (*DeleteStale_Response, error)

func (UnimplementedDestinationServer) GetMetrics 

func (UnimplementedDestinationServer) GetMetrics(context.Context, *GetDestinationMetrics_Request) (*GetDestinationMetrics_Response, error)

func (UnimplementedDestinationServer) GetName 

func (UnimplementedDestinationServer) GetName(context.Context, *GetName_Request) (*GetName_Response, error)

func (UnimplementedDestinationServer) GetVersion 

func (UnimplementedDestinationServer) GetVersion(context.Context, *GetVersion_Request) (*GetVersion_Response, error)

func (UnimplementedDestinationServer) Migrate 

func (UnimplementedDestinationServer) Migrate(context.Context, *Migrate_Request) (*Migrate_Response, error)

func (UnimplementedDestinationServer) Write 

func (UnimplementedDestinationServer) Write(grpc.ClientStreamingServer[Write_Request, Write_Response]) error

type UnsafeDestinationServer 

type UnsafeDestinationServer interface {
	// contains filtered or unexported methods
}

UnsafeDestinationServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DestinationServer will result in compilation errors.

type Write 

type Write struct {
	// contains filtered or unexported fields
}

func (*Write) Descriptor deprecated 

func (*Write) Descriptor() ([]byte, []int)

Deprecated: Use Write.ProtoReflect.Descriptor instead.

func (*Write) ProtoMessage 

func (*Write) ProtoMessage()

func (*Write) ProtoReflect 

func (x *Write) ProtoReflect() protoreflect.Message

func (*Write) Reset 

func (x *Write) Reset()

func (*Write) String 

func (x *Write) String() string

type Write_Request 

type Write_Request struct {
	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
	Tables [][]byte `protobuf:"bytes,3,rep,name=tables,proto3" json:"tables,omitempty"`
	// 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"`
	// contains filtered or unexported fields
}

func (*Write_Request) Descriptor deprecated 

func (*Write_Request) Descriptor() ([]byte, []int)

Deprecated: Use Write_Request.ProtoReflect.Descriptor instead.

func (*Write_Request) GetResource 

func (x *Write_Request) GetResource() []byte

func (*Write_Request) GetSource 

func (x *Write_Request) GetSource() string

func (*Write_Request) GetSourceSpec 

func (x *Write_Request) GetSourceSpec() []byte

func (*Write_Request) GetTables 

func (x *Write_Request) GetTables() [][]byte

func (*Write_Request) GetTimestamp 

func (x *Write_Request) GetTimestamp() *timestamppb.Timestamp

func (*Write_Request) ProtoMessage 

func (*Write_Request) ProtoMessage()

func (*Write_Request) ProtoReflect 

func (x *Write_Request) ProtoReflect() protoreflect.Message

func (*Write_Request) Reset 

func (x *Write_Request) Reset()

func (*Write_Request) String 

func (x *Write_Request) String() string

type Write_Response 

type Write_Response struct {
	// contains filtered or unexported fields
}

func (*Write_Response) Descriptor deprecated 

func (*Write_Response) Descriptor() ([]byte, []int)

Deprecated: Use Write_Response.ProtoReflect.Descriptor instead.

func (*Write_Response) ProtoMessage 

func (*Write_Response) ProtoMessage()

func (*Write_Response) ProtoReflect 

func (x *Write_Response) ProtoReflect() protoreflect.Message

func (*Write_Response) Reset 

func (x *Write_Response) Reset()

func (*Write_Response) String 

func (x *Write_Response) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.