destination

package
v1.21.3 Latest Latest
Warning

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

Go to latest
Published: Jul 30, 2024 License: MPL-2.0 Imports: 10 Imported by: 5

Documentation

Index

Constants

View Source
const (
	Destination_GetProtocolVersion_FullMethodName = "/proto.Destination/GetProtocolVersion"
	Destination_GetName_FullMethodName            = "/proto.Destination/GetName"
	Destination_GetVersion_FullMethodName         = "/proto.Destination/GetVersion"
	Destination_Configure_FullMethodName          = "/proto.Destination/Configure"
	Destination_Migrate_FullMethodName            = "/proto.Destination/Migrate"
	Destination_Write_FullMethodName              = "/proto.Destination/Write"
	Destination_Write2_FullMethodName             = "/proto.Destination/Write2"
	Destination_Close_FullMethodName              = "/proto.Destination/Close"
	Destination_DeleteStale_FullMethodName        = "/proto.Destination/DeleteStale"
	Destination_GetMetrics_FullMethodName         = "/proto.Destination/GetMetrics"
)

Variables

View Source
var Destination_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.Destination",
	HandlerType: (*DestinationServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetProtocolVersion",
			Handler:    _Destination_GetProtocolVersion_Handler,
		},
		{
			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,
		},
		{
			StreamName:    "Write2",
			Handler:       _Destination_Write2_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "plugin-pb/destination/v0/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_v0_destination_proto protoreflect.FileDescriptor

Functions

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 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,opt,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 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) (grpc.ClientStreamingClient[Write_Request, Write_Response], error)
	// Write2 resources
	Write2(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[Write2_Request, Write2_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.

type DestinationServer

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(grpc.ClientStreamingServer[Write_Request, Write_Response]) error
	// Write2 resources
	Write2(grpc.ClientStreamingServer[Write2_Request, Write2_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_Write2Client

type Destination_Write2Client = grpc.ClientStreamingClient[Write2_Request, Write2_Response]

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

type Destination_Write2Server

type Destination_Write2Server = grpc.ClientStreamingServer[Write2_Request, Write2_Response]

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

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 (*GetDestinationMetrics_Request) Reset

func (x *GetDestinationMetrics_Request) Reset()

func (*GetDestinationMetrics_Request) 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 (*GetDestinationMetrics_Response) Reset

func (x *GetDestinationMetrics_Response) Reset()

func (*GetDestinationMetrics_Response) 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,opt,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) Configure

func (UnimplementedDestinationServer) DeleteStale

func (UnimplementedDestinationServer) GetName

func (UnimplementedDestinationServer) GetVersion

func (UnimplementedDestinationServer) Migrate

func (UnimplementedDestinationServer) Write

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 Write2

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

func (*Write2) Descriptor deprecated

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

Deprecated: Use Write2.ProtoReflect.Descriptor instead.

func (*Write2) ProtoMessage

func (*Write2) ProtoMessage()

func (*Write2) ProtoReflect

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

func (*Write2) Reset

func (x *Write2) Reset()

func (*Write2) String

func (x *Write2) String() string

type Write2_Request

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
}

func (*Write2_Request) Descriptor deprecated

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

Deprecated: Use Write2_Request.ProtoReflect.Descriptor instead.

func (*Write2_Request) GetResource

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

func (*Write2_Request) GetSource

func (x *Write2_Request) GetSource() string

func (*Write2_Request) GetSourceSpec

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

func (*Write2_Request) GetTables

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

func (*Write2_Request) GetTimestamp

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

func (*Write2_Request) ProtoMessage

func (*Write2_Request) ProtoMessage()

func (*Write2_Request) ProtoReflect

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

func (*Write2_Request) Reset

func (x *Write2_Request) Reset()

func (*Write2_Request) String

func (x *Write2_Request) String() string

type Write2_Response

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

func (*Write2_Response) Descriptor deprecated

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

Deprecated: Use Write2_Response.ProtoReflect.Descriptor instead.

func (*Write2_Response) ProtoMessage

func (*Write2_Response) ProtoMessage()

func (*Write2_Response) ProtoReflect

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

func (*Write2_Response) Reset

func (x *Write2_Response) Reset()

func (*Write2_Response) String

func (x *Write2_Response) String() string

type Write_Request

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
}

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) 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 {
	FailedWrites uint64 `protobuf:"varint,1,opt,name=failed_writes,json=failedWrites,proto3" json:"failed_writes,omitempty"`
	// 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) GetFailedWrites

func (x *Write_Response) GetFailedWrites() uint64

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL