plugin

package
v1.14.5 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	Plugin_GetName_FullMethodName    = "/cloudquery.plugin.v3.Plugin/GetName"
	Plugin_GetVersion_FullMethodName = "/cloudquery.plugin.v3.Plugin/GetVersion"
	Plugin_Init_FullMethodName       = "/cloudquery.plugin.v3.Plugin/Init"
	Plugin_GetTables_FullMethodName  = "/cloudquery.plugin.v3.Plugin/GetTables"
	Plugin_Sync_FullMethodName       = "/cloudquery.plugin.v3.Plugin/Sync"
	Plugin_Read_FullMethodName       = "/cloudquery.plugin.v3.Plugin/Read"
	Plugin_Write_FullMethodName      = "/cloudquery.plugin.v3.Plugin/Write"
	Plugin_Close_FullMethodName      = "/cloudquery.plugin.v3.Plugin/Close"
)

Variables

View Source 
var (
	Predicate_Operator_name = map[int32]string{
		0: "EQ",
	}
	Predicate_Operator_value = map[string]int32{
		"EQ": 0,
	}
)

Enum value maps for Predicate_Operator.

View Source 
var (
	PredicatesGroup_GroupingType_name = map[int32]string{
		0: "AND",
		1: "OR",
	}
	PredicatesGroup_GroupingType_value = map[string]int32{
		"AND": 0,
		"OR":  1,
	}
)

Enum value maps for PredicatesGroup_GroupingType.

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:    "Read",
			Handler:       _Plugin_Read_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 NewSchemasFromBytes added in v1.3.2 

func NewSchemasFromBytes(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)

func SchemasToBytes added in v1.3.2 

func SchemasToBytes(schemas []*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"`
	SkipDependentTables bool     `protobuf:"varint,3,opt,name=skip_dependent_tables,json=skipDependentTables,proto3" json:"skip_dependent_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) GetSkipDependentTables added in v1.9.2 

func (x *GetTables_Request) GetSkipDependentTables() bool

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 {
	Spec         []byte `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`                                      // Internal plugin-specific spec
	NoConnection bool   `protobuf:"varint,2,opt,name=no_connection,json=noConnection,proto3" json:"no_connection,omitempty"` // A flag to indicate plugins should skip establishing a connection
	// 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) GetNoConnection added in v1.7.1 

func (x *Init_Request) GetNoConnection() bool

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 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 a sync on the source plugin. It streams messages as output.
	Sync(ctx context.Context, in *Sync_Request, opts ...grpc.CallOption) (Plugin_SyncClient, error)
	// Start a Read on the source plugin for a given table and schema. It streams messages as output.
	// The plugin assume that that schema was used to also write the data beforehand
	Read(ctx context.Context, in *Read_Request, opts ...grpc.CallOption) (Plugin_ReadClient, error)
	// Write resources. Write is the mirror of Sync, expecting a stream of messages as input.
	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 a sync on the source plugin. It streams messages as output.
	Sync(*Sync_Request, Plugin_SyncServer) error
	// Start a Read on the source plugin for a given table and schema. It streams messages as output.
	// The plugin assume that that schema was used to also write the data beforehand
	Read(*Read_Request, Plugin_ReadServer) error
	// Write resources. Write is the mirror of Sync, expecting a stream of messages as input.
	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_ReadClient added in v1.5.0 

type Plugin_ReadClient interface {
	Recv() (*Read_Response, error)
	grpc.ClientStream
}

type Plugin_ReadServer added in v1.5.0 

type Plugin_ReadServer interface {
	Send(*Read_Response) error
	grpc.ServerStream
}

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 Predicate added in v1.12.3 

type Predicate struct {
	Operator Predicate_Operator `protobuf:"varint,1,opt,name=operator,proto3,enum=cloudquery.plugin.v3.Predicate_Operator" json:"operator,omitempty"`
	Column   string             `protobuf:"bytes,2,opt,name=column,proto3" json:"column,omitempty"`
	// marshalled arrow.Record
	Record []byte `protobuf:"bytes,3,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

func (*Predicate) Descriptor deprecated added in v1.12.3 

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

Deprecated: Use Predicate.ProtoReflect.Descriptor instead.

func (*Predicate) GetColumn added in v1.12.3 

func (x *Predicate) GetColumn() string

func (*Predicate) GetOperator added in v1.12.3 

func (x *Predicate) GetOperator() Predicate_Operator

func (*Predicate) GetRecord added in v1.12.3 

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

func (*Predicate) ProtoMessage added in v1.12.3 

func (*Predicate) ProtoMessage()

func (*Predicate) ProtoReflect added in v1.12.3 

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

func (*Predicate) Reset added in v1.12.3 

func (x *Predicate) Reset()

func (*Predicate) String added in v1.12.3 

func (x *Predicate) String() string

type Predicate_Operator added in v1.12.3 

type Predicate_Operator int32
const (
	Predicate_EQ Predicate_Operator = 0
)

func (Predicate_Operator) Descriptor added in v1.12.3 

func (Predicate_Operator) Descriptor() protoreflect.EnumDescriptor

func (Predicate_Operator) Enum added in v1.12.3 

func (x Predicate_Operator) Enum() *Predicate_Operator

func (Predicate_Operator) EnumDescriptor deprecated added in v1.12.3 

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

Deprecated: Use Predicate_Operator.Descriptor instead.

func (Predicate_Operator) Number added in v1.12.3 

func (x Predicate_Operator) Number() protoreflect.EnumNumber

func (Predicate_Operator) String added in v1.12.3 

func (x Predicate_Operator) String() string

func (Predicate_Operator) Type added in v1.12.3 

func (Predicate_Operator) Type() protoreflect.EnumType

type PredicatesGroup added in v1.12.3 

type PredicatesGroup struct {
	GroupingType PredicatesGroup_GroupingType `` /* 153-byte string literal not displayed */
	Predicates   []*Predicate                 `protobuf:"bytes,2,rep,name=predicates,proto3" json:"predicates,omitempty"`
	// contains filtered or unexported fields
}

func (*PredicatesGroup) Descriptor deprecated added in v1.12.3 

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

Deprecated: Use PredicatesGroup.ProtoReflect.Descriptor instead.

func (*PredicatesGroup) GetGroupingType added in v1.12.3 

func (x *PredicatesGroup) GetGroupingType() PredicatesGroup_GroupingType

func (*PredicatesGroup) GetPredicates added in v1.12.3 

func (x *PredicatesGroup) GetPredicates() []*Predicate

func (*PredicatesGroup) ProtoMessage added in v1.12.3 

func (*PredicatesGroup) ProtoMessage()

func (*PredicatesGroup) ProtoReflect added in v1.12.3 

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

func (*PredicatesGroup) Reset added in v1.12.3 

func (x *PredicatesGroup) Reset()

func (*PredicatesGroup) String added in v1.12.3 

func (x *PredicatesGroup) String() string

type PredicatesGroup_GroupingType added in v1.12.3 

type PredicatesGroup_GroupingType int32
const (
	PredicatesGroup_AND PredicatesGroup_GroupingType = 0
	PredicatesGroup_OR  PredicatesGroup_GroupingType = 1
)

func (PredicatesGroup_GroupingType) Descriptor added in v1.12.3 

func (PredicatesGroup_GroupingType) Descriptor() protoreflect.EnumDescriptor

func (PredicatesGroup_GroupingType) Enum added in v1.12.3 

func (x PredicatesGroup_GroupingType) Enum() *PredicatesGroup_GroupingType

func (PredicatesGroup_GroupingType) EnumDescriptor deprecated added in v1.12.3 

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

Deprecated: Use PredicatesGroup_GroupingType.Descriptor instead.

func (PredicatesGroup_GroupingType) Number added in v1.12.3 

func (x PredicatesGroup_GroupingType) Number() protoreflect.EnumNumber

func (PredicatesGroup_GroupingType) String added in v1.12.3 

func (x PredicatesGroup_GroupingType) String() string

func (PredicatesGroup_GroupingType) Type added in v1.12.3 

func (PredicatesGroup_GroupingType) Type() protoreflect.EnumType

type Read added in v1.5.0 

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

func (*Read) Descriptor deprecated added in v1.5.0 

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

Deprecated: Use Read.ProtoReflect.Descriptor instead.

func (*Read) ProtoMessage added in v1.5.0 

func (*Read) ProtoMessage()

func (*Read) ProtoReflect added in v1.5.0 

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

func (*Read) Reset added in v1.5.0 

func (x *Read) Reset()

func (*Read) String added in v1.5.0 

func (x *Read) String() string

type Read_Request added in v1.5.0 

type Read_Request struct {

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

func (*Read_Request) Descriptor deprecated added in v1.5.0 

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

Deprecated: Use Read_Request.ProtoReflect.Descriptor instead.

func (*Read_Request) GetTable added in v1.5.0 

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

func (*Read_Request) ProtoMessage added in v1.5.0 

func (*Read_Request) ProtoMessage()

func (*Read_Request) ProtoReflect added in v1.5.0 

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

func (*Read_Request) Reset added in v1.5.0 

func (x *Read_Request) Reset()

func (*Read_Request) String added in v1.5.0 

func (x *Read_Request) String() string

type Read_Response added in v1.5.0 

type Read_Response struct {

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

func (*Read_Response) Descriptor deprecated added in v1.5.0 

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

Deprecated: Use Read_Response.ProtoReflect.Descriptor instead.

func (*Read_Response) GetRecord added in v1.5.0 

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

func (*Read_Response) ProtoMessage added in v1.5.0 

func (*Read_Response) ProtoMessage()

func (*Read_Response) ProtoReflect added in v1.5.0 

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

func (*Read_Response) Reset added in v1.5.0 

func (x *Read_Response) Reset()

func (*Read_Response) String added in v1.5.0 

func (x *Read_Response) 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_BackendOptions added in v1.5.1 

type Sync_BackendOptions struct {

	// table name to use for state backend
	TableName string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// connection path to use for state backend
	Connection string `protobuf:"bytes,2,opt,name=connection,proto3" json:"connection,omitempty"`
	// contains filtered or unexported fields
}

func (*Sync_BackendOptions) Descriptor deprecated added in v1.5.1 

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

Deprecated: Use Sync_BackendOptions.ProtoReflect.Descriptor instead.

func (*Sync_BackendOptions) GetConnection added in v1.5.1 

func (x *Sync_BackendOptions) GetConnection() string

func (*Sync_BackendOptions) GetTableName added in v1.5.1 

func (x *Sync_BackendOptions) GetTableName() string

func (*Sync_BackendOptions) ProtoMessage added in v1.5.1 

func (*Sync_BackendOptions) ProtoMessage()

func (*Sync_BackendOptions) ProtoReflect added in v1.5.1 

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

func (*Sync_BackendOptions) Reset added in v1.5.1 

func (x *Sync_BackendOptions) Reset()

func (*Sync_BackendOptions) String added in v1.5.1 

func (x *Sync_BackendOptions) String() string

type Sync_MessageDeleteRecord added in v1.12.3 

type Sync_MessageDeleteRecord struct {
	TableName      string             `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	WhereClause    []*PredicatesGroup `protobuf:"bytes,2,rep,name=where_clause,json=whereClause,proto3" json:"where_clause,omitempty"`
	TableRelations []*TableRelation   `protobuf:"bytes,3,rep,name=table_relations,json=tableRelations,proto3" json:"table_relations,omitempty"`
	// contains filtered or unexported fields
}

func (*Sync_MessageDeleteRecord) Descriptor deprecated added in v1.12.3 

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

Deprecated: Use Sync_MessageDeleteRecord.ProtoReflect.Descriptor instead.

func (*Sync_MessageDeleteRecord) GetTableName added in v1.12.3 

func (x *Sync_MessageDeleteRecord) GetTableName() string

func (*Sync_MessageDeleteRecord) GetTableRelations added in v1.12.3 

func (x *Sync_MessageDeleteRecord) GetTableRelations() []*TableRelation

func (*Sync_MessageDeleteRecord) GetWhereClause added in v1.12.3 

func (x *Sync_MessageDeleteRecord) GetWhereClause() []*PredicatesGroup

func (*Sync_MessageDeleteRecord) ProtoMessage added in v1.12.3 

func (*Sync_MessageDeleteRecord) ProtoMessage()

func (*Sync_MessageDeleteRecord) ProtoReflect added in v1.12.3 

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

func (*Sync_MessageDeleteRecord) Reset added in v1.12.3 

func (x *Sync_MessageDeleteRecord) Reset()

func (*Sync_MessageDeleteRecord) String added in v1.12.3 

func (x *Sync_MessageDeleteRecord) String() string

type Sync_MessageInsert added in v1.3.6 

type Sync_MessageInsert struct {

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

func (*Sync_MessageInsert) Descriptor deprecated added in v1.3.6 

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

Deprecated: Use Sync_MessageInsert.ProtoReflect.Descriptor instead.

func (*Sync_MessageInsert) GetRecord added in v1.3.6 

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

func (*Sync_MessageInsert) ProtoMessage added in v1.3.6 

func (*Sync_MessageInsert) ProtoMessage()

func (*Sync_MessageInsert) ProtoReflect added in v1.3.6 

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

func (*Sync_MessageInsert) Reset added in v1.3.6 

func (x *Sync_MessageInsert) Reset()

func (*Sync_MessageInsert) String added in v1.3.6 

func (x *Sync_MessageInsert) String() string

type Sync_MessageMigrateTable added in v1.3.6 

type Sync_MessageMigrateTable struct {

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

func (*Sync_MessageMigrateTable) Descriptor deprecated added in v1.3.6 

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

Deprecated: Use Sync_MessageMigrateTable.ProtoReflect.Descriptor instead.

func (*Sync_MessageMigrateTable) GetTable added in v1.3.6 

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

func (*Sync_MessageMigrateTable) ProtoMessage added in v1.3.6 

func (*Sync_MessageMigrateTable) ProtoMessage()

func (*Sync_MessageMigrateTable) ProtoReflect added in v1.3.6 

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

func (*Sync_MessageMigrateTable) Reset added in v1.3.6 

func (x *Sync_MessageMigrateTable) Reset()

func (*Sync_MessageMigrateTable) String added in v1.3.6 

func (x *Sync_MessageMigrateTable) 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"`
	SkipDependentTables bool                 `protobuf:"varint,3,opt,name=skip_dependent_tables,json=skipDependentTables,proto3" json:"skip_dependent_tables,omitempty"`
	DeterministicCqId   bool                 `protobuf:"varint,4,opt,name=deterministic_cq_id,json=deterministicCqId,proto3" json:"deterministic_cq_id,omitempty"`
	Backend             *Sync_BackendOptions `protobuf:"bytes,5,opt,name=backend,proto3" json:"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) GetBackend added in v1.5.1 

func (x *Sync_Request) GetBackend() *Sync_BackendOptions

func (*Sync_Request) GetDeterministicCqId added in v1.3.4 

func (x *Sync_Request) GetDeterministicCqId() bool

func (*Sync_Request) GetSkipDependentTables added in v1.3.4 

func (x *Sync_Request) GetSkipDependentTables() bool

func (*Sync_Request) GetSkipTables 

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

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_DeleteRecord
	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) GetDeleteRecord added in v1.12.3 

func (x *Sync_Response) GetDeleteRecord() *Sync_MessageDeleteRecord

func (*Sync_Response) GetInsert 

func (x *Sync_Response) GetInsert() *Sync_MessageInsert

func (*Sync_Response) GetMessage 

func (m *Sync_Response) GetMessage() isSync_Response_Message

func (*Sync_Response) GetMigrateTable 

func (x *Sync_Response) GetMigrateTable() *Sync_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_DeleteRecord added in v1.12.3 

type Sync_Response_DeleteRecord struct {
	DeleteRecord *Sync_MessageDeleteRecord `protobuf:"bytes,3,opt,name=delete_record,json=deleteRecord,proto3,oneof"`
}

type Sync_Response_Insert 

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

type Sync_Response_MigrateTable 

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

type TableRelation added in v1.12.3 

type TableRelation struct {
	TableName   string `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	ParentTable string `protobuf:"bytes,2,opt,name=parent_table,json=parentTable,proto3" json:"parent_table,omitempty"`
	// contains filtered or unexported fields
}

func (*TableRelation) Descriptor deprecated added in v1.12.3 

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

Deprecated: Use TableRelation.ProtoReflect.Descriptor instead.

func (*TableRelation) GetParentTable added in v1.12.3 

func (x *TableRelation) GetParentTable() string

func (*TableRelation) GetTableName added in v1.12.3 

func (x *TableRelation) GetTableName() string

func (*TableRelation) ProtoMessage added in v1.12.3 

func (*TableRelation) ProtoMessage()

func (*TableRelation) ProtoReflect added in v1.12.3 

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

func (*TableRelation) Reset added in v1.12.3 

func (x *TableRelation) Reset()

func (*TableRelation) String added in v1.12.3 

func (x *TableRelation) String() string

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) Read added in v1.5.0 

func (UnimplementedPluginServer) Read(*Read_Request, Plugin_ReadServer) 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 Write_MessageDeleteRecord added in v1.12.3 

type Write_MessageDeleteRecord struct {
	TableName      string             `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	WhereClause    []*PredicatesGroup `protobuf:"bytes,2,rep,name=where_clause,json=whereClause,proto3" json:"where_clause,omitempty"`
	TableRelations []*TableRelation   `protobuf:"bytes,3,rep,name=table_relations,json=tableRelations,proto3" json:"table_relations,omitempty"`
	// contains filtered or unexported fields
}

func (*Write_MessageDeleteRecord) Descriptor deprecated added in v1.12.3 

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

Deprecated: Use Write_MessageDeleteRecord.ProtoReflect.Descriptor instead.

func (*Write_MessageDeleteRecord) GetTableName added in v1.12.3 

func (x *Write_MessageDeleteRecord) GetTableName() string

func (*Write_MessageDeleteRecord) GetTableRelations added in v1.12.3 

func (x *Write_MessageDeleteRecord) GetTableRelations() []*TableRelation

func (*Write_MessageDeleteRecord) GetWhereClause added in v1.12.3 

func (x *Write_MessageDeleteRecord) GetWhereClause() []*PredicatesGroup

func (*Write_MessageDeleteRecord) ProtoMessage added in v1.12.3 

func (*Write_MessageDeleteRecord) ProtoMessage()

func (*Write_MessageDeleteRecord) ProtoReflect added in v1.12.3 

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

func (*Write_MessageDeleteRecord) Reset added in v1.12.3 

func (x *Write_MessageDeleteRecord) Reset()

func (*Write_MessageDeleteRecord) String added in v1.12.3 

func (x *Write_MessageDeleteRecord) String() string

type Write_MessageDeleteStale added in v1.3.6 

type Write_MessageDeleteStale struct {

	// marshalled arrow.Schema
	//
	// Deprecated: Marked as deprecated in plugin-pb/plugin/v3/plugin.proto.
	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"`
	TableName  string                 `protobuf:"bytes,4,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// contains filtered or unexported fields
}

func (*Write_MessageDeleteStale) Descriptor deprecated added in v1.3.6 

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

Deprecated: Use Write_MessageDeleteStale.ProtoReflect.Descriptor instead.

func (*Write_MessageDeleteStale) GetSourceName added in v1.3.6 

func (x *Write_MessageDeleteStale) GetSourceName() string

func (*Write_MessageDeleteStale) GetSyncTime added in v1.3.6 

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

func (*Write_MessageDeleteStale) GetTable deprecated added in v1.3.6 

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

Deprecated: Marked as deprecated in plugin-pb/plugin/v3/plugin.proto.

func (*Write_MessageDeleteStale) GetTableName added in v1.5.0 

func (x *Write_MessageDeleteStale) GetTableName() string

func (*Write_MessageDeleteStale) ProtoMessage added in v1.3.6 

func (*Write_MessageDeleteStale) ProtoMessage()

func (*Write_MessageDeleteStale) ProtoReflect added in v1.3.6 

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

func (*Write_MessageDeleteStale) Reset added in v1.3.6 

func (x *Write_MessageDeleteStale) Reset()

func (*Write_MessageDeleteStale) String added in v1.3.6 

func (x *Write_MessageDeleteStale) String() string

type Write_MessageInsert added in v1.3.6 

type Write_MessageInsert struct {

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

func (*Write_MessageInsert) Descriptor deprecated added in v1.3.6 

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

Deprecated: Use Write_MessageInsert.ProtoReflect.Descriptor instead.

func (*Write_MessageInsert) GetRecord added in v1.3.6 

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

func (*Write_MessageInsert) ProtoMessage added in v1.3.6 

func (*Write_MessageInsert) ProtoMessage()

func (*Write_MessageInsert) ProtoReflect added in v1.3.6 

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

func (*Write_MessageInsert) Reset added in v1.3.6 

func (x *Write_MessageInsert) Reset()

func (*Write_MessageInsert) String added in v1.3.6 

func (x *Write_MessageInsert) String() string

type Write_MessageMigrateTable added in v1.3.6 

type Write_MessageMigrateTable struct {

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

func (*Write_MessageMigrateTable) Descriptor deprecated added in v1.3.6 

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

Deprecated: Use Write_MessageMigrateTable.ProtoReflect.Descriptor instead.

func (*Write_MessageMigrateTable) GetMigrateForce added in v1.4.0 

func (x *Write_MessageMigrateTable) GetMigrateForce() bool

func (*Write_MessageMigrateTable) GetTable added in v1.3.6 

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

func (*Write_MessageMigrateTable) ProtoMessage added in v1.3.6 

func (*Write_MessageMigrateTable) ProtoMessage()

func (*Write_MessageMigrateTable) ProtoReflect added in v1.3.6 

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

func (*Write_MessageMigrateTable) Reset added in v1.3.6 

func (x *Write_MessageMigrateTable) Reset()

func (*Write_MessageMigrateTable) String added in v1.3.6 

func (x *Write_MessageMigrateTable) String() string

type Write_Request 

type Write_Request struct {

	// Types that are assignable to Message:
	//
	//	*Write_Request_MigrateTable
	//	*Write_Request_Insert
	//	*Write_Request_Delete
	//	*Write_Request_DeleteRecord
	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() *Write_MessageDeleteStale

func (*Write_Request) GetDeleteRecord added in v1.12.3 

func (x *Write_Request) GetDeleteRecord() *Write_MessageDeleteRecord

func (*Write_Request) GetInsert 

func (x *Write_Request) GetInsert() *Write_MessageInsert

func (*Write_Request) GetMessage 

func (m *Write_Request) GetMessage() isWrite_Request_Message

func (*Write_Request) GetMigrateTable 

func (x *Write_Request) GetMigrateTable() *Write_MessageMigrateTable

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 *Write_MessageDeleteStale `protobuf:"bytes,3,opt,name=delete,proto3,oneof"`
}

type Write_Request_DeleteRecord added in v1.12.3 

type Write_Request_DeleteRecord struct {
	DeleteRecord *Write_MessageDeleteRecord `protobuf:"bytes,4,opt,name=delete_record,json=deleteRecord,proto3,oneof"`
}

type Write_Request_Insert 

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

type Write_Request_MigrateTable 

type Write_Request_MigrateTable struct {
	MigrateTable *Write_MessageMigrateTable `protobuf:"bytes,1,opt,name=migrate_table,json=migrateTable,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.