plugins

package
v0.13.0 Latest Latest
Warning

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

 Go to latest Published: May 11, 2024 License: MPL-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source 
const APILevel = 2

Variables

View Source 
var Datasource_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "plugins.Datasource",
	HandlerType: (*DatasourceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetTable",
			Handler:    _Datasource_GetTable_Handler,
		},
		{
			MethodName: "PushDownPredicates",
			Handler:    _Datasource_PushDownPredicates_Handler,
		},
		{
			MethodName: "Materialize",
			Handler:    _Datasource_Materialize_Handler,
		},
		{
			MethodName: "Metadata",
			Handler:    _Datasource_Metadata_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "plugins.proto",
}

Datasource_ServiceDesc is the grpc.ServiceDesc for Datasource 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 ExecutionDatasource_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "plugins.ExecutionDatasource",
	HandlerType: (*ExecutionDatasourceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Run",
			Handler:       _ExecutionDatasource_Run_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "plugins.proto",
}

ExecutionDatasource_ServiceDesc is the grpc.ServiceDesc for ExecutionDatasource 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_plugins_proto protoreflect.FileDescriptor

Functions

func RegisterDatasourceServer 

func RegisterDatasourceServer(s grpc.ServiceRegistrar, srv DatasourceServer)

func RegisterExecutionDatasourceServer 

func RegisterExecutionDatasourceServer(s grpc.ServiceRegistrar, srv ExecutionDatasourceServer)

func RepopulatePhysicalExpressionFunctions added in v0.4.2 

func RepopulatePhysicalExpressionFunctions(expr physical.Expression) (physical.Expression, bool)

Types

type DatasourceClient 

type DatasourceClient interface {
	GetTable(ctx context.Context, in *GetTableRequest, opts ...grpc.CallOption) (*GetTableResponse, error)
	PushDownPredicates(ctx context.Context, in *PushDownPredicatesRequest, opts ...grpc.CallOption) (*PushDownPredicatesResponse, error)
	Materialize(ctx context.Context, in *MaterializeRequest, opts ...grpc.CallOption) (*MaterializeResponse, error)
	Metadata(ctx context.Context, in *MetadataRequest, opts ...grpc.CallOption) (*MetadataResponse, error)
}

DatasourceClient is the client API for Datasource 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 NewDatasourceClient 

func NewDatasourceClient(cc grpc.ClientConnInterface) DatasourceClient

type DatasourceServer 

type DatasourceServer interface {
	GetTable(context.Context, *GetTableRequest) (*GetTableResponse, error)
	PushDownPredicates(context.Context, *PushDownPredicatesRequest) (*PushDownPredicatesResponse, error)
	Materialize(context.Context, *MaterializeRequest) (*MaterializeResponse, error)
	Metadata(context.Context, *MetadataRequest) (*MetadataResponse, error)
	// contains filtered or unexported methods
}

DatasourceServer is the server API for Datasource service. All implementations must embed UnimplementedDatasourceServer for forward compatibility

type ExecutionDatasourceClient 

type ExecutionDatasourceClient interface {
	Run(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (ExecutionDatasource_RunClient, error)
}

ExecutionDatasourceClient is the client API for ExecutionDatasource 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 NewExecutionDatasourceClient 

func NewExecutionDatasourceClient(cc grpc.ClientConnInterface) ExecutionDatasourceClient

type ExecutionDatasourceServer 

type ExecutionDatasourceServer interface {
	Run(*RunRequest, ExecutionDatasource_RunServer) error
	// contains filtered or unexported methods
}

ExecutionDatasourceServer is the server API for ExecutionDatasource service. All implementations must embed UnimplementedExecutionDatasourceServer for forward compatibility

type ExecutionDatasource_RunClient 

type ExecutionDatasource_RunClient interface {
	Recv() (*RunResponseMessage, error)
	grpc.ClientStream
}

type ExecutionDatasource_RunServer 

type ExecutionDatasource_RunServer interface {
	Send(*RunResponseMessage) error
	grpc.ServerStream
}

type ExecutionVariableContext 

type ExecutionVariableContext struct {
	Frames []*ExecutionVariableContextFrame `protobuf:"bytes,1,rep,name=frames,proto3" json:"frames,omitempty"`
	// contains filtered or unexported fields
}

func NativeExecutionVariableContextToProto 

func NativeExecutionVariableContextToProto(c *execution.VariableContext) *ExecutionVariableContext

func (*ExecutionVariableContext) Descriptor deprecated 

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

Deprecated: Use ExecutionVariableContext.ProtoReflect.Descriptor instead.

func (*ExecutionVariableContext) GetFrames 

func (x *ExecutionVariableContext) GetFrames() []*ExecutionVariableContextFrame

func (*ExecutionVariableContext) ProtoMessage 

func (*ExecutionVariableContext) ProtoMessage()

func (*ExecutionVariableContext) ProtoReflect 

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

func (*ExecutionVariableContext) Reset 

func (x *ExecutionVariableContext) Reset()

func (*ExecutionVariableContext) String 

func (x *ExecutionVariableContext) String() string

func (*ExecutionVariableContext) ToNativeExecutionVariableContext 

func (x *ExecutionVariableContext) ToNativeExecutionVariableContext() *execution.VariableContext

type ExecutionVariableContextFrame 

type ExecutionVariableContextFrame struct {
	Values []*Value `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecutionVariableContextFrame) Descriptor deprecated 

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

Deprecated: Use ExecutionVariableContextFrame.ProtoReflect.Descriptor instead.

func (*ExecutionVariableContextFrame) GetValues 

func (x *ExecutionVariableContextFrame) GetValues() []*Value

func (*ExecutionVariableContextFrame) ProtoMessage 

func (*ExecutionVariableContextFrame) ProtoMessage()

func (*ExecutionVariableContextFrame) ProtoReflect 

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

func (*ExecutionVariableContextFrame) Reset 

func (x *ExecutionVariableContextFrame) Reset()

func (*ExecutionVariableContextFrame) String 

func (x *ExecutionVariableContextFrame) String() string

type GetTableRequest 

type GetTableRequest struct {
	TableContext *TableContext `protobuf:"bytes,1,opt,name=table_context,json=tableContext,proto3" json:"table_context,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTableRequest) Descriptor deprecated 

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

Deprecated: Use GetTableRequest.ProtoReflect.Descriptor instead.

func (*GetTableRequest) GetTableContext 

func (x *GetTableRequest) GetTableContext() *TableContext

func (*GetTableRequest) ProtoMessage 

func (*GetTableRequest) ProtoMessage()

func (*GetTableRequest) ProtoReflect 

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

func (*GetTableRequest) Reset 

func (x *GetTableRequest) Reset()

func (*GetTableRequest) String 

func (x *GetTableRequest) String() string

type GetTableResponse 

type GetTableResponse struct {
	Schema *Schema `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTableResponse) Descriptor deprecated 

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

Deprecated: Use GetTableResponse.ProtoReflect.Descriptor instead.

func (*GetTableResponse) GetSchema 

func (x *GetTableResponse) GetSchema() *Schema

func (*GetTableResponse) ProtoMessage 

func (*GetTableResponse) ProtoMessage()

func (*GetTableResponse) ProtoReflect 

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

func (*GetTableResponse) Reset 

func (x *GetTableResponse) Reset()

func (*GetTableResponse) String 

func (x *GetTableResponse) String() string

type MaterializeRequest 

type MaterializeRequest struct {
	TableContext         *TableContext            `protobuf:"bytes,1,opt,name=table_context,json=tableContext,proto3" json:"table_context,omitempty"`
	Schema               *Schema                  `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	PushedDownPredicates []byte                   `protobuf:"bytes,3,opt,name=pushed_down_predicates,json=pushedDownPredicates,proto3" json:"pushed_down_predicates,omitempty"`
	VariableContext      *PhysicalVariableContext `protobuf:"bytes,4,opt,name=variable_context,json=variableContext,proto3" json:"variable_context,omitempty"`
	// contains filtered or unexported fields
}

func (*MaterializeRequest) Descriptor deprecated 

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

Deprecated: Use MaterializeRequest.ProtoReflect.Descriptor instead.

func (*MaterializeRequest) GetPushedDownPredicates 

func (x *MaterializeRequest) GetPushedDownPredicates() []byte

func (*MaterializeRequest) GetSchema 

func (x *MaterializeRequest) GetSchema() *Schema

func (*MaterializeRequest) GetTableContext 

func (x *MaterializeRequest) GetTableContext() *TableContext

func (*MaterializeRequest) GetVariableContext 

func (x *MaterializeRequest) GetVariableContext() *PhysicalVariableContext

func (*MaterializeRequest) ProtoMessage 

func (*MaterializeRequest) ProtoMessage()

func (*MaterializeRequest) ProtoReflect 

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

func (*MaterializeRequest) Reset 

func (x *MaterializeRequest) Reset()

func (*MaterializeRequest) String 

func (x *MaterializeRequest) String() string

type MaterializeResponse 

type MaterializeResponse struct {
	SocketPath string `protobuf:"bytes,1,opt,name=socket_path,json=socketPath,proto3" json:"socket_path,omitempty"`
	// contains filtered or unexported fields
}

func (*MaterializeResponse) Descriptor deprecated 

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

Deprecated: Use MaterializeResponse.ProtoReflect.Descriptor instead.

func (*MaterializeResponse) GetSocketPath 

func (x *MaterializeResponse) GetSocketPath() string

func (*MaterializeResponse) ProtoMessage 

func (*MaterializeResponse) ProtoMessage()

func (*MaterializeResponse) ProtoReflect 

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

func (*MaterializeResponse) Reset 

func (x *MaterializeResponse) Reset()

func (*MaterializeResponse) String 

func (x *MaterializeResponse) String() string

type MetadataMessage 

type MetadataMessage struct {
	MessageType int32                  `protobuf:"varint,1,opt,name=message_type,json=messageType,proto3" json:"message_type,omitempty"`
	Watermark   *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=watermark,proto3" json:"watermark,omitempty"`
	// contains filtered or unexported fields
}

func NativeMetadataMessageToProto 

func NativeMetadataMessageToProto(msg execution.MetadataMessage) *MetadataMessage

func (*MetadataMessage) Descriptor deprecated 

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

Deprecated: Use MetadataMessage.ProtoReflect.Descriptor instead.

func (*MetadataMessage) GetMessageType 

func (x *MetadataMessage) GetMessageType() int32

func (*MetadataMessage) GetWatermark 

func (x *MetadataMessage) GetWatermark() *timestamppb.Timestamp

func (*MetadataMessage) ProtoMessage 

func (*MetadataMessage) ProtoMessage()

func (*MetadataMessage) ProtoReflect 

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

func (*MetadataMessage) Reset 

func (x *MetadataMessage) Reset()

func (*MetadataMessage) String 

func (x *MetadataMessage) String() string

func (*MetadataMessage) ToNativeMetadataMessage 

func (x *MetadataMessage) ToNativeMetadataMessage() execution.MetadataMessage

type MetadataRequest 

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

func (*MetadataRequest) Descriptor deprecated 

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

Deprecated: Use MetadataRequest.ProtoReflect.Descriptor instead.

func (*MetadataRequest) ProtoMessage 

func (*MetadataRequest) ProtoMessage()

func (*MetadataRequest) ProtoReflect 

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

func (*MetadataRequest) Reset 

func (x *MetadataRequest) Reset()

func (*MetadataRequest) String 

func (x *MetadataRequest) String() string

type MetadataResponse 

type MetadataResponse struct {
	ApiLevel int64 `protobuf:"varint,1,opt,name=api_level,json=apiLevel,proto3" json:"api_level,omitempty"`
	// contains filtered or unexported fields
}

func (*MetadataResponse) Descriptor deprecated 

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

Deprecated: Use MetadataResponse.ProtoReflect.Descriptor instead.

func (*MetadataResponse) GetApiLevel 

func (x *MetadataResponse) GetApiLevel() int64

func (*MetadataResponse) ProtoMessage 

func (*MetadataResponse) ProtoMessage()

func (*MetadataResponse) ProtoReflect 

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

func (*MetadataResponse) Reset 

func (x *MetadataResponse) Reset()

func (*MetadataResponse) String 

func (x *MetadataResponse) String() string

type PhysicalVariableContext 

type PhysicalVariableContext struct {
	Frames []*PhysicalVariableContextFrame `protobuf:"bytes,1,rep,name=frames,proto3" json:"frames,omitempty"`
	// contains filtered or unexported fields
}

func NativePhysicalVariableContextToProto 

func NativePhysicalVariableContextToProto(c *physical.VariableContext) *PhysicalVariableContext

func (*PhysicalVariableContext) Descriptor deprecated 

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

Deprecated: Use PhysicalVariableContext.ProtoReflect.Descriptor instead.

func (*PhysicalVariableContext) GetFrames 

func (x *PhysicalVariableContext) GetFrames() []*PhysicalVariableContextFrame

func (*PhysicalVariableContext) ProtoMessage 

func (*PhysicalVariableContext) ProtoMessage()

func (*PhysicalVariableContext) ProtoReflect 

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

func (*PhysicalVariableContext) Reset 

func (x *PhysicalVariableContext) Reset()

func (*PhysicalVariableContext) String 

func (x *PhysicalVariableContext) String() string

func (*PhysicalVariableContext) ToNativePhysicalVariableContext 

func (x *PhysicalVariableContext) ToNativePhysicalVariableContext() *physical.VariableContext

type PhysicalVariableContextFrame 

type PhysicalVariableContextFrame struct {
	Fields []*SchemaField `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
	// contains filtered or unexported fields
}

func (*PhysicalVariableContextFrame) Descriptor deprecated 

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

Deprecated: Use PhysicalVariableContextFrame.ProtoReflect.Descriptor instead.

func (*PhysicalVariableContextFrame) GetFields 

func (x *PhysicalVariableContextFrame) GetFields() []*SchemaField

func (*PhysicalVariableContextFrame) ProtoMessage 

func (*PhysicalVariableContextFrame) ProtoMessage()

func (*PhysicalVariableContextFrame) ProtoReflect 

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

func (*PhysicalVariableContextFrame) Reset 

func (x *PhysicalVariableContextFrame) Reset()

func (*PhysicalVariableContextFrame) String 

func (x *PhysicalVariableContextFrame) String() string

type PluginInput 

type PluginInput struct {
	Config yaml.Node
}

type PushDownPredicatesRequest 

type PushDownPredicatesRequest struct {
	TableContext *TableContext `protobuf:"bytes,1,opt,name=table_context,json=tableContext,proto3" json:"table_context,omitempty"`
	// []Expression JSONs, not performance sensitive.
	NewPredicates        []byte `protobuf:"bytes,2,opt,name=new_predicates,json=newPredicates,proto3" json:"new_predicates,omitempty"`
	PushedDownPredicates []byte `protobuf:"bytes,3,opt,name=pushed_down_predicates,json=pushedDownPredicates,proto3" json:"pushed_down_predicates,omitempty"`
	// contains filtered or unexported fields
}

func (*PushDownPredicatesRequest) Descriptor deprecated 

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

Deprecated: Use PushDownPredicatesRequest.ProtoReflect.Descriptor instead.

func (*PushDownPredicatesRequest) GetNewPredicates 

func (x *PushDownPredicatesRequest) GetNewPredicates() []byte

func (*PushDownPredicatesRequest) GetPushedDownPredicates 

func (x *PushDownPredicatesRequest) GetPushedDownPredicates() []byte

func (*PushDownPredicatesRequest) GetTableContext 

func (x *PushDownPredicatesRequest) GetTableContext() *TableContext

func (*PushDownPredicatesRequest) ProtoMessage 

func (*PushDownPredicatesRequest) ProtoMessage()

func (*PushDownPredicatesRequest) ProtoReflect 

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

func (*PushDownPredicatesRequest) Reset 

func (x *PushDownPredicatesRequest) Reset()

func (*PushDownPredicatesRequest) String 

func (x *PushDownPredicatesRequest) String() string

type PushDownPredicatesResponse 

type PushDownPredicatesResponse struct {

	// []Expression JSONs, not performance sensitive.
	Rejected   []byte `protobuf:"bytes,1,opt,name=rejected,proto3" json:"rejected,omitempty"`
	PushedDown []byte `protobuf:"bytes,2,opt,name=pushed_down,json=pushedDown,proto3" json:"pushed_down,omitempty"`
	Changed    bool   `protobuf:"varint,3,opt,name=changed,proto3" json:"changed,omitempty"`
	// contains filtered or unexported fields
}

func (*PushDownPredicatesResponse) Descriptor deprecated 

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

Deprecated: Use PushDownPredicatesResponse.ProtoReflect.Descriptor instead.

func (*PushDownPredicatesResponse) GetChanged 

func (x *PushDownPredicatesResponse) GetChanged() bool

func (*PushDownPredicatesResponse) GetPushedDown 

func (x *PushDownPredicatesResponse) GetPushedDown() []byte

func (*PushDownPredicatesResponse) GetRejected 

func (x *PushDownPredicatesResponse) GetRejected() []byte

func (*PushDownPredicatesResponse) ProtoMessage 

func (*PushDownPredicatesResponse) ProtoMessage()

func (*PushDownPredicatesResponse) ProtoReflect 

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

func (*PushDownPredicatesResponse) Reset 

func (x *PushDownPredicatesResponse) Reset()

func (*PushDownPredicatesResponse) String 

func (x *PushDownPredicatesResponse) String() string

type Record 

type Record struct {
	Values     []*Value               `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	Retraction bool                   `protobuf:"varint,2,opt,name=retraction,proto3" json:"retraction,omitempty"`
	EventTime  *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=event_time,json=eventTime,proto3" json:"event_time,omitempty"`
	// contains filtered or unexported fields
}

func NativeRecordToProto 

func NativeRecordToProto(record execution.Record) *Record

func (*Record) Descriptor deprecated 

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

Deprecated: Use Record.ProtoReflect.Descriptor instead.

func (*Record) GetEventTime 

func (x *Record) GetEventTime() *timestamppb.Timestamp

func (*Record) GetRetraction 

func (x *Record) GetRetraction() bool

func (*Record) GetValues 

func (x *Record) GetValues() []*Value

func (*Record) ProtoMessage 

func (*Record) ProtoMessage()

func (*Record) ProtoReflect 

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

func (*Record) Reset 

func (x *Record) Reset()

func (*Record) String 

func (x *Record) String() string

func (*Record) ToNativeRecord 

func (x *Record) ToNativeRecord() execution.Record

type RunRequest 

type RunRequest struct {
	VariableContext *ExecutionVariableContext `protobuf:"bytes,4,opt,name=variable_context,json=variableContext,proto3" json:"variable_context,omitempty"`
	// contains filtered or unexported fields
}

func (*RunRequest) Descriptor deprecated 

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

Deprecated: Use RunRequest.ProtoReflect.Descriptor instead.

func (*RunRequest) GetVariableContext 

func (x *RunRequest) GetVariableContext() *ExecutionVariableContext

func (*RunRequest) ProtoMessage 

func (*RunRequest) ProtoMessage()

func (*RunRequest) ProtoReflect 

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

func (*RunRequest) Reset 

func (x *RunRequest) Reset()

func (*RunRequest) String 

func (x *RunRequest) String() string

type RunResponseMessage 

type RunResponseMessage struct {
	Record   *Record          `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
	Metadata *MetadataMessage `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*RunResponseMessage) Descriptor deprecated 

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

Deprecated: Use RunResponseMessage.ProtoReflect.Descriptor instead.

func (*RunResponseMessage) GetMetadata 

func (x *RunResponseMessage) GetMetadata() *MetadataMessage

func (*RunResponseMessage) GetRecord 

func (x *RunResponseMessage) GetRecord() *Record

func (*RunResponseMessage) ProtoMessage 

func (*RunResponseMessage) ProtoMessage()

func (*RunResponseMessage) ProtoReflect 

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

func (*RunResponseMessage) Reset 

func (x *RunResponseMessage) Reset()

func (*RunResponseMessage) String 

func (x *RunResponseMessage) String() string

type Schema 

type Schema struct {
	Fields        []*SchemaField `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields,omitempty"`
	TimeField     int32          `protobuf:"varint,2,opt,name=time_field,json=timeField,proto3" json:"time_field,omitempty"`
	NoRetractions bool           `protobuf:"varint,3,opt,name=no_retractions,json=noRetractions,proto3" json:"no_retractions,omitempty"`
	// contains filtered or unexported fields
}

func NativeSchemaToProto 

func NativeSchemaToProto(schema physical.Schema) *Schema

func (*Schema) Descriptor deprecated 

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

Deprecated: Use Schema.ProtoReflect.Descriptor instead.

func (*Schema) GetFields 

func (x *Schema) GetFields() []*SchemaField

func (*Schema) GetNoRetractions added in v0.6.0 

func (x *Schema) GetNoRetractions() bool

func (*Schema) GetTimeField 

func (x *Schema) GetTimeField() int32

func (*Schema) ProtoMessage 

func (*Schema) ProtoMessage()

func (*Schema) ProtoReflect 

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

func (*Schema) Reset 

func (x *Schema) Reset()

func (*Schema) String 

func (x *Schema) String() string

func (*Schema) ToNativeSchema 

func (x *Schema) ToNativeSchema() physical.Schema

type SchemaField 

type SchemaField struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type *Type  `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*SchemaField) Descriptor deprecated 

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

Deprecated: Use SchemaField.ProtoReflect.Descriptor instead.

func (*SchemaField) GetName 

func (x *SchemaField) GetName() string

func (*SchemaField) GetType 

func (x *SchemaField) GetType() *Type

func (*SchemaField) ProtoMessage 

func (*SchemaField) ProtoMessage()

func (*SchemaField) ProtoReflect 

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

func (*SchemaField) Reset 

func (x *SchemaField) Reset()

func (*SchemaField) String 

func (x *SchemaField) String() string

type StructField 

type StructField struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type *Type  `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*StructField) Descriptor deprecated 

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

Deprecated: Use StructField.ProtoReflect.Descriptor instead.

func (*StructField) GetName 

func (x *StructField) GetName() string

func (*StructField) GetType 

func (x *StructField) GetType() *Type

func (*StructField) ProtoMessage 

func (*StructField) ProtoMessage()

func (*StructField) ProtoReflect 

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

func (*StructField) Reset 

func (x *StructField) Reset()

func (*StructField) String 

func (x *StructField) String() string

type TableContext 

type TableContext struct {
	TableName string            `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	Options   map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*TableContext) Descriptor deprecated 

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

Deprecated: Use TableContext.ProtoReflect.Descriptor instead.

func (*TableContext) GetOptions added in v0.6.0 

func (x *TableContext) GetOptions() map[string]string

func (*TableContext) GetTableName 

func (x *TableContext) GetTableName() string

func (*TableContext) ProtoMessage 

func (*TableContext) ProtoMessage()

func (*TableContext) ProtoReflect 

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

func (*TableContext) Reset 

func (x *TableContext) Reset()

func (*TableContext) String 

func (x *TableContext) String() string

type Type 

type Type struct {
	TypeId int32          `protobuf:"varint,1,opt,name=type_id,json=typeId,proto3" json:"type_id,omitempty"`
	List   *Type          `protobuf:"bytes,2,opt,name=list,proto3" json:"list,omitempty"`
	Struct []*StructField `protobuf:"bytes,3,rep,name=struct,proto3" json:"struct,omitempty"`
	Tuple  []*Type        `protobuf:"bytes,4,rep,name=tuple,proto3" json:"tuple,omitempty"`
	Union  []*Type        `protobuf:"bytes,5,rep,name=union,proto3" json:"union,omitempty"`
	// contains filtered or unexported fields
}

func NativeTypeToProto 

func NativeTypeToProto(t octosql.Type) *Type

func (*Type) Descriptor deprecated 

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

Deprecated: Use Type.ProtoReflect.Descriptor instead.

func (*Type) GetList 

func (x *Type) GetList() *Type

func (*Type) GetStruct 

func (x *Type) GetStruct() []*StructField

func (*Type) GetTuple 

func (x *Type) GetTuple() []*Type

func (*Type) GetTypeId 

func (x *Type) GetTypeId() int32

func (*Type) GetUnion 

func (x *Type) GetUnion() []*Type

func (*Type) ProtoMessage 

func (*Type) ProtoMessage()

func (*Type) ProtoReflect 

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

func (*Type) Reset 

func (x *Type) Reset()

func (*Type) String 

func (x *Type) String() string

func (*Type) ToNativeType 

func (x *Type) ToNativeType() octosql.Type

type UnimplementedDatasourceServer 

type UnimplementedDatasourceServer struct {
}

UnimplementedDatasourceServer must be embedded to have forward compatible implementations.

func (UnimplementedDatasourceServer) GetTable 

func (UnimplementedDatasourceServer) GetTable(context.Context, *GetTableRequest) (*GetTableResponse, error)

func (UnimplementedDatasourceServer) Materialize 

func (UnimplementedDatasourceServer) Materialize(context.Context, *MaterializeRequest) (*MaterializeResponse, error)

func (UnimplementedDatasourceServer) Metadata 

func (UnimplementedDatasourceServer) Metadata(context.Context, *MetadataRequest) (*MetadataResponse, error)

func (UnimplementedDatasourceServer) PushDownPredicates 

func (UnimplementedDatasourceServer) PushDownPredicates(context.Context, *PushDownPredicatesRequest) (*PushDownPredicatesResponse, error)

type UnimplementedExecutionDatasourceServer 

type UnimplementedExecutionDatasourceServer struct {
}

UnimplementedExecutionDatasourceServer must be embedded to have forward compatible implementations.

func (UnimplementedExecutionDatasourceServer) Run 

func (UnimplementedExecutionDatasourceServer) Run(*RunRequest, ExecutionDatasource_RunServer) error

type UnsafeDatasourceServer 

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

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

type UnsafeExecutionDatasourceServer 

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

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

type Value 

type Value struct {
	TypeId   int32                  `protobuf:"varint,1,opt,name=type_id,json=typeId,proto3" json:"type_id,omitempty"`
	Int      int64                  `protobuf:"varint,2,opt,name=int,proto3" json:"int,omitempty"`
	Float    float64                `protobuf:"fixed64,3,opt,name=float,proto3" json:"float,omitempty"`
	Boolean  bool                   `protobuf:"varint,4,opt,name=boolean,proto3" json:"boolean,omitempty"`
	Str      string                 `protobuf:"bytes,5,opt,name=str,proto3" json:"str,omitempty"`
	Time     *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=time,proto3" json:"time,omitempty"`
	Duration *durationpb.Duration   `protobuf:"bytes,7,opt,name=duration,proto3" json:"duration,omitempty"`
	List     []*Value               `protobuf:"bytes,8,rep,name=list,proto3" json:"list,omitempty"` // TODO: These should have their own messages.
	Struct   []*Value               `protobuf:"bytes,9,rep,name=struct,proto3" json:"struct,omitempty"`
	Tuple    []*Value               `protobuf:"bytes,10,rep,name=tuple,proto3" json:"tuple,omitempty"`
	// contains filtered or unexported fields
}

func NativeValueToProto 

func NativeValueToProto(value octosql.Value) *Value

func (*Value) Descriptor deprecated 

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

Deprecated: Use Value.ProtoReflect.Descriptor instead.

func (*Value) GetBoolean 

func (x *Value) GetBoolean() bool

func (*Value) GetDuration 

func (x *Value) GetDuration() *durationpb.Duration

func (*Value) GetFloat 

func (x *Value) GetFloat() float64

func (*Value) GetInt 

func (x *Value) GetInt() int64

func (*Value) GetList 

func (x *Value) GetList() []*Value

func (*Value) GetStr 

func (x *Value) GetStr() string

func (*Value) GetStruct 

func (x *Value) GetStruct() []*Value

func (*Value) GetTime 

func (x *Value) GetTime() *timestamppb.Timestamp

func (*Value) GetTuple 

func (x *Value) GetTuple() []*Value

func (*Value) GetTypeId 

func (x *Value) GetTypeId() int32

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) ProtoReflect 

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

func (*Value) Reset 

func (x *Value) Reset()

func (*Value) String 

func (x *Value) String() string

func (*Value) ToNativeValue 

func (x *Value) ToNativeValue() octosql.Value

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.