plugins

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)
}

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
}

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

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

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

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

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

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

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

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

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
}

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

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
}

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

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

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

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

type PluginInput struct {
	Config yaml.Node
}

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
}

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
}

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
}

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

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
}

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
}

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
}

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
}

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
}

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
}

type UnimplementedDatasourceServer struct {
}

type UnimplementedExecutionDatasourceServer struct {
}

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

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

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
}