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.

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

func (x *ExecutionVariableContextFrame) Reset()

func (*ExecutionVariableContextFrame) 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 (*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 (*PhysicalVariableContextFrame) Reset

func (x *PhysicalVariableContextFrame) Reset()

func (*PhysicalVariableContextFrame) 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 (*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 (*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) Materialize

func (UnimplementedDatasourceServer) Metadata

type UnimplementedExecutionDatasourceServer

type UnimplementedExecutionDatasourceServer struct {
}

UnimplementedExecutionDatasourceServer must be embedded to have forward compatible implementations.

func (UnimplementedExecutionDatasourceServer) Run

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

Jump to

Keyboard shortcuts

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