proto

package
v4.1.23 Latest Latest
Warning

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

 Go to latest Published: Nov 7, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	DataType_name = map[int32]string{
		0:  "UNKNOWN",
		1:  "FLOAT32",
		2:  "INT32",
		3:  "FLOAT64",
		4:  "INT64",
		5:  "EPOCH",
		6:  "BYTE",
		7:  "BOOL",
		8:  "NONE",
		9:  "STRING",
		10: "INT16",
		11: "UINT8",
		12: "UINT16",
		13: "UINT32",
		14: "UINT64",
		15: "STRING16",
	}
	DataType_value = map[string]int32{
		"UNKNOWN":  0,
		"FLOAT32":  1,
		"INT32":    2,
		"FLOAT64":  3,
		"INT64":    4,
		"EPOCH":    5,
		"BYTE":     6,
		"BOOL":     7,
		"NONE":     8,
		"STRING":   9,
		"INT16":    10,
		"UINT8":    11,
		"UINT16":   12,
		"UINT32":   13,
		"UINT64":   14,
		"STRING16": 15,
	}
)

Enum value maps for DataType.

View Source 
var (
	ListSymbolsRequest_Format_name = map[int32]string{
		0: "SYMBOL",
		1: "TIME_BUCKET_KEY",
	}
	ListSymbolsRequest_Format_value = map[string]int32{
		"SYMBOL":          0,
		"TIME_BUCKET_KEY": 1,
	}
)

Enum value maps for ListSymbolsRequest_Format.

View Source 
var File_marketstore_proto protoreflect.FileDescriptor
View Source 
var File_replication_proto protoreflect.FileDescriptor
View Source 
var Marketstore_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.Marketstore",
	HandlerType: (*MarketstoreServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Query",
			Handler:    _Marketstore_Query_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _Marketstore_Create_Handler,
		},
		{
			MethodName: "Write",
			Handler:    _Marketstore_Write_Handler,
		},
		{
			MethodName: "Destroy",
			Handler:    _Marketstore_Destroy_Handler,
		},
		{
			MethodName: "ListSymbols",
			Handler:    _Marketstore_ListSymbols_Handler,
		},
		{
			MethodName: "ServerVersion",
			Handler:    _Marketstore_ServerVersion_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "marketstore.proto",
}

Marketstore_ServiceDesc is the grpc.ServiceDesc for Marketstore 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 Replication_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.Replication",
	HandlerType: (*ReplicationServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetWALStream",
			Handler:       _Replication_GetWALStream_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "replication.proto",
}

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

Functions

func RegisterMarketstoreServer 

func RegisterMarketstoreServer(s grpc.ServiceRegistrar, srv MarketstoreServer)

func RegisterReplicationServer added in v4.1.0 

func RegisterReplicationServer(s grpc.ServiceRegistrar, srv ReplicationServer)

Types

type CreateRequest added in v4.1.1 

type CreateRequest struct {
	Key        string       `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // a time bucket key
	DataShapes []*DataShape `protobuf:"bytes,2,rep,name=data_shapes,json=dataShapes,proto3" json:"data_shapes,omitempty"`
	RowType    string       `protobuf:"bytes,3,opt,name=row_type,json=rowType,proto3" json:"row_type,omitempty"` // fixed or variable
	// contains filtered or unexported fields
}

func (*CreateRequest) Descriptor deprecated added in v4.1.1 

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

Deprecated: Use CreateRequest.ProtoReflect.Descriptor instead.

func (*CreateRequest) GetDataShapes added in v4.1.1 

func (x *CreateRequest) GetDataShapes() []*DataShape

func (*CreateRequest) GetKey added in v4.1.1 

func (x *CreateRequest) GetKey() string

func (*CreateRequest) GetRowType added in v4.1.1 

func (x *CreateRequest) GetRowType() string

func (*CreateRequest) ProtoMessage added in v4.1.1 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) ProtoReflect added in v4.1.18 

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

func (*CreateRequest) Reset added in v4.1.1 

func (x *CreateRequest) Reset()

func (*CreateRequest) String added in v4.1.1 

func (x *CreateRequest) String() string

type DataShape 

type DataShape struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// DataType type = 2;
	// type string such as i4 and f8
	// use string instead of DataType enum in order to align with column_types in NumpyDataset.
	// TODO: use DataType enum at DataShape and NumpyDataset
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*DataShape) Descriptor deprecated 

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

Deprecated: Use DataShape.ProtoReflect.Descriptor instead.

func (*DataShape) GetName 

func (x *DataShape) GetName() string

func (*DataShape) GetType 

func (x *DataShape) GetType() string

func (*DataShape) ProtoMessage 

func (*DataShape) ProtoMessage()

func (*DataShape) ProtoReflect added in v4.1.18 

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

func (*DataShape) Reset 

func (x *DataShape) Reset()

func (*DataShape) String 

func (x *DataShape) String() string

type DataType 

type DataType int32
const (
	//
	//NOTE: The ordering of this enum must match the File Format order
	//
	//We define our own types here instead of using the (excellent!) built-in Go type system for the primary reason
	//that we are serializing data to files and so need to have a (very!) stable on-disk representation that matches
	//the processing we do internally.
	DataType_UNKNOWN  DataType = 0
	DataType_FLOAT32  DataType = 1
	DataType_INT32    DataType = 2
	DataType_FLOAT64  DataType = 3
	DataType_INT64    DataType = 4
	DataType_EPOCH    DataType = 5
	DataType_BYTE     DataType = 6
	DataType_BOOL     DataType = 7
	DataType_NONE     DataType = 8
	DataType_STRING   DataType = 9
	DataType_INT16    DataType = 10
	DataType_UINT8    DataType = 11
	DataType_UINT16   DataType = 12
	DataType_UINT32   DataType = 13
	DataType_UINT64   DataType = 14
	DataType_STRING16 DataType = 15
)

func (DataType) Descriptor added in v4.1.18 

func (DataType) Descriptor() protoreflect.EnumDescriptor

func (DataType) Enum added in v4.1.18 

func (x DataType) Enum() *DataType

func (DataType) EnumDescriptor deprecated 

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

Deprecated: Use DataType.Descriptor instead.

func (DataType) Number added in v4.1.18 

func (x DataType) Number() protoreflect.EnumNumber

func (DataType) String 

func (x DataType) String() string

func (DataType) Type added in v4.1.18 

func (DataType) Type() protoreflect.EnumType

type GetWALStreamRequest added in v4.1.0 

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

func (*GetWALStreamRequest) Descriptor deprecated added in v4.1.0 

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

Deprecated: Use GetWALStreamRequest.ProtoReflect.Descriptor instead.

func (*GetWALStreamRequest) ProtoMessage added in v4.1.0 

func (*GetWALStreamRequest) ProtoMessage()

func (*GetWALStreamRequest) ProtoReflect added in v4.1.18 

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

func (*GetWALStreamRequest) Reset added in v4.1.0 

func (x *GetWALStreamRequest) Reset()

func (*GetWALStreamRequest) String added in v4.1.0 

func (x *GetWALStreamRequest) String() string

type GetWALStreamResponse added in v4.1.0 

type GetWALStreamResponse struct {
	TransactionGroup []byte `protobuf:"bytes,1,opt,name=transaction_group,json=transactionGroup,proto3" json:"transaction_group,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWALStreamResponse) Descriptor deprecated added in v4.1.0 

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

Deprecated: Use GetWALStreamResponse.ProtoReflect.Descriptor instead.

func (*GetWALStreamResponse) GetTransactionGroup added in v4.1.0 

func (x *GetWALStreamResponse) GetTransactionGroup() []byte

func (*GetWALStreamResponse) ProtoMessage added in v4.1.0 

func (*GetWALStreamResponse) ProtoMessage()

func (*GetWALStreamResponse) ProtoReflect added in v4.1.18 

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

func (*GetWALStreamResponse) Reset added in v4.1.0 

func (x *GetWALStreamResponse) Reset()

func (*GetWALStreamResponse) String added in v4.1.0 

func (x *GetWALStreamResponse) String() string

type KeyRequest 

type KeyRequest struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyRequest) Descriptor deprecated 

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

Deprecated: Use KeyRequest.ProtoReflect.Descriptor instead.

func (*KeyRequest) GetKey 

func (x *KeyRequest) GetKey() string

func (*KeyRequest) ProtoMessage 

func (*KeyRequest) ProtoMessage()

func (*KeyRequest) ProtoReflect added in v4.1.18 

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

func (*KeyRequest) Reset 

func (x *KeyRequest) Reset()

func (*KeyRequest) String 

func (x *KeyRequest) String() string

type ListSymbolsRequest 

type ListSymbolsRequest struct {
	Format ListSymbolsRequest_Format `protobuf:"varint,1,opt,name=format,proto3,enum=proto.ListSymbolsRequest_Format" json:"format,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSymbolsRequest) Descriptor deprecated 

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

Deprecated: Use ListSymbolsRequest.ProtoReflect.Descriptor instead.

func (*ListSymbolsRequest) GetFormat added in v4.0.1 

func (x *ListSymbolsRequest) GetFormat() ListSymbolsRequest_Format

func (*ListSymbolsRequest) ProtoMessage 

func (*ListSymbolsRequest) ProtoMessage()

func (*ListSymbolsRequest) ProtoReflect added in v4.1.18 

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

func (*ListSymbolsRequest) Reset 

func (x *ListSymbolsRequest) Reset()

func (*ListSymbolsRequest) String 

func (x *ListSymbolsRequest) String() string

type ListSymbolsRequest_Format added in v4.0.1 

type ListSymbolsRequest_Format int32
const (
	// symbol names (e.g. ["AAPL", "AMZN", ....])
	ListSymbolsRequest_SYMBOL ListSymbolsRequest_Format = 0
	// {symbol/timeframe/attributeGroup} names (e.g. ["AAPL/1Min/TICK", "AAPL/1Sec/OHLCV", "Amazon/1D/Tick",...])
	ListSymbolsRequest_TIME_BUCKET_KEY ListSymbolsRequest_Format = 1
)

func (ListSymbolsRequest_Format) Descriptor added in v4.1.18 

func (ListSymbolsRequest_Format) Descriptor() protoreflect.EnumDescriptor

func (ListSymbolsRequest_Format) Enum added in v4.1.18 

func (x ListSymbolsRequest_Format) Enum() *ListSymbolsRequest_Format

func (ListSymbolsRequest_Format) EnumDescriptor deprecated added in v4.0.1 

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

Deprecated: Use ListSymbolsRequest_Format.Descriptor instead.

func (ListSymbolsRequest_Format) Number added in v4.1.18 

func (x ListSymbolsRequest_Format) Number() protoreflect.EnumNumber

func (ListSymbolsRequest_Format) String added in v4.0.1 

func (x ListSymbolsRequest_Format) String() string

func (ListSymbolsRequest_Format) Type added in v4.1.18 

func (ListSymbolsRequest_Format) Type() protoreflect.EnumType

type ListSymbolsResponse 

type ListSymbolsResponse struct {
	Results []string `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSymbolsResponse) Descriptor deprecated 

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

Deprecated: Use ListSymbolsResponse.ProtoReflect.Descriptor instead.

func (*ListSymbolsResponse) GetResults 

func (x *ListSymbolsResponse) GetResults() []string

func (*ListSymbolsResponse) ProtoMessage 

func (*ListSymbolsResponse) ProtoMessage()

func (*ListSymbolsResponse) ProtoReflect added in v4.1.18 

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

func (*ListSymbolsResponse) Reset 

func (x *ListSymbolsResponse) Reset()

func (*ListSymbolsResponse) String 

func (x *ListSymbolsResponse) String() string

type MarketstoreClient 

type MarketstoreClient interface {
	Query(ctx context.Context, in *MultiQueryRequest, opts ...grpc.CallOption) (*MultiQueryResponse, error)
	Create(ctx context.Context, in *MultiCreateRequest, opts ...grpc.CallOption) (*MultiServerResponse, error)
	Write(ctx context.Context, in *MultiWriteRequest, opts ...grpc.CallOption) (*MultiServerResponse, error)
	Destroy(ctx context.Context, in *MultiKeyRequest, opts ...grpc.CallOption) (*MultiServerResponse, error)
	ListSymbols(ctx context.Context, in *ListSymbolsRequest, opts ...grpc.CallOption) (*ListSymbolsResponse, error)
	ServerVersion(ctx context.Context, in *ServerVersionRequest, opts ...grpc.CallOption) (*ServerVersionResponse, error)
}

MarketstoreClient is the client API for Marketstore 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 NewMarketstoreClient 

func NewMarketstoreClient(cc grpc.ClientConnInterface) MarketstoreClient

type MarketstoreServer 

type MarketstoreServer interface {
	Query(context.Context, *MultiQueryRequest) (*MultiQueryResponse, error)
	Create(context.Context, *MultiCreateRequest) (*MultiServerResponse, error)
	Write(context.Context, *MultiWriteRequest) (*MultiServerResponse, error)
	Destroy(context.Context, *MultiKeyRequest) (*MultiServerResponse, error)
	ListSymbols(context.Context, *ListSymbolsRequest) (*ListSymbolsResponse, error)
	ServerVersion(context.Context, *ServerVersionRequest) (*ServerVersionResponse, error)
	// contains filtered or unexported methods
}

MarketstoreServer is the server API for Marketstore service. All implementations must embed UnimplementedMarketstoreServer for forward compatibility

type MultiCreateRequest added in v4.1.1 

type MultiCreateRequest struct {
	Requests []*CreateRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

func (*MultiCreateRequest) Descriptor deprecated added in v4.1.1 

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

Deprecated: Use MultiCreateRequest.ProtoReflect.Descriptor instead.

func (*MultiCreateRequest) GetRequests added in v4.1.1 

func (x *MultiCreateRequest) GetRequests() []*CreateRequest

func (*MultiCreateRequest) ProtoMessage added in v4.1.1 

func (*MultiCreateRequest) ProtoMessage()

func (*MultiCreateRequest) ProtoReflect added in v4.1.18 

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

func (*MultiCreateRequest) Reset added in v4.1.1 

func (x *MultiCreateRequest) Reset()

func (*MultiCreateRequest) String added in v4.1.1 

func (x *MultiCreateRequest) String() string

type MultiKeyRequest 

type MultiKeyRequest struct {
	Requests []*KeyRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

func (*MultiKeyRequest) Descriptor deprecated 

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

Deprecated: Use MultiKeyRequest.ProtoReflect.Descriptor instead.

func (*MultiKeyRequest) GetRequests 

func (x *MultiKeyRequest) GetRequests() []*KeyRequest

func (*MultiKeyRequest) ProtoMessage 

func (*MultiKeyRequest) ProtoMessage()

func (*MultiKeyRequest) ProtoReflect added in v4.1.18 

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

func (*MultiKeyRequest) Reset 

func (x *MultiKeyRequest) Reset()

func (*MultiKeyRequest) String 

func (x *MultiKeyRequest) String() string

type MultiQueryRequest 

type MultiQueryRequest struct {

	//
	//A multi-request allows for different Timeframes and record formats for each request
	Requests []*QueryRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

func (*MultiQueryRequest) Descriptor deprecated 

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

Deprecated: Use MultiQueryRequest.ProtoReflect.Descriptor instead.

func (*MultiQueryRequest) GetRequests 

func (x *MultiQueryRequest) GetRequests() []*QueryRequest

func (*MultiQueryRequest) ProtoMessage 

func (*MultiQueryRequest) ProtoMessage()

func (*MultiQueryRequest) ProtoReflect added in v4.1.18 

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

func (*MultiQueryRequest) Reset 

func (x *MultiQueryRequest) Reset()

func (*MultiQueryRequest) String 

func (x *MultiQueryRequest) String() string

type MultiQueryResponse 

type MultiQueryResponse struct {
	Responses []*QueryResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	Version   string           `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` // Server Version
	Timezone  string           `protobuf:"bytes,3,opt,name=timezone,proto3" json:"timezone,omitempty"`
	// contains filtered or unexported fields
}

func (*MultiQueryResponse) Descriptor deprecated 

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

Deprecated: Use MultiQueryResponse.ProtoReflect.Descriptor instead.

func (*MultiQueryResponse) GetResponses 

func (x *MultiQueryResponse) GetResponses() []*QueryResponse

func (*MultiQueryResponse) GetTimezone 

func (x *MultiQueryResponse) GetTimezone() string

func (*MultiQueryResponse) GetVersion 

func (x *MultiQueryResponse) GetVersion() string

func (*MultiQueryResponse) ProtoMessage 

func (*MultiQueryResponse) ProtoMessage()

func (*MultiQueryResponse) ProtoReflect added in v4.1.18 

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

func (*MultiQueryResponse) Reset 

func (x *MultiQueryResponse) Reset()

func (*MultiQueryResponse) String 

func (x *MultiQueryResponse) String() string

type MultiServerResponse 

type MultiServerResponse struct {
	Responses []*ServerResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

func (*MultiServerResponse) Descriptor deprecated 

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

Deprecated: Use MultiServerResponse.ProtoReflect.Descriptor instead.

func (*MultiServerResponse) GetResponses 

func (x *MultiServerResponse) GetResponses() []*ServerResponse

func (*MultiServerResponse) ProtoMessage 

func (*MultiServerResponse) ProtoMessage()

func (*MultiServerResponse) ProtoReflect added in v4.1.18 

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

func (*MultiServerResponse) Reset 

func (x *MultiServerResponse) Reset()

func (*MultiServerResponse) String 

func (x *MultiServerResponse) String() string

type MultiWriteRequest 

type MultiWriteRequest struct {

	//
	//A multi-request allows for different Timeframes and record formats for each request
	Requests []*WriteRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

func (*MultiWriteRequest) Descriptor deprecated 

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

Deprecated: Use MultiWriteRequest.ProtoReflect.Descriptor instead.

func (*MultiWriteRequest) GetRequests 

func (x *MultiWriteRequest) GetRequests() []*WriteRequest

func (*MultiWriteRequest) ProtoMessage 

func (*MultiWriteRequest) ProtoMessage()

func (*MultiWriteRequest) ProtoReflect added in v4.1.18 

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

func (*MultiWriteRequest) Reset 

func (x *MultiWriteRequest) Reset()

func (*MultiWriteRequest) String 

func (x *MultiWriteRequest) String() string

type NumpyDataset 

type NumpyDataset struct {

	// a list of type strings such as i4 and f8
	ColumnTypes []string `protobuf:"bytes,1,rep,name=column_types,json=columnTypes,proto3" json:"column_types,omitempty"`
	// a list of column names
	ColumnNames []string `protobuf:"bytes,2,rep,name=column_names,json=columnNames,proto3" json:"column_names,omitempty"`
	// two dimentional byte arrays holding the column data
	ColumnData [][]byte `protobuf:"bytes,3,rep,name=column_data,json=columnData,proto3" json:"column_data,omitempty"`
	Length     int32    `protobuf:"varint,4,opt,name=length,proto3" json:"length,omitempty"`
	// hidden
	DataShapes []*DataShape `protobuf:"bytes,5,rep,name=data_shapes,json=dataShapes,proto3" json:"data_shapes,omitempty"`
	// contains filtered or unexported fields
}

func (*NumpyDataset) Descriptor deprecated 

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

Deprecated: Use NumpyDataset.ProtoReflect.Descriptor instead.

func (*NumpyDataset) GetColumnData 

func (x *NumpyDataset) GetColumnData() [][]byte

func (*NumpyDataset) GetColumnNames 

func (x *NumpyDataset) GetColumnNames() []string

func (*NumpyDataset) GetColumnTypes 

func (x *NumpyDataset) GetColumnTypes() []string

func (*NumpyDataset) GetDataShapes 

func (x *NumpyDataset) GetDataShapes() []*DataShape

func (*NumpyDataset) GetLength 

func (x *NumpyDataset) GetLength() int32

func (*NumpyDataset) ProtoMessage 

func (*NumpyDataset) ProtoMessage()

func (*NumpyDataset) ProtoReflect added in v4.1.18 

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

func (*NumpyDataset) Reset 

func (x *NumpyDataset) Reset()

func (*NumpyDataset) String 

func (x *NumpyDataset) String() string

type NumpyMultiDataset 

type NumpyMultiDataset struct {
	Data       *NumpyDataset    `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	StartIndex map[string]int32 `` /* 180-byte string literal not displayed */
	Lengths    map[string]int32 `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*NumpyMultiDataset) Descriptor deprecated 

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

Deprecated: Use NumpyMultiDataset.ProtoReflect.Descriptor instead.

func (*NumpyMultiDataset) GetData 

func (x *NumpyMultiDataset) GetData() *NumpyDataset

func (*NumpyMultiDataset) GetLengths 

func (x *NumpyMultiDataset) GetLengths() map[string]int32

func (*NumpyMultiDataset) GetStartIndex 

func (x *NumpyMultiDataset) GetStartIndex() map[string]int32

func (*NumpyMultiDataset) ProtoMessage 

func (*NumpyMultiDataset) ProtoMessage()

func (*NumpyMultiDataset) ProtoReflect added in v4.1.18 

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

func (*NumpyMultiDataset) Reset 

func (x *NumpyMultiDataset) Reset()

func (*NumpyMultiDataset) String 

func (x *NumpyMultiDataset) String() string

type QueryRequest 

type QueryRequest struct {

	// Note: SQL is not fully supported
	IsSqlStatement bool   `protobuf:"varint,1,opt,name=is_sql_statement,json=isSqlStatement,proto3" json:"is_sql_statement,omitempty"` // If this is a SQL request, Only SQLStatement is relevant
	SqlStatement   string `protobuf:"bytes,2,opt,name=sql_statement,json=sqlStatement,proto3" json:"sql_statement,omitempty"`
	// Destination is <symbol>/<timeframe>/<attributegroup>
	Destination string `protobuf:"bytes,3,opt,name=destination,proto3" json:"destination,omitempty"`
	// This is not usually set, defaults to Symbol/Timeframe/AttributeGroup
	KeyCategory string `protobuf:"bytes,4,opt,name=key_category,json=keyCategory,proto3" json:"key_category,omitempty"`
	// Lower time predicate (i.e. index >= start) in unix epoch second
	EpochStart int64 `protobuf:"varint,5,opt,name=epoch_start,json=epochStart,proto3" json:"epoch_start,omitempty"`
	// fractional part (nano second) of epoch_start
	EpochStartNanos int64 `protobuf:"varint,6,opt,name=epoch_start_nanos,json=epochStartNanos,proto3" json:"epoch_start_nanos,omitempty"`
	// Upper time predicate (i.e. index <= end) in unix epoch second
	EpochEnd int64 `protobuf:"varint,7,opt,name=epoch_end,json=epochEnd,proto3" json:"epoch_end,omitempty"`
	// fractional part (nano second) of epoch_end
	EpochEndNanos int64 `protobuf:"varint,8,opt,name=epoch_end_nanos,json=epochEndNanos,proto3" json:"epoch_end_nanos,omitempty"`
	// Number of max returned rows from lower/upper bound
	LimitRecordCount int32 `protobuf:"varint,9,opt,name=limit_record_count,json=limitRecordCount,proto3" json:"limit_record_count,omitempty"`
	// Set to true if LimitRecordCount should be from the lower
	LimitFromStart bool `protobuf:"varint,10,opt,name=limit_from_start,json=limitFromStart,proto3" json:"limit_from_start,omitempty"`
	// Array of column names to be returned
	Columns []string `protobuf:"bytes,11,rep,name=columns,proto3" json:"columns,omitempty"`
	// Support for functions is experimental and subject to change
	Functions []string `protobuf:"bytes,12,rep,name=functions,proto3" json:"functions,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryRequest) Descriptor deprecated 

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

Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.

func (*QueryRequest) GetColumns 

func (x *QueryRequest) GetColumns() []string

func (*QueryRequest) GetDestination 

func (x *QueryRequest) GetDestination() string

func (*QueryRequest) GetEpochEnd 

func (x *QueryRequest) GetEpochEnd() int64

func (*QueryRequest) GetEpochEndNanos 

func (x *QueryRequest) GetEpochEndNanos() int64

func (*QueryRequest) GetEpochStart 

func (x *QueryRequest) GetEpochStart() int64

func (*QueryRequest) GetEpochStartNanos 

func (x *QueryRequest) GetEpochStartNanos() int64

func (*QueryRequest) GetFunctions 

func (x *QueryRequest) GetFunctions() []string

func (*QueryRequest) GetIsSqlStatement 

func (x *QueryRequest) GetIsSqlStatement() bool

func (*QueryRequest) GetKeyCategory 

func (x *QueryRequest) GetKeyCategory() string

func (*QueryRequest) GetLimitFromStart 

func (x *QueryRequest) GetLimitFromStart() bool

func (*QueryRequest) GetLimitRecordCount 

func (x *QueryRequest) GetLimitRecordCount() int32

func (*QueryRequest) GetSqlStatement 

func (x *QueryRequest) GetSqlStatement() string

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) ProtoReflect added in v4.1.18 

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

func (*QueryRequest) Reset 

func (x *QueryRequest) Reset()

func (*QueryRequest) String 

func (x *QueryRequest) String() string

type QueryResponse 

type QueryResponse struct {
	Result *NumpyMultiDataset `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryResponse) Descriptor deprecated 

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

Deprecated: Use QueryResponse.ProtoReflect.Descriptor instead.

func (*QueryResponse) GetResult 

func (x *QueryResponse) GetResult() *NumpyMultiDataset

func (*QueryResponse) ProtoMessage 

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) ProtoReflect added in v4.1.18 

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

func (*QueryResponse) Reset 

func (x *QueryResponse) Reset()

func (*QueryResponse) String 

func (x *QueryResponse) String() string

type ReplicationClient added in v4.1.0 

type ReplicationClient interface {
	GetWALStream(ctx context.Context, in *GetWALStreamRequest, opts ...grpc.CallOption) (Replication_GetWALStreamClient, error)
}

ReplicationClient is the client API for Replication 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 NewReplicationClient added in v4.1.0 

func NewReplicationClient(cc grpc.ClientConnInterface) ReplicationClient

type ReplicationServer added in v4.1.0 

type ReplicationServer interface {
	GetWALStream(*GetWALStreamRequest, Replication_GetWALStreamServer) error
	// contains filtered or unexported methods
}

ReplicationServer is the server API for Replication service. All implementations must embed UnimplementedReplicationServer for forward compatibility

type Replication_GetWALStreamClient added in v4.1.0 

type Replication_GetWALStreamClient interface {
	Recv() (*GetWALStreamResponse, error)
	grpc.ClientStream
}

type Replication_GetWALStreamServer added in v4.1.0 

type Replication_GetWALStreamServer interface {
	Send(*GetWALStreamResponse) error
	grpc.ServerStream
}

type ServerResponse 

type ServerResponse struct {
	Error   string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` // Server Version
	// contains filtered or unexported fields
}

func (*ServerResponse) Descriptor deprecated 

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

Deprecated: Use ServerResponse.ProtoReflect.Descriptor instead.

func (*ServerResponse) GetError 

func (x *ServerResponse) GetError() string

func (*ServerResponse) GetVersion 

func (x *ServerResponse) GetVersion() string

func (*ServerResponse) ProtoMessage 

func (*ServerResponse) ProtoMessage()

func (*ServerResponse) ProtoReflect added in v4.1.18 

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

func (*ServerResponse) Reset 

func (x *ServerResponse) Reset()

func (*ServerResponse) String 

func (x *ServerResponse) String() string

type ServerVersionRequest 

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

func (*ServerVersionRequest) Descriptor deprecated 

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

Deprecated: Use ServerVersionRequest.ProtoReflect.Descriptor instead.

func (*ServerVersionRequest) ProtoMessage 

func (*ServerVersionRequest) ProtoMessage()

func (*ServerVersionRequest) ProtoReflect added in v4.1.18 

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

func (*ServerVersionRequest) Reset 

func (x *ServerVersionRequest) Reset()

func (*ServerVersionRequest) String 

func (x *ServerVersionRequest) String() string

type ServerVersionResponse 

type ServerVersionResponse struct {
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*ServerVersionResponse) Descriptor deprecated 

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

Deprecated: Use ServerVersionResponse.ProtoReflect.Descriptor instead.

func (*ServerVersionResponse) GetVersion 

func (x *ServerVersionResponse) GetVersion() string

func (*ServerVersionResponse) ProtoMessage 

func (*ServerVersionResponse) ProtoMessage()

func (*ServerVersionResponse) ProtoReflect added in v4.1.18 

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

func (*ServerVersionResponse) Reset 

func (x *ServerVersionResponse) Reset()

func (*ServerVersionResponse) String 

func (x *ServerVersionResponse) String() string

type UnimplementedMarketstoreServer 

type UnimplementedMarketstoreServer struct {
}

UnimplementedMarketstoreServer must be embedded to have forward compatible implementations.

func (UnimplementedMarketstoreServer) Create added in v4.1.1 

func (UnimplementedMarketstoreServer) Create(context.Context, *MultiCreateRequest) (*MultiServerResponse, error)

func (UnimplementedMarketstoreServer) Destroy 

func (UnimplementedMarketstoreServer) Destroy(context.Context, *MultiKeyRequest) (*MultiServerResponse, error)

func (UnimplementedMarketstoreServer) ListSymbols 

func (UnimplementedMarketstoreServer) ListSymbols(context.Context, *ListSymbolsRequest) (*ListSymbolsResponse, error)

func (UnimplementedMarketstoreServer) Query 

func (UnimplementedMarketstoreServer) Query(context.Context, *MultiQueryRequest) (*MultiQueryResponse, error)

func (UnimplementedMarketstoreServer) ServerVersion 

func (UnimplementedMarketstoreServer) ServerVersion(context.Context, *ServerVersionRequest) (*ServerVersionResponse, error)

func (UnimplementedMarketstoreServer) Write 

func (UnimplementedMarketstoreServer) Write(context.Context, *MultiWriteRequest) (*MultiServerResponse, error)

type UnimplementedReplicationServer added in v4.1.0 

type UnimplementedReplicationServer struct {
}

UnimplementedReplicationServer must be embedded to have forward compatible implementations.

func (UnimplementedReplicationServer) GetWALStream added in v4.1.0 

func (UnimplementedReplicationServer) GetWALStream(*GetWALStreamRequest, Replication_GetWALStreamServer) error

type UnsafeMarketstoreServer added in v4.1.18 

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

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

type UnsafeReplicationServer added in v4.1.18 

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

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

type WriteAheadLog added in v4.1.0 

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

func (*WriteAheadLog) Descriptor deprecated added in v4.1.0 

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

Deprecated: Use WriteAheadLog.ProtoReflect.Descriptor instead.

func (*WriteAheadLog) ProtoMessage added in v4.1.0 

func (*WriteAheadLog) ProtoMessage()

func (*WriteAheadLog) ProtoReflect added in v4.1.18 

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

func (*WriteAheadLog) Reset added in v4.1.0 

func (x *WriteAheadLog) Reset()

func (*WriteAheadLog) String added in v4.1.0 

func (x *WriteAheadLog) String() string

type WriteRequest 

type WriteRequest struct {
	Data             *NumpyMultiDataset `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	IsVariableLength bool               `protobuf:"varint,2,opt,name=is_variable_length,json=isVariableLength,proto3" json:"is_variable_length,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteRequest) Descriptor deprecated 

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

Deprecated: Use WriteRequest.ProtoReflect.Descriptor instead.

func (*WriteRequest) GetData 

func (x *WriteRequest) GetData() *NumpyMultiDataset

func (*WriteRequest) GetIsVariableLength 

func (x *WriteRequest) GetIsVariableLength() bool

func (*WriteRequest) ProtoMessage 

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) ProtoReflect added in v4.1.18 

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

func (*WriteRequest) Reset 

func (x *WriteRequest) Reset()

func (*WriteRequest) String 

func (x *WriteRequest) 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.