pb

package
v0.13.12 Latest Latest
Warning

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

 Go to latest Published: Oct 20, 2022 License: MPL-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

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,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Write",
			Handler:       _Destination_Write_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "internal/pb/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_internal_pb_base_proto protoreflect.FileDescriptor
View Source 
var File_internal_pb_destination_proto protoreflect.FileDescriptor
View Source 
var File_internal_pb_source_proto protoreflect.FileDescriptor
View Source 
var Source_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.Source",
	HandlerType: (*SourceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetProtocolVersion",
			Handler:    _Source_GetProtocolVersion_Handler,
		},
		{
			MethodName: "GetName",
			Handler:    _Source_GetName_Handler,
		},
		{
			MethodName: "GetVersion",
			Handler:    _Source_GetVersion_Handler,
		},
		{
			MethodName: "GetTables",
			Handler:    _Source_GetTables_Handler,
		},
		{
			MethodName: "GetSyncSummary",
			Handler:    _Source_GetSyncSummary_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Sync",
			Handler:       _Source_Sync_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "internal/pb/source.proto",
}

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

Functions

func RegisterDestinationServer 

func RegisterDestinationServer(s grpc.ServiceRegistrar, srv DestinationServer)

func RegisterSourceServer 

func RegisterSourceServer(s grpc.ServiceRegistrar, srv SourceServer)

Types

type Close added in v0.11.4 

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

func (*Close) Descriptor deprecated added in v0.11.4 

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

Deprecated: Use Close.ProtoReflect.Descriptor instead.

func (*Close) ProtoMessage added in v0.11.4 

func (*Close) ProtoMessage()

func (*Close) ProtoReflect added in v0.11.4 

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

func (*Close) Reset added in v0.11.4 

func (x *Close) Reset()

func (*Close) String added in v0.11.4 

func (x *Close) String() string

type Close_Request added in v0.11.4 

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

func (*Close_Request) Descriptor deprecated added in v0.11.4 

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

Deprecated: Use Close_Request.ProtoReflect.Descriptor instead.

func (*Close_Request) ProtoMessage added in v0.11.4 

func (*Close_Request) ProtoMessage()

func (*Close_Request) ProtoReflect added in v0.11.4 

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

func (*Close_Request) Reset added in v0.11.4 

func (x *Close_Request) Reset()

func (*Close_Request) String added in v0.11.4 

func (x *Close_Request) String() string

type Close_Response added in v0.11.4 

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

func (*Close_Response) Descriptor deprecated added in v0.11.4 

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

Deprecated: Use Close_Response.ProtoReflect.Descriptor instead.

func (*Close_Response) ProtoMessage added in v0.11.4 

func (*Close_Response) ProtoMessage()

func (*Close_Response) ProtoReflect added in v0.11.4 

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

func (*Close_Response) Reset added in v0.11.4 

func (x *Close_Response) Reset()

func (*Close_Response) String added in v0.11.4 

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 {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// 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) GetError 

func (x *Configure_Response) GetError() string

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 added in v0.12.0 

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

func (*DeleteStale) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use DeleteStale.ProtoReflect.Descriptor instead.

func (*DeleteStale) ProtoMessage added in v0.12.0 

func (*DeleteStale) ProtoMessage()

func (*DeleteStale) ProtoReflect added in v0.12.0 

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

func (*DeleteStale) Reset added in v0.12.0 

func (x *DeleteStale) Reset()

func (*DeleteStale) String added in v0.12.0 

func (x *DeleteStale) String() string

type DeleteStale_Request added in v0.12.0 

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 added in v0.12.0 

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

Deprecated: Use DeleteStale_Request.ProtoReflect.Descriptor instead.

func (*DeleteStale_Request) GetSource added in v0.12.0 

func (x *DeleteStale_Request) GetSource() string

func (*DeleteStale_Request) GetTables added in v0.12.0 

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

func (*DeleteStale_Request) GetTimestamp added in v0.12.0 

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

func (*DeleteStale_Request) ProtoMessage added in v0.12.0 

func (*DeleteStale_Request) ProtoMessage()

func (*DeleteStale_Request) ProtoReflect added in v0.12.0 

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

func (*DeleteStale_Request) Reset added in v0.12.0 

func (x *DeleteStale_Request) Reset()

func (*DeleteStale_Request) String added in v0.12.0 

func (x *DeleteStale_Request) String() string

type DeleteStale_Response added in v0.12.0 

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 added in v0.12.0 

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

Deprecated: Use DeleteStale_Response.ProtoReflect.Descriptor instead.

func (*DeleteStale_Response) GetFailedDeletes added in v0.12.0 

func (x *DeleteStale_Response) GetFailedDeletes() uint64

func (*DeleteStale_Response) ProtoMessage added in v0.12.0 

func (*DeleteStale_Response) ProtoMessage()

func (*DeleteStale_Response) ProtoReflect added in v0.12.0 

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

func (*DeleteStale_Response) Reset added in v0.12.0 

func (x *DeleteStale_Response) Reset()

func (*DeleteStale_Response) String added in v0.12.0 

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 *GetProtocolVersion_Request, opts ...grpc.CallOption) (*GetProtocolVersion_Response, error)
	// 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) (Destination_WriteClient, 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)
}

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 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, *GetProtocolVersion_Request) (*GetProtocolVersion_Response, error)
	// 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(Destination_WriteServer) 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)
	// contains filtered or unexported methods
}

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

type Destination_WriteClient added in v0.0.4 

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

type Destination_WriteServer added in v0.0.4 

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

type GetName added in v0.0.10 

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

func (*GetName) Descriptor deprecated added in v0.0.10 

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

Deprecated: Use GetName.ProtoReflect.Descriptor instead.

func (*GetName) ProtoMessage added in v0.0.10 

func (*GetName) ProtoMessage()

func (*GetName) ProtoReflect added in v0.0.10 

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

func (*GetName) Reset added in v0.0.10 

func (x *GetName) Reset()

func (*GetName) String added in v0.0.10 

func (x *GetName) String() string

type GetName_Request added in v0.0.10 

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

func (*GetName_Request) Descriptor deprecated added in v0.0.10 

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

Deprecated: Use GetName_Request.ProtoReflect.Descriptor instead.

func (*GetName_Request) ProtoMessage added in v0.0.10 

func (*GetName_Request) ProtoMessage()

func (*GetName_Request) ProtoReflect added in v0.0.10 

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

func (*GetName_Request) Reset added in v0.0.10 

func (x *GetName_Request) Reset()

func (*GetName_Request) String added in v0.0.10 

func (x *GetName_Request) String() string

type GetName_Response added in v0.0.10 

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 added in v0.0.10 

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

Deprecated: Use GetName_Response.ProtoReflect.Descriptor instead.

func (*GetName_Response) GetName added in v0.0.10 

func (x *GetName_Response) GetName() string

func (*GetName_Response) ProtoMessage added in v0.0.10 

func (*GetName_Response) ProtoMessage()

func (*GetName_Response) ProtoReflect added in v0.0.10 

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

func (*GetName_Response) Reset added in v0.0.10 

func (x *GetName_Response) Reset()

func (*GetName_Response) String added in v0.0.10 

func (x *GetName_Response) String() string

type GetProtocolVersion added in v0.13.8 

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

func (*GetProtocolVersion) Descriptor deprecated added in v0.13.8 

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

Deprecated: Use GetProtocolVersion.ProtoReflect.Descriptor instead.

func (*GetProtocolVersion) ProtoMessage added in v0.13.8 

func (*GetProtocolVersion) ProtoMessage()

func (*GetProtocolVersion) ProtoReflect added in v0.13.8 

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

func (*GetProtocolVersion) Reset added in v0.13.8 

func (x *GetProtocolVersion) Reset()

func (*GetProtocolVersion) String added in v0.13.8 

func (x *GetProtocolVersion) String() string

type GetProtocolVersion_Request added in v0.13.8 

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

func (*GetProtocolVersion_Request) Descriptor deprecated added in v0.13.8 

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

Deprecated: Use GetProtocolVersion_Request.ProtoReflect.Descriptor instead.

func (*GetProtocolVersion_Request) ProtoMessage added in v0.13.8 

func (*GetProtocolVersion_Request) ProtoMessage()

func (*GetProtocolVersion_Request) ProtoReflect added in v0.13.8 

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

func (*GetProtocolVersion_Request) Reset added in v0.13.8 

func (x *GetProtocolVersion_Request) Reset()

func (*GetProtocolVersion_Request) String added in v0.13.8 

func (x *GetProtocolVersion_Request) String() string

type GetProtocolVersion_Response added in v0.13.8 

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

func (*GetProtocolVersion_Response) Descriptor deprecated added in v0.13.8 

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

Deprecated: Use GetProtocolVersion_Response.ProtoReflect.Descriptor instead.

func (*GetProtocolVersion_Response) GetVersion added in v0.13.8 

func (x *GetProtocolVersion_Response) GetVersion() uint64

func (*GetProtocolVersion_Response) ProtoMessage added in v0.13.8 

func (*GetProtocolVersion_Response) ProtoMessage()

func (*GetProtocolVersion_Response) ProtoReflect added in v0.13.8 

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

func (*GetProtocolVersion_Response) Reset added in v0.13.8 

func (x *GetProtocolVersion_Response) Reset()

func (*GetProtocolVersion_Response) String added in v0.13.8 

func (x *GetProtocolVersion_Response) String() string

type GetSyncSummary added in v0.12.0 

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

func (*GetSyncSummary) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use GetSyncSummary.ProtoReflect.Descriptor instead.

func (*GetSyncSummary) ProtoMessage added in v0.12.0 

func (*GetSyncSummary) ProtoMessage()

func (*GetSyncSummary) ProtoReflect added in v0.12.0 

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

func (*GetSyncSummary) Reset added in v0.12.0 

func (x *GetSyncSummary) Reset()

func (*GetSyncSummary) String added in v0.12.0 

func (x *GetSyncSummary) String() string

type GetSyncSummary_Request added in v0.12.0 

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

func (*GetSyncSummary_Request) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use GetSyncSummary_Request.ProtoReflect.Descriptor instead.

func (*GetSyncSummary_Request) ProtoMessage added in v0.12.0 

func (*GetSyncSummary_Request) ProtoMessage()

func (*GetSyncSummary_Request) ProtoReflect added in v0.12.0 

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

func (*GetSyncSummary_Request) Reset added in v0.12.0 

func (x *GetSyncSummary_Request) Reset()

func (*GetSyncSummary_Request) String added in v0.12.0 

func (x *GetSyncSummary_Request) String() string

type GetSyncSummary_Response added in v0.12.0 

type GetSyncSummary_Response struct {

	// marshalled *schema.SyncSummary
	Summary []byte `protobuf:"bytes,1,opt,name=summary,proto3" json:"summary,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSyncSummary_Response) Descriptor deprecated added in v0.12.0 

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

Deprecated: Use GetSyncSummary_Response.ProtoReflect.Descriptor instead.

func (*GetSyncSummary_Response) GetSummary added in v0.12.0 

func (x *GetSyncSummary_Response) GetSummary() []byte

func (*GetSyncSummary_Response) ProtoMessage added in v0.12.0 

func (*GetSyncSummary_Response) ProtoMessage()

func (*GetSyncSummary_Response) ProtoReflect added in v0.12.0 

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

func (*GetSyncSummary_Response) Reset added in v0.12.0 

func (x *GetSyncSummary_Response) Reset()

func (*GetSyncSummary_Response) String added in v0.12.0 

func (x *GetSyncSummary_Response) String() string

type GetTables 

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

func (*GetTables) Descriptor deprecated 

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

Deprecated: Use GetTables.ProtoReflect.Descriptor instead.

func (*GetTables) ProtoMessage 

func (*GetTables) ProtoMessage()

func (*GetTables) ProtoReflect 

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

func (*GetTables) Reset 

func (x *GetTables) Reset()

func (*GetTables) String 

func (x *GetTables) String() string

type GetTables_Request 

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

func (*GetTables_Request) Descriptor deprecated 

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

Deprecated: Use GetTables_Request.ProtoReflect.Descriptor instead.

func (*GetTables_Request) ProtoMessage 

func (*GetTables_Request) ProtoMessage()

func (*GetTables_Request) ProtoReflect 

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

func (*GetTables_Request) Reset 

func (x *GetTables_Request) Reset()

func (*GetTables_Request) String 

func (x *GetTables_Request) String() string

type GetTables_Response 

type GetTables_Response 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"`
	// Marshalled []*schema.Table
	Tables []byte `protobuf:"bytes,3,opt,name=tables,proto3" json:"tables,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTables_Response) Descriptor deprecated 

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

Deprecated: Use GetTables_Response.ProtoReflect.Descriptor instead.

func (*GetTables_Response) GetName 

func (x *GetTables_Response) GetName() string

func (*GetTables_Response) GetTables 

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

func (*GetTables_Response) GetVersion 

func (x *GetTables_Response) GetVersion() string

func (*GetTables_Response) ProtoMessage 

func (*GetTables_Response) ProtoMessage()

func (*GetTables_Response) ProtoReflect 

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

func (*GetTables_Response) Reset 

func (x *GetTables_Response) Reset()

func (*GetTables_Response) String 

func (x *GetTables_Response) String() string

type GetVersion added in v0.0.10 

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

func (*GetVersion) Descriptor deprecated added in v0.0.10 

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

Deprecated: Use GetVersion.ProtoReflect.Descriptor instead.

func (*GetVersion) ProtoMessage added in v0.0.10 

func (*GetVersion) ProtoMessage()

func (*GetVersion) ProtoReflect added in v0.0.10 

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

func (*GetVersion) Reset added in v0.0.10 

func (x *GetVersion) Reset()

func (*GetVersion) String added in v0.0.10 

func (x *GetVersion) String() string

type GetVersion_Request added in v0.0.10 

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

func (*GetVersion_Request) Descriptor deprecated added in v0.0.10 

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

Deprecated: Use GetVersion_Request.ProtoReflect.Descriptor instead.

func (*GetVersion_Request) ProtoMessage added in v0.0.10 

func (*GetVersion_Request) ProtoMessage()

func (*GetVersion_Request) ProtoReflect added in v0.0.10 

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

func (*GetVersion_Request) Reset added in v0.0.10 

func (x *GetVersion_Request) Reset()

func (*GetVersion_Request) String added in v0.0.10 

func (x *GetVersion_Request) String() string

type GetVersion_Response added in v0.0.10 

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 added in v0.0.10 

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

Deprecated: Use GetVersion_Response.ProtoReflect.Descriptor instead.

func (*GetVersion_Response) GetVersion added in v0.0.10 

func (x *GetVersion_Response) GetVersion() string

func (*GetVersion_Response) ProtoMessage added in v0.0.10 

func (*GetVersion_Response) ProtoMessage()

func (*GetVersion_Response) ProtoReflect added in v0.0.10 

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

func (*GetVersion_Response) Reset added in v0.0.10 

func (x *GetVersion_Response) Reset()

func (*GetVersion_Response) String added in v0.0.10 

func (x *GetVersion_Response) String() string

type Migrate added in v0.0.4 

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

func (*Migrate) Descriptor deprecated added in v0.0.4 

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

Deprecated: Use Migrate.ProtoReflect.Descriptor instead.

func (*Migrate) ProtoMessage added in v0.0.4 

func (*Migrate) ProtoMessage()

func (*Migrate) ProtoReflect added in v0.0.4 

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

func (*Migrate) Reset added in v0.0.4 

func (x *Migrate) Reset()

func (*Migrate) String added in v0.0.4 

func (x *Migrate) String() string

type Migrate_Request added in v0.0.4 

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 added in v0.0.4 

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

Deprecated: Use Migrate_Request.ProtoReflect.Descriptor instead.

func (*Migrate_Request) GetName added in v0.0.4 

func (x *Migrate_Request) GetName() string

func (*Migrate_Request) GetTables added in v0.0.4 

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

func (*Migrate_Request) GetVersion added in v0.0.4 

func (x *Migrate_Request) GetVersion() string

func (*Migrate_Request) ProtoMessage added in v0.0.4 

func (*Migrate_Request) ProtoMessage()

func (*Migrate_Request) ProtoReflect added in v0.0.4 

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

func (*Migrate_Request) Reset added in v0.0.4 

func (x *Migrate_Request) Reset()

func (*Migrate_Request) String added in v0.0.4 

func (x *Migrate_Request) String() string

type Migrate_Response added in v0.0.4 

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

func (*Migrate_Response) Descriptor deprecated added in v0.0.4 

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

Deprecated: Use Migrate_Response.ProtoReflect.Descriptor instead.

func (*Migrate_Response) ProtoMessage added in v0.0.4 

func (*Migrate_Response) ProtoMessage()

func (*Migrate_Response) ProtoReflect added in v0.0.4 

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

func (*Migrate_Response) Reset added in v0.0.4 

func (x *Migrate_Response) Reset()

func (*Migrate_Response) String added in v0.0.4 

func (x *Migrate_Response) String() string

type SourceClient 

type SourceClient 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 *GetProtocolVersion_Request, opts ...grpc.CallOption) (*GetProtocolVersion_Response, error)
	// 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)
	// Get all tables the source plugin supports
	GetTables(ctx context.Context, in *GetTables_Request, opts ...grpc.CallOption) (*GetTables_Response, error)
	// GetSyncSummary returns the latest sync summary of the source plugin. we don't want to send the summary on
	// every sync request.
	GetSyncSummary(ctx context.Context, in *GetSyncSummary_Request, opts ...grpc.CallOption) (*GetSyncSummary_Response, error)
	// Fetch resources
	Sync(ctx context.Context, in *Sync_Request, opts ...grpc.CallOption) (Source_SyncClient, error)
}

SourceClient is the client API for Source 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 NewSourceClient 

func NewSourceClient(cc grpc.ClientConnInterface) SourceClient

type SourceServer 

type SourceServer 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, *GetProtocolVersion_Request) (*GetProtocolVersion_Response, error)
	// 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)
	// Get all tables the source plugin supports
	GetTables(context.Context, *GetTables_Request) (*GetTables_Response, error)
	// GetSyncSummary returns the latest sync summary of the source plugin. we don't want to send the summary on
	// every sync request.
	GetSyncSummary(context.Context, *GetSyncSummary_Request) (*GetSyncSummary_Response, error)
	// Fetch resources
	Sync(*Sync_Request, Source_SyncServer) error
	// contains filtered or unexported methods
}

SourceServer is the server API for Source service. All implementations must embed UnimplementedSourceServer for forward compatibility

type Source_SyncClient added in v0.0.4 

type Source_SyncClient interface {
	Recv() (*Sync_Response, error)
	grpc.ClientStream
}

type Source_SyncServer added in v0.0.4 

type Source_SyncServer interface {
	Send(*Sync_Response) error
	grpc.ServerStream
}

type Sync added in v0.0.4 

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

func (*Sync) Descriptor deprecated added in v0.0.4 

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

Deprecated: Use Sync.ProtoReflect.Descriptor instead.

func (*Sync) ProtoMessage added in v0.0.4 

func (*Sync) ProtoMessage()

func (*Sync) ProtoReflect added in v0.0.4 

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

func (*Sync) Reset added in v0.0.4 

func (x *Sync) Reset()

func (*Sync) String added in v0.0.4 

func (x *Sync) String() string

type Sync_Request added in v0.0.4 

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

func (*Sync_Request) Descriptor deprecated added in v0.0.4 

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

Deprecated: Use Sync_Request.ProtoReflect.Descriptor instead.

func (*Sync_Request) GetSpec added in v0.0.4 

func (x *Sync_Request) GetSpec() []byte

func (*Sync_Request) GetTimestamp added in v0.12.0 

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

func (*Sync_Request) ProtoMessage added in v0.0.4 

func (*Sync_Request) ProtoMessage()

func (*Sync_Request) ProtoReflect added in v0.0.4 

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

func (*Sync_Request) Reset added in v0.0.4 

func (x *Sync_Request) Reset()

func (*Sync_Request) String added in v0.0.4 

func (x *Sync_Request) String() string

type Sync_Response added in v0.0.4 

type Sync_Response struct {

	// marshalled *schema.Resources
	Resource []byte `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	// contains filtered or unexported fields
}

func (*Sync_Response) Descriptor deprecated added in v0.0.4 

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

Deprecated: Use Sync_Response.ProtoReflect.Descriptor instead.

func (*Sync_Response) GetResource added in v0.0.4 

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

func (*Sync_Response) ProtoMessage added in v0.0.4 

func (*Sync_Response) ProtoMessage()

func (*Sync_Response) ProtoReflect added in v0.0.4 

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

func (*Sync_Response) Reset added in v0.0.4 

func (x *Sync_Response) Reset()

func (*Sync_Response) String added in v0.0.4 

func (x *Sync_Response) String() string

type UnimplementedDestinationServer 

type UnimplementedDestinationServer struct {
}

UnimplementedDestinationServer must be embedded to have forward compatible implementations.

func (UnimplementedDestinationServer) Close added in v0.11.4 

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 added in v0.12.0 

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

func (UnimplementedDestinationServer) GetName added in v0.0.10 

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

func (UnimplementedDestinationServer) GetProtocolVersion added in v0.13.8 

func (UnimplementedDestinationServer) GetProtocolVersion(context.Context, *GetProtocolVersion_Request) (*GetProtocolVersion_Response, error)

func (UnimplementedDestinationServer) GetVersion added in v0.0.10 

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

func (UnimplementedDestinationServer) Migrate added in v0.0.4 

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

func (UnimplementedDestinationServer) Write added in v0.0.4 

func (UnimplementedDestinationServer) Write(Destination_WriteServer) error

type UnimplementedSourceServer 

type UnimplementedSourceServer struct {
}

UnimplementedSourceServer must be embedded to have forward compatible implementations.

func (UnimplementedSourceServer) GetName added in v0.0.10 

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

func (UnimplementedSourceServer) GetProtocolVersion added in v0.13.8 

func (UnimplementedSourceServer) GetProtocolVersion(context.Context, *GetProtocolVersion_Request) (*GetProtocolVersion_Response, error)

func (UnimplementedSourceServer) GetSyncSummary added in v0.12.0 

func (UnimplementedSourceServer) GetSyncSummary(context.Context, *GetSyncSummary_Request) (*GetSyncSummary_Response, error)

func (UnimplementedSourceServer) GetTables 

func (UnimplementedSourceServer) GetTables(context.Context, *GetTables_Request) (*GetTables_Response, error)

func (UnimplementedSourceServer) GetVersion added in v0.0.10 

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

func (UnimplementedSourceServer) Sync added in v0.0.4 

func (UnimplementedSourceServer) Sync(*Sync_Request, Source_SyncServer) 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 UnsafeSourceServer 

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

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

type Write added in v0.0.4 

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

func (*Write) Descriptor deprecated added in v0.0.4 

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

Deprecated: Use Write.ProtoReflect.Descriptor instead.

func (*Write) ProtoMessage added in v0.0.4 

func (*Write) ProtoMessage()

func (*Write) ProtoReflect added in v0.0.4 

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

func (*Write) Reset added in v0.0.4 

func (x *Write) Reset()

func (*Write) String added in v0.0.4 

func (x *Write) String() string

type Write_Request added in v0.0.4 

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 added in v0.0.4 

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

Deprecated: Use Write_Request.ProtoReflect.Descriptor instead.

func (*Write_Request) GetResource added in v0.0.4 

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

func (*Write_Request) GetSource added in v0.12.0 

func (x *Write_Request) GetSource() string

func (*Write_Request) GetTimestamp added in v0.12.0 

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

func (*Write_Request) ProtoMessage added in v0.0.4 

func (*Write_Request) ProtoMessage()

func (*Write_Request) ProtoReflect added in v0.0.4 

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

func (*Write_Request) Reset added in v0.0.4 

func (x *Write_Request) Reset()

func (*Write_Request) String added in v0.0.4 

func (x *Write_Request) String() string

type Write_Response added in v0.0.4 

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 added in v0.0.4 

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

Deprecated: Use Write_Response.ProtoReflect.Descriptor instead.

func (*Write_Response) GetFailedWrites added in v0.10.2 

func (x *Write_Response) GetFailedWrites() uint64

func (*Write_Response) ProtoMessage added in v0.0.4 

func (*Write_Response) ProtoMessage()

func (*Write_Response) ProtoReflect added in v0.0.4 

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

func (*Write_Response) Reset added in v0.0.4 

func (x *Write_Response) Reset()

func (*Write_Response) String added in v0.0.4 

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.