destination

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

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

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

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

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
}

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

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

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
}

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
}

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)
}

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
}

type Destination_WriteClient = grpc.ClientStreamingClient[Write_Request, Write_Response]

type Destination_WriteServer = grpc.ClientStreamingServer[Write_Request, Write_Response]

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

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

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
}

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

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

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

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

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

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

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

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
}

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

type UnimplementedDestinationServer struct{}

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

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

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
}

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