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 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,opt,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 current protocol version of the plugin. This helps
	// get the right message about upgrade/downgrade of cli and/or plugin.
	// Also, on the cli side it can try to upgrade/downgrade the protocol if cli supports it.
	GetProtocolVersion(ctx context.Context, in *v0.GetProtocolVersion_Request, opts ...grpc.CallOption) (*v0.GetProtocolVersion_Response, error)
	// Get the name of the plugin
	GetName(ctx context.Context, in *v0.GetName_Request, opts ...grpc.CallOption) (*v0.GetName_Response, error)
	// Get the current version of the plugin
	GetVersion(ctx context.Context, in *v0.GetVersion_Request, opts ...grpc.CallOption) (*v0.GetVersion_Response, error)
	// Configure the plugin with the given credentials and mode
	Configure(ctx context.Context, in *v0.Configure_Request, opts ...grpc.CallOption) (*v0.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) (Destination_WriteClient, error)
	// Write2 resources
	Write2(ctx context.Context, opts ...grpc.CallOption) (Destination_Write2Client, 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 current protocol version of the plugin. This helps
	// get the right message about upgrade/downgrade of cli and/or plugin.
	// Also, on the cli side it can try to upgrade/downgrade the protocol if cli supports it.
	GetProtocolVersion(context.Context, *v0.GetProtocolVersion_Request) (*v0.GetProtocolVersion_Response, error)
	// Get the name of the plugin
	GetName(context.Context, *v0.GetName_Request) (*v0.GetName_Response, error)
	// Get the current version of the plugin
	GetVersion(context.Context, *v0.GetVersion_Request) (*v0.GetVersion_Response, error)
	// Configure the plugin with the given credentials and mode
	Configure(context.Context, *v0.Configure_Request) (*v0.Configure_Response, error)
	// Migrate tables to the given plugin version
	Migrate(context.Context, *Migrate_Request) (*Migrate_Response, error)
	// Write resources
	Write(Destination_WriteServer) error
	// Write2 resources
	Write2(Destination_Write2Server) 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_Write2Client interface {
	Send(*Write2_Request) error
	CloseAndRecv() (*Write2_Response, error)
	grpc.ClientStream
}

type Destination_Write2Server interface {
	SendAndClose(*Write2_Response) error
	Recv() (*Write2_Request, error)
	grpc.ServerStream
}

type Destination_WriteClient interface {
	Send(*Write_Request) error
	CloseAndRecv() (*Write_Response, error)
	grpc.ClientStream
}

type Destination_WriteServer interface {
	SendAndClose(*Write_Response) error
	Recv() (*Write_Request, error)
	grpc.ServerStream
}

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 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,opt,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 Write2 struct {
	// contains filtered or unexported fields
}

type Write2_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 schema.Tables
	Tables []byte `protobuf:"bytes,3,opt,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 Write2_Response struct {
	// contains filtered or unexported fields
}

type Write_Request struct {

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

type Write_Response struct {
	FailedWrites uint64 `protobuf:"varint,1,opt,name=failed_writes,json=failedWrites,proto3" json:"failed_writes,omitempty"`
	// contains filtered or unexported fields
}