plugin

package
v1.3.1 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Registry_name = map[int32]string{
		0: "REGISTRY_UNSPECIFIED",
		1: "REGISTRY_GITHUB",
		2: "REGISTRY_GRPC",
		3: "REGISTRY_LOCAL",
	}
	Registry_value = map[string]int32{
		"REGISTRY_UNSPECIFIED": 0,
		"REGISTRY_GITHUB":      1,
		"REGISTRY_GRPC":        2,
		"REGISTRY_LOCAL":       3,
	}
)

Enum value maps for Registry.

View Source 
var File_plugin_pb_plugin_v3_plugin_proto protoreflect.FileDescriptor
View Source 
var Plugin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cloudquery.plugin.v3.Plugin",
	HandlerType: (*PluginServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetName",
			Handler:    _Plugin_GetName_Handler,
		},
		{
			MethodName: "GetVersion",
			Handler:    _Plugin_GetVersion_Handler,
		},
		{
			MethodName: "Init",
			Handler:    _Plugin_Init_Handler,
		},
		{
			MethodName: "GetTables",
			Handler:    _Plugin_GetTables_Handler,
		},
		{
			MethodName: "Close",
			Handler:    _Plugin_Close_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Sync",
			Handler:       _Plugin_Sync_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Write",
			Handler:       _Plugin_Write_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "plugin-pb/plugin/v3/plugin.proto",
}

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

Functions

func NewRecordFromBytes 

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

func NewSchemaFromBytes 

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

func RecordToBytes 

func RecordToBytes(record arrow.Record) ([]byte, error)

func RegisterPluginServer 

func RegisterPluginServer(s grpc.ServiceRegistrar, srv PluginServer)

func SchemaToBytes 

func SchemaToBytes(sc *arrow.Schema) ([]byte, error)

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 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 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 {
	Tables     []string `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
	SkipTables []string `protobuf:"bytes,2,rep,name=skip_tables,json=skipTables,proto3" json:"skip_tables,omitempty"`
	// 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) GetSkipTables 

func (x *GetTables_Request) GetSkipTables() []string

func (*GetTables_Request) GetTables 

func (x *GetTables_Request) GetTables() []string

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 {

	// marshalled []arrow.Schema
	Tables [][]byte `protobuf:"bytes,1,rep,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) GetTables 

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

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 

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 Init 

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

func (*Init) Descriptor deprecated 

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

Deprecated: Use Init.ProtoReflect.Descriptor instead.

func (*Init) ProtoMessage 

func (*Init) ProtoMessage()

func (*Init) ProtoReflect 

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

func (*Init) Reset 

func (x *Init) Reset()

func (*Init) String 

func (x *Init) String() string

type Init_Request 

type Init_Request struct {

	// Internal plugin-specific spec
	Spec []byte `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*Init_Request) Descriptor deprecated 

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

Deprecated: Use Init_Request.ProtoReflect.Descriptor instead.

func (*Init_Request) GetSpec 

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

func (*Init_Request) ProtoMessage 

func (*Init_Request) ProtoMessage()

func (*Init_Request) ProtoReflect 

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

func (*Init_Request) Reset 

func (x *Init_Request) Reset()

func (*Init_Request) String 

func (x *Init_Request) String() string

type Init_Response 

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

func (*Init_Response) Descriptor deprecated 

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

Deprecated: Use Init_Response.ProtoReflect.Descriptor instead.

func (*Init_Response) ProtoMessage 

func (*Init_Response) ProtoMessage()

func (*Init_Response) ProtoReflect 

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

func (*Init_Response) Reset 

func (x *Init_Response) Reset()

func (*Init_Response) String 

func (x *Init_Response) String() string

type MessageDeleteStale 

type MessageDeleteStale struct {

	// marshalled arrow.Schema
	Table      []byte                 `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	SourceName string                 `protobuf:"bytes,2,opt,name=source_name,json=sourceName,proto3" json:"source_name,omitempty"`
	SyncTime   *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=sync_time,json=syncTime,proto3" json:"sync_time,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageDeleteStale) Descriptor deprecated 

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

Deprecated: Use MessageDeleteStale.ProtoReflect.Descriptor instead.

func (*MessageDeleteStale) GetSourceName 

func (x *MessageDeleteStale) GetSourceName() string

func (*MessageDeleteStale) GetSyncTime 

func (x *MessageDeleteStale) GetSyncTime() *timestamppb.Timestamp

func (*MessageDeleteStale) GetTable 

func (x *MessageDeleteStale) GetTable() []byte

func (*MessageDeleteStale) ProtoMessage 

func (*MessageDeleteStale) ProtoMessage()

func (*MessageDeleteStale) ProtoReflect 

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

func (*MessageDeleteStale) Reset 

func (x *MessageDeleteStale) Reset()

func (*MessageDeleteStale) String 

func (x *MessageDeleteStale) String() string

type MessageInsert 

type MessageInsert struct {

	// marshalled arrow.Record
	Record []byte `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageInsert) Descriptor deprecated 

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

Deprecated: Use MessageInsert.ProtoReflect.Descriptor instead.

func (*MessageInsert) GetRecord 

func (x *MessageInsert) GetRecord() []byte

func (*MessageInsert) ProtoMessage 

func (*MessageInsert) ProtoMessage()

func (*MessageInsert) ProtoReflect 

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

func (*MessageInsert) Reset 

func (x *MessageInsert) Reset()

func (*MessageInsert) String 

func (x *MessageInsert) String() string

type MessageMigrateTable 

type MessageMigrateTable struct {

	// marshalled arrow.Schema
	Table []byte `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

func (*MessageMigrateTable) Descriptor deprecated 

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

Deprecated: Use MessageMigrateTable.ProtoReflect.Descriptor instead.

func (*MessageMigrateTable) GetTable 

func (x *MessageMigrateTable) GetTable() []byte

func (*MessageMigrateTable) ProtoMessage 

func (*MessageMigrateTable) ProtoMessage()

func (*MessageMigrateTable) ProtoReflect 

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

func (*MessageMigrateTable) Reset 

func (x *MessageMigrateTable) Reset()

func (*MessageMigrateTable) String 

func (x *MessageMigrateTable) String() string

type PluginClient 

type PluginClient 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
	Init(ctx context.Context, in *Init_Request, opts ...grpc.CallOption) (*Init_Response, error)
	// Get all tables the source plugin supports. Must be called after Init
	GetTables(ctx context.Context, in *GetTables_Request, opts ...grpc.CallOption) (*GetTables_Response, error)
	// Start the sync the source plugin
	Sync(ctx context.Context, in *Sync_Request, opts ...grpc.CallOption) (Plugin_SyncClient, error)
	// Write resources
	Write(ctx context.Context, opts ...grpc.CallOption) (Plugin_WriteClient, error)
	// Send signal to flush and close open connections
	Close(ctx context.Context, in *Close_Request, opts ...grpc.CallOption) (*Close_Response, error)
}

PluginClient is the client API for Plugin 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 NewPluginClient 

func NewPluginClient(cc grpc.ClientConnInterface) PluginClient

type PluginServer 

type PluginServer 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
	Init(context.Context, *Init_Request) (*Init_Response, error)
	// Get all tables the source plugin supports. Must be called after Init
	GetTables(context.Context, *GetTables_Request) (*GetTables_Response, error)
	// Start the sync the source plugin
	Sync(*Sync_Request, Plugin_SyncServer) error
	// Write resources
	Write(Plugin_WriteServer) error
	// Send signal to flush and close open connections
	Close(context.Context, *Close_Request) (*Close_Response, error)
	// contains filtered or unexported methods
}

PluginServer is the server API for Plugin service. All implementations must embed UnimplementedPluginServer for forward compatibility

type Plugin_SyncClient 

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

type Plugin_SyncServer 

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

type Plugin_WriteClient 

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

type Plugin_WriteServer 

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

type Registry 

type Registry int32
const (
	Registry_REGISTRY_UNSPECIFIED Registry = 0
	Registry_REGISTRY_GITHUB      Registry = 1
	Registry_REGISTRY_GRPC        Registry = 2
	Registry_REGISTRY_LOCAL       Registry = 3
)

func (Registry) Descriptor 

func (Registry) Descriptor() protoreflect.EnumDescriptor

func (Registry) Enum 

func (x Registry) Enum() *Registry

func (Registry) EnumDescriptor deprecated 

func (Registry) EnumDescriptor() ([]byte, []int)

Deprecated: Use Registry.Descriptor instead.

func (Registry) Number 

func (x Registry) Number() protoreflect.EnumNumber

func (Registry) String 

func (x Registry) String() string

func (Registry) Type 

func (Registry) Type() protoreflect.EnumType

type StateBackendSpec 

type StateBackendSpec struct {
	Name     string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Path     string   `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Version  string   `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Registry Registry `protobuf:"varint,4,opt,name=registry,proto3,enum=cloudquery.plugin.v3.Registry" json:"registry,omitempty"`
	Spec     []byte   `protobuf:"bytes,5,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*StateBackendSpec) Descriptor deprecated 

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

Deprecated: Use StateBackendSpec.ProtoReflect.Descriptor instead.

func (*StateBackendSpec) GetName 

func (x *StateBackendSpec) GetName() string

func (*StateBackendSpec) GetPath 

func (x *StateBackendSpec) GetPath() string

func (*StateBackendSpec) GetRegistry 

func (x *StateBackendSpec) GetRegistry() Registry

func (*StateBackendSpec) GetSpec 

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

func (*StateBackendSpec) GetVersion 

func (x *StateBackendSpec) GetVersion() string

func (*StateBackendSpec) ProtoMessage 

func (*StateBackendSpec) ProtoMessage()

func (*StateBackendSpec) ProtoReflect 

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

func (*StateBackendSpec) Reset 

func (x *StateBackendSpec) Reset()

func (*StateBackendSpec) String 

func (x *StateBackendSpec) String() string

type Sync 

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

func (*Sync) Descriptor deprecated 

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

Deprecated: Use Sync.ProtoReflect.Descriptor instead.

func (*Sync) ProtoMessage 

func (*Sync) ProtoMessage()

func (*Sync) ProtoReflect 

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

func (*Sync) Reset 

func (x *Sync) Reset()

func (*Sync) String 

func (x *Sync) String() string

type Sync_Request 

type Sync_Request struct {
	Tables       []string          `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
	SkipTables   []string          `protobuf:"bytes,2,rep,name=skip_tables,json=skipTables,proto3" json:"skip_tables,omitempty"`
	StateBackend *StateBackendSpec `protobuf:"bytes,3,opt,name=state_backend,json=stateBackend,proto3" json:"state_backend,omitempty"`
	// contains filtered or unexported fields
}

func (*Sync_Request) Descriptor deprecated 

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

Deprecated: Use Sync_Request.ProtoReflect.Descriptor instead.

func (*Sync_Request) GetSkipTables 

func (x *Sync_Request) GetSkipTables() []string

func (*Sync_Request) GetStateBackend 

func (x *Sync_Request) GetStateBackend() *StateBackendSpec

func (*Sync_Request) GetTables 

func (x *Sync_Request) GetTables() []string

func (*Sync_Request) ProtoMessage 

func (*Sync_Request) ProtoMessage()

func (*Sync_Request) ProtoReflect 

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

func (*Sync_Request) Reset 

func (x *Sync_Request) Reset()

func (*Sync_Request) String 

func (x *Sync_Request) String() string

type Sync_Response 

type Sync_Response struct {

	// Types that are assignable to Message:
	//
	//	*Sync_Response_MigrateTable
	//	*Sync_Response_Insert
	//	*Sync_Response_Delete
	Message isSync_Response_Message `protobuf_oneof:"message"`
	// contains filtered or unexported fields
}

func (*Sync_Response) Descriptor deprecated 

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

Deprecated: Use Sync_Response.ProtoReflect.Descriptor instead.

func (*Sync_Response) GetDelete 

func (x *Sync_Response) GetDelete() *MessageDeleteStale

func (*Sync_Response) GetInsert 

func (x *Sync_Response) GetInsert() *MessageInsert

func (*Sync_Response) GetMessage 

func (m *Sync_Response) GetMessage() isSync_Response_Message

func (*Sync_Response) GetMigrateTable 

func (x *Sync_Response) GetMigrateTable() *MessageMigrateTable

func (*Sync_Response) ProtoMessage 

func (*Sync_Response) ProtoMessage()

func (*Sync_Response) ProtoReflect 

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

func (*Sync_Response) Reset 

func (x *Sync_Response) Reset()

func (*Sync_Response) String 

func (x *Sync_Response) String() string

type Sync_Response_Delete 

type Sync_Response_Delete struct {
	Delete *MessageDeleteStale `protobuf:"bytes,3,opt,name=delete,proto3,oneof"`
}

type Sync_Response_Insert 

type Sync_Response_Insert struct {
	Insert *MessageInsert `protobuf:"bytes,2,opt,name=insert,proto3,oneof"`
}

type Sync_Response_MigrateTable 

type Sync_Response_MigrateTable struct {
	MigrateTable *MessageMigrateTable `protobuf:"bytes,1,opt,name=migrate_table,json=migrateTable,proto3,oneof"`
}

type UnimplementedPluginServer 

type UnimplementedPluginServer struct {
}

UnimplementedPluginServer must be embedded to have forward compatible implementations.

func (UnimplementedPluginServer) Close 

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

func (UnimplementedPluginServer) GetName 

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

func (UnimplementedPluginServer) GetTables 

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

func (UnimplementedPluginServer) GetVersion 

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

func (UnimplementedPluginServer) Init 

func (UnimplementedPluginServer) Init(context.Context, *Init_Request) (*Init_Response, error)

func (UnimplementedPluginServer) Sync 

func (UnimplementedPluginServer) Sync(*Sync_Request, Plugin_SyncServer) error

func (UnimplementedPluginServer) Write 

func (UnimplementedPluginServer) Write(Plugin_WriteServer) error

type UnsafePluginServer 

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

UnsafePluginServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PluginServer 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 WriteOptions 

type WriteOptions struct {
	MigrateForce bool `protobuf:"varint,1,opt,name=migrate_force,json=migrateForce,proto3" json:"migrate_force,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteOptions) Descriptor deprecated 

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

Deprecated: Use WriteOptions.ProtoReflect.Descriptor instead.

func (*WriteOptions) GetMigrateForce 

func (x *WriteOptions) GetMigrateForce() bool

func (*WriteOptions) ProtoMessage 

func (*WriteOptions) ProtoMessage()

func (*WriteOptions) ProtoReflect 

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

func (*WriteOptions) Reset 

func (x *WriteOptions) Reset()

func (*WriteOptions) String 

func (x *WriteOptions) String() string

type Write_Request 

type Write_Request struct {

	// Types that are assignable to Message:
	//
	//	*Write_Request_Options
	//	*Write_Request_MigrateTable
	//	*Write_Request_Insert
	//	*Write_Request_Delete
	Message isWrite_Request_Message `protobuf_oneof:"message"`
	// 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) GetDelete 

func (x *Write_Request) GetDelete() *MessageDeleteStale

func (*Write_Request) GetInsert 

func (x *Write_Request) GetInsert() *MessageInsert

func (*Write_Request) GetMessage 

func (m *Write_Request) GetMessage() isWrite_Request_Message

func (*Write_Request) GetMigrateTable 

func (x *Write_Request) GetMigrateTable() *MessageMigrateTable

func (*Write_Request) GetOptions 

func (x *Write_Request) GetOptions() *WriteOptions

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_Request_Delete 

type Write_Request_Delete struct {
	Delete *MessageDeleteStale `protobuf:"bytes,4,opt,name=delete,proto3,oneof"`
}

type Write_Request_Insert 

type Write_Request_Insert struct {
	Insert *MessageInsert `protobuf:"bytes,3,opt,name=insert,proto3,oneof"`
}

type Write_Request_MigrateTable 

type Write_Request_MigrateTable struct {
	MigrateTable *MessageMigrateTable `protobuf:"bytes,2,opt,name=migrate_table,json=migrateTable,proto3,oneof"`
}

type Write_Request_Options 

type Write_Request_Options struct {
	// WriteOptions is only used for the first message
	// to configure the write stream
	Options *WriteOptions `protobuf:"bytes,1,opt,name=options,proto3,oneof"`
}

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.