proto

package
v4.1.17 Latest Latest
Warning

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

 Go to latest Published: Apr 6, 2022 License: Apache-2.0 Imports: 7 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",
}
View Source 
var 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,
}
View Source 
var ListSymbolsRequest_Format_name = map[int32]string{
	0: "SYMBOL",
	1: "TIME_BUCKET_KEY",
}
View Source 
var ListSymbolsRequest_Format_value = map[string]int32{
	"SYMBOL":          0,
	"TIME_BUCKET_KEY": 1,
}

Functions

func RegisterMarketstoreServer 

func RegisterMarketstoreServer(s *grpc.Server, srv MarketstoreServer)

func RegisterReplicationServer added in v4.1.0 

func RegisterReplicationServer(s *grpc.Server, 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"`
	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"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*CreateRequest) Descriptor added in v4.1.1 

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

func (*CreateRequest) GetDataShapes added in v4.1.1 

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

func (*CreateRequest) GetKey added in v4.1.1 

func (m *CreateRequest) GetKey() string

func (*CreateRequest) GetRowType added in v4.1.1 

func (m *CreateRequest) GetRowType() string

func (*CreateRequest) ProtoMessage added in v4.1.1 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) Reset added in v4.1.1 

func (m *CreateRequest) Reset()

func (*CreateRequest) String added in v4.1.1 

func (m *CreateRequest) String() string

func (*CreateRequest) XXX_DiscardUnknown added in v4.1.1 

func (m *CreateRequest) XXX_DiscardUnknown()

func (*CreateRequest) XXX_Marshal added in v4.1.1 

func (m *CreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateRequest) XXX_Merge added in v4.1.1 

func (m *CreateRequest) XXX_Merge(src proto.Message)

func (*CreateRequest) XXX_Size added in v4.1.1 

func (m *CreateRequest) XXX_Size() int

func (*CreateRequest) XXX_Unmarshal added in v4.1.1 

func (m *CreateRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DataShape) Descriptor 

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

func (*DataShape) GetName 

func (m *DataShape) GetName() string

func (*DataShape) GetType 

func (m *DataShape) GetType() string

func (*DataShape) ProtoMessage 

func (*DataShape) ProtoMessage()

func (*DataShape) Reset 

func (m *DataShape) Reset()

func (*DataShape) String 

func (m *DataShape) String() string

func (*DataShape) XXX_DiscardUnknown 

func (m *DataShape) XXX_DiscardUnknown()

func (*DataShape) XXX_Marshal 

func (m *DataShape) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataShape) XXX_Merge 

func (m *DataShape) XXX_Merge(src proto.Message)

func (*DataShape) XXX_Size 

func (m *DataShape) XXX_Size() int

func (*DataShape) XXX_Unmarshal 

func (m *DataShape) XXX_Unmarshal(b []byte) error

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

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

func (DataType) String 

func (x DataType) String() string

type GetWALStreamRequest added in v4.1.0 

type GetWALStreamRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetWALStreamRequest) Descriptor added in v4.1.0 

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

func (*GetWALStreamRequest) ProtoMessage added in v4.1.0 

func (*GetWALStreamRequest) ProtoMessage()

func (*GetWALStreamRequest) Reset added in v4.1.0 

func (m *GetWALStreamRequest) Reset()

func (*GetWALStreamRequest) String added in v4.1.0 

func (m *GetWALStreamRequest) String() string

func (*GetWALStreamRequest) XXX_DiscardUnknown added in v4.1.0 

func (m *GetWALStreamRequest) XXX_DiscardUnknown()

func (*GetWALStreamRequest) XXX_Marshal added in v4.1.0 

func (m *GetWALStreamRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetWALStreamRequest) XXX_Merge added in v4.1.0 

func (m *GetWALStreamRequest) XXX_Merge(src proto.Message)

func (*GetWALStreamRequest) XXX_Size added in v4.1.0 

func (m *GetWALStreamRequest) XXX_Size() int

func (*GetWALStreamRequest) XXX_Unmarshal added in v4.1.0 

func (m *GetWALStreamRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetWALStreamResponse) Descriptor added in v4.1.0 

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

func (*GetWALStreamResponse) GetTransactionGroup added in v4.1.0 

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

func (*GetWALStreamResponse) ProtoMessage added in v4.1.0 

func (*GetWALStreamResponse) ProtoMessage()

func (*GetWALStreamResponse) Reset added in v4.1.0 

func (m *GetWALStreamResponse) Reset()

func (*GetWALStreamResponse) String added in v4.1.0 

func (m *GetWALStreamResponse) String() string

func (*GetWALStreamResponse) XXX_DiscardUnknown added in v4.1.0 

func (m *GetWALStreamResponse) XXX_DiscardUnknown()

func (*GetWALStreamResponse) XXX_Marshal added in v4.1.0 

func (m *GetWALStreamResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetWALStreamResponse) XXX_Merge added in v4.1.0 

func (m *GetWALStreamResponse) XXX_Merge(src proto.Message)

func (*GetWALStreamResponse) XXX_Size added in v4.1.0 

func (m *GetWALStreamResponse) XXX_Size() int

func (*GetWALStreamResponse) XXX_Unmarshal added in v4.1.0 

func (m *GetWALStreamResponse) XXX_Unmarshal(b []byte) error

type KeyRequest 

type KeyRequest struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KeyRequest) Descriptor 

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

func (*KeyRequest) GetKey 

func (m *KeyRequest) GetKey() string

func (*KeyRequest) ProtoMessage 

func (*KeyRequest) ProtoMessage()

func (*KeyRequest) Reset 

func (m *KeyRequest) Reset()

func (*KeyRequest) String 

func (m *KeyRequest) String() string

func (*KeyRequest) XXX_DiscardUnknown 

func (m *KeyRequest) XXX_DiscardUnknown()

func (*KeyRequest) XXX_Marshal 

func (m *KeyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KeyRequest) XXX_Merge 

func (m *KeyRequest) XXX_Merge(src proto.Message)

func (*KeyRequest) XXX_Size 

func (m *KeyRequest) XXX_Size() int

func (*KeyRequest) XXX_Unmarshal 

func (m *KeyRequest) XXX_Unmarshal(b []byte) error

type ListSymbolsRequest 

type ListSymbolsRequest struct {
	Format               ListSymbolsRequest_Format `protobuf:"varint,1,opt,name=format,proto3,enum=proto.ListSymbolsRequest_Format" json:"format,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*ListSymbolsRequest) Descriptor 

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

func (*ListSymbolsRequest) GetFormat added in v4.0.1 

func (m *ListSymbolsRequest) GetFormat() ListSymbolsRequest_Format

func (*ListSymbolsRequest) ProtoMessage 

func (*ListSymbolsRequest) ProtoMessage()

func (*ListSymbolsRequest) Reset 

func (m *ListSymbolsRequest) Reset()

func (*ListSymbolsRequest) String 

func (m *ListSymbolsRequest) String() string

func (*ListSymbolsRequest) XXX_DiscardUnknown 

func (m *ListSymbolsRequest) XXX_DiscardUnknown()

func (*ListSymbolsRequest) XXX_Marshal 

func (m *ListSymbolsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListSymbolsRequest) XXX_Merge 

func (m *ListSymbolsRequest) XXX_Merge(src proto.Message)

func (*ListSymbolsRequest) XXX_Size 

func (m *ListSymbolsRequest) XXX_Size() int

func (*ListSymbolsRequest) XXX_Unmarshal 

func (m *ListSymbolsRequest) XXX_Unmarshal(b []byte) error

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) EnumDescriptor added in v4.0.1 

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

func (ListSymbolsRequest_Format) String added in v4.0.1 

func (x ListSymbolsRequest_Format) String() string

type ListSymbolsResponse 

type ListSymbolsResponse struct {
	Results              []string `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListSymbolsResponse) Descriptor 

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

func (*ListSymbolsResponse) GetResults 

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

func (*ListSymbolsResponse) ProtoMessage 

func (*ListSymbolsResponse) ProtoMessage()

func (*ListSymbolsResponse) Reset 

func (m *ListSymbolsResponse) Reset()

func (*ListSymbolsResponse) String 

func (m *ListSymbolsResponse) String() string

func (*ListSymbolsResponse) XXX_DiscardUnknown 

func (m *ListSymbolsResponse) XXX_DiscardUnknown()

func (*ListSymbolsResponse) XXX_Marshal 

func (m *ListSymbolsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListSymbolsResponse) XXX_Merge 

func (m *ListSymbolsResponse) XXX_Merge(src proto.Message)

func (*ListSymbolsResponse) XXX_Size 

func (m *ListSymbolsResponse) XXX_Size() int

func (*ListSymbolsResponse) XXX_Unmarshal 

func (m *ListSymbolsResponse) XXX_Unmarshal(b []byte) error

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://godoc.org/google.golang.org/grpc#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)
}

MarketstoreServer is the server API for Marketstore service.

type MultiCreateRequest added in v4.1.1 

type MultiCreateRequest struct {
	Requests             []*CreateRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*MultiCreateRequest) Descriptor added in v4.1.1 

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

func (*MultiCreateRequest) GetRequests added in v4.1.1 

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

func (*MultiCreateRequest) ProtoMessage added in v4.1.1 

func (*MultiCreateRequest) ProtoMessage()

func (*MultiCreateRequest) Reset added in v4.1.1 

func (m *MultiCreateRequest) Reset()

func (*MultiCreateRequest) String added in v4.1.1 

func (m *MultiCreateRequest) String() string

func (*MultiCreateRequest) XXX_DiscardUnknown added in v4.1.1 

func (m *MultiCreateRequest) XXX_DiscardUnknown()

func (*MultiCreateRequest) XXX_Marshal added in v4.1.1 

func (m *MultiCreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MultiCreateRequest) XXX_Merge added in v4.1.1 

func (m *MultiCreateRequest) XXX_Merge(src proto.Message)

func (*MultiCreateRequest) XXX_Size added in v4.1.1 

func (m *MultiCreateRequest) XXX_Size() int

func (*MultiCreateRequest) XXX_Unmarshal added in v4.1.1 

func (m *MultiCreateRequest) XXX_Unmarshal(b []byte) error

type MultiKeyRequest 

type MultiKeyRequest struct {
	Requests             []*KeyRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*MultiKeyRequest) Descriptor 

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

func (*MultiKeyRequest) GetRequests 

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

func (*MultiKeyRequest) ProtoMessage 

func (*MultiKeyRequest) ProtoMessage()

func (*MultiKeyRequest) Reset 

func (m *MultiKeyRequest) Reset()

func (*MultiKeyRequest) String 

func (m *MultiKeyRequest) String() string

func (*MultiKeyRequest) XXX_DiscardUnknown 

func (m *MultiKeyRequest) XXX_DiscardUnknown()

func (*MultiKeyRequest) XXX_Marshal 

func (m *MultiKeyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MultiKeyRequest) XXX_Merge 

func (m *MultiKeyRequest) XXX_Merge(src proto.Message)

func (*MultiKeyRequest) XXX_Size 

func (m *MultiKeyRequest) XXX_Size() int

func (*MultiKeyRequest) XXX_Unmarshal 

func (m *MultiKeyRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*MultiQueryRequest) Descriptor 

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

func (*MultiQueryRequest) GetRequests 

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

func (*MultiQueryRequest) ProtoMessage 

func (*MultiQueryRequest) ProtoMessage()

func (*MultiQueryRequest) Reset 

func (m *MultiQueryRequest) Reset()

func (*MultiQueryRequest) String 

func (m *MultiQueryRequest) String() string

func (*MultiQueryRequest) XXX_DiscardUnknown 

func (m *MultiQueryRequest) XXX_DiscardUnknown()

func (*MultiQueryRequest) XXX_Marshal 

func (m *MultiQueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MultiQueryRequest) XXX_Merge 

func (m *MultiQueryRequest) XXX_Merge(src proto.Message)

func (*MultiQueryRequest) XXX_Size 

func (m *MultiQueryRequest) XXX_Size() int

func (*MultiQueryRequest) XXX_Unmarshal 

func (m *MultiQueryRequest) XXX_Unmarshal(b []byte) error

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"`
	Timezone             string           `protobuf:"bytes,3,opt,name=timezone,proto3" json:"timezone,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*MultiQueryResponse) Descriptor 

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

func (*MultiQueryResponse) GetResponses 

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

func (*MultiQueryResponse) GetTimezone 

func (m *MultiQueryResponse) GetTimezone() string

func (*MultiQueryResponse) GetVersion 

func (m *MultiQueryResponse) GetVersion() string

func (*MultiQueryResponse) ProtoMessage 

func (*MultiQueryResponse) ProtoMessage()

func (*MultiQueryResponse) Reset 

func (m *MultiQueryResponse) Reset()

func (*MultiQueryResponse) String 

func (m *MultiQueryResponse) String() string

func (*MultiQueryResponse) XXX_DiscardUnknown 

func (m *MultiQueryResponse) XXX_DiscardUnknown()

func (*MultiQueryResponse) XXX_Marshal 

func (m *MultiQueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MultiQueryResponse) XXX_Merge 

func (m *MultiQueryResponse) XXX_Merge(src proto.Message)

func (*MultiQueryResponse) XXX_Size 

func (m *MultiQueryResponse) XXX_Size() int

func (*MultiQueryResponse) XXX_Unmarshal 

func (m *MultiQueryResponse) XXX_Unmarshal(b []byte) error

type MultiServerResponse 

type MultiServerResponse struct {
	Responses            []*ServerResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*MultiServerResponse) Descriptor 

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

func (*MultiServerResponse) GetResponses 

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

func (*MultiServerResponse) ProtoMessage 

func (*MultiServerResponse) ProtoMessage()

func (*MultiServerResponse) Reset 

func (m *MultiServerResponse) Reset()

func (*MultiServerResponse) String 

func (m *MultiServerResponse) String() string

func (*MultiServerResponse) XXX_DiscardUnknown 

func (m *MultiServerResponse) XXX_DiscardUnknown()

func (*MultiServerResponse) XXX_Marshal 

func (m *MultiServerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MultiServerResponse) XXX_Merge 

func (m *MultiServerResponse) XXX_Merge(src proto.Message)

func (*MultiServerResponse) XXX_Size 

func (m *MultiServerResponse) XXX_Size() int

func (*MultiServerResponse) XXX_Unmarshal 

func (m *MultiServerResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*MultiWriteRequest) Descriptor 

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

func (*MultiWriteRequest) GetRequests 

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

func (*MultiWriteRequest) ProtoMessage 

func (*MultiWriteRequest) ProtoMessage()

func (*MultiWriteRequest) Reset 

func (m *MultiWriteRequest) Reset()

func (*MultiWriteRequest) String 

func (m *MultiWriteRequest) String() string

func (*MultiWriteRequest) XXX_DiscardUnknown 

func (m *MultiWriteRequest) XXX_DiscardUnknown()

func (*MultiWriteRequest) XXX_Marshal 

func (m *MultiWriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MultiWriteRequest) XXX_Merge 

func (m *MultiWriteRequest) XXX_Merge(src proto.Message)

func (*MultiWriteRequest) XXX_Size 

func (m *MultiWriteRequest) XXX_Size() int

func (*MultiWriteRequest) XXX_Unmarshal 

func (m *MultiWriteRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*NumpyDataset) Descriptor 

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

func (*NumpyDataset) GetColumnData 

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

func (*NumpyDataset) GetColumnNames 

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

func (*NumpyDataset) GetColumnTypes 

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

func (*NumpyDataset) GetDataShapes 

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

func (*NumpyDataset) GetLength 

func (m *NumpyDataset) GetLength() int32

func (*NumpyDataset) ProtoMessage 

func (*NumpyDataset) ProtoMessage()

func (*NumpyDataset) Reset 

func (m *NumpyDataset) Reset()

func (*NumpyDataset) String 

func (m *NumpyDataset) String() string

func (*NumpyDataset) XXX_DiscardUnknown 

func (m *NumpyDataset) XXX_DiscardUnknown()

func (*NumpyDataset) XXX_Marshal 

func (m *NumpyDataset) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NumpyDataset) XXX_Merge 

func (m *NumpyDataset) XXX_Merge(src proto.Message)

func (*NumpyDataset) XXX_Size 

func (m *NumpyDataset) XXX_Size() int

func (*NumpyDataset) XXX_Unmarshal 

func (m *NumpyDataset) XXX_Unmarshal(b []byte) error

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 */
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*NumpyMultiDataset) Descriptor 

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

func (*NumpyMultiDataset) GetData 

func (m *NumpyMultiDataset) GetData() *NumpyDataset

func (*NumpyMultiDataset) GetLengths 

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

func (*NumpyMultiDataset) GetStartIndex 

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

func (*NumpyMultiDataset) ProtoMessage 

func (*NumpyMultiDataset) ProtoMessage()

func (*NumpyMultiDataset) Reset 

func (m *NumpyMultiDataset) Reset()

func (*NumpyMultiDataset) String 

func (m *NumpyMultiDataset) String() string

func (*NumpyMultiDataset) XXX_DiscardUnknown 

func (m *NumpyMultiDataset) XXX_DiscardUnknown()

func (*NumpyMultiDataset) XXX_Marshal 

func (m *NumpyMultiDataset) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NumpyMultiDataset) XXX_Merge 

func (m *NumpyMultiDataset) XXX_Merge(src proto.Message)

func (*NumpyMultiDataset) XXX_Size 

func (m *NumpyMultiDataset) XXX_Size() int

func (*NumpyMultiDataset) XXX_Unmarshal 

func (m *NumpyMultiDataset) XXX_Unmarshal(b []byte) error

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"`
	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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QueryRequest) Descriptor 

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

func (*QueryRequest) GetColumns 

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

func (*QueryRequest) GetDestination 

func (m *QueryRequest) GetDestination() string

func (*QueryRequest) GetEpochEnd 

func (m *QueryRequest) GetEpochEnd() int64

func (*QueryRequest) GetEpochEndNanos 

func (m *QueryRequest) GetEpochEndNanos() int64

func (*QueryRequest) GetEpochStart 

func (m *QueryRequest) GetEpochStart() int64

func (*QueryRequest) GetEpochStartNanos 

func (m *QueryRequest) GetEpochStartNanos() int64

func (*QueryRequest) GetFunctions 

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

func (*QueryRequest) GetIsSqlStatement 

func (m *QueryRequest) GetIsSqlStatement() bool

func (*QueryRequest) GetKeyCategory 

func (m *QueryRequest) GetKeyCategory() string

func (*QueryRequest) GetLimitFromStart 

func (m *QueryRequest) GetLimitFromStart() bool

func (*QueryRequest) GetLimitRecordCount 

func (m *QueryRequest) GetLimitRecordCount() int32

func (*QueryRequest) GetSqlStatement 

func (m *QueryRequest) GetSqlStatement() string

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) Reset 

func (m *QueryRequest) Reset()

func (*QueryRequest) String 

func (m *QueryRequest) String() string

func (*QueryRequest) XXX_DiscardUnknown 

func (m *QueryRequest) XXX_DiscardUnknown()

func (*QueryRequest) XXX_Marshal 

func (m *QueryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryRequest) XXX_Merge 

func (m *QueryRequest) XXX_Merge(src proto.Message)

func (*QueryRequest) XXX_Size 

func (m *QueryRequest) XXX_Size() int

func (*QueryRequest) XXX_Unmarshal 

func (m *QueryRequest) XXX_Unmarshal(b []byte) error

type QueryResponse 

type QueryResponse struct {
	Result               *NumpyMultiDataset `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*QueryResponse) Descriptor 

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

func (*QueryResponse) GetResult 

func (m *QueryResponse) GetResult() *NumpyMultiDataset

func (*QueryResponse) ProtoMessage 

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) Reset 

func (m *QueryResponse) Reset()

func (*QueryResponse) String 

func (m *QueryResponse) String() string

func (*QueryResponse) XXX_DiscardUnknown 

func (m *QueryResponse) XXX_DiscardUnknown()

func (*QueryResponse) XXX_Marshal 

func (m *QueryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryResponse) XXX_Merge 

func (m *QueryResponse) XXX_Merge(src proto.Message)

func (*QueryResponse) XXX_Size 

func (m *QueryResponse) XXX_Size() int

func (*QueryResponse) XXX_Unmarshal 

func (m *QueryResponse) XXX_Unmarshal(b []byte) error

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://godoc.org/google.golang.org/grpc#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
}

ReplicationServer is the server API for Replication service.

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ServerResponse) Descriptor 

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

func (*ServerResponse) GetError 

func (m *ServerResponse) GetError() string

func (*ServerResponse) GetVersion 

func (m *ServerResponse) GetVersion() string

func (*ServerResponse) ProtoMessage 

func (*ServerResponse) ProtoMessage()

func (*ServerResponse) Reset 

func (m *ServerResponse) Reset()

func (*ServerResponse) String 

func (m *ServerResponse) String() string

func (*ServerResponse) XXX_DiscardUnknown 

func (m *ServerResponse) XXX_DiscardUnknown()

func (*ServerResponse) XXX_Marshal 

func (m *ServerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServerResponse) XXX_Merge 

func (m *ServerResponse) XXX_Merge(src proto.Message)

func (*ServerResponse) XXX_Size 

func (m *ServerResponse) XXX_Size() int

func (*ServerResponse) XXX_Unmarshal 

func (m *ServerResponse) XXX_Unmarshal(b []byte) error

type ServerVersionRequest 

type ServerVersionRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ServerVersionRequest) Descriptor 

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

func (*ServerVersionRequest) ProtoMessage 

func (*ServerVersionRequest) ProtoMessage()

func (*ServerVersionRequest) Reset 

func (m *ServerVersionRequest) Reset()

func (*ServerVersionRequest) String 

func (m *ServerVersionRequest) String() string

func (*ServerVersionRequest) XXX_DiscardUnknown 

func (m *ServerVersionRequest) XXX_DiscardUnknown()

func (*ServerVersionRequest) XXX_Marshal 

func (m *ServerVersionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServerVersionRequest) XXX_Merge 

func (m *ServerVersionRequest) XXX_Merge(src proto.Message)

func (*ServerVersionRequest) XXX_Size 

func (m *ServerVersionRequest) XXX_Size() int

func (*ServerVersionRequest) XXX_Unmarshal 

func (m *ServerVersionRequest) XXX_Unmarshal(b []byte) error

type ServerVersionResponse 

type ServerVersionResponse struct {
	Version              string   `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ServerVersionResponse) Descriptor 

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

func (*ServerVersionResponse) GetVersion 

func (m *ServerVersionResponse) GetVersion() string

func (*ServerVersionResponse) ProtoMessage 

func (*ServerVersionResponse) ProtoMessage()

func (*ServerVersionResponse) Reset 

func (m *ServerVersionResponse) Reset()

func (*ServerVersionResponse) String 

func (m *ServerVersionResponse) String() string

func (*ServerVersionResponse) XXX_DiscardUnknown 

func (m *ServerVersionResponse) XXX_DiscardUnknown()

func (*ServerVersionResponse) XXX_Marshal 

func (m *ServerVersionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServerVersionResponse) XXX_Merge 

func (m *ServerVersionResponse) XXX_Merge(src proto.Message)

func (*ServerVersionResponse) XXX_Size 

func (m *ServerVersionResponse) XXX_Size() int

func (*ServerVersionResponse) XXX_Unmarshal 

func (m *ServerVersionResponse) XXX_Unmarshal(b []byte) error

type UnimplementedMarketstoreServer 

type UnimplementedMarketstoreServer struct {
}

UnimplementedMarketstoreServer can be embedded to have forward compatible implementations.

func (*UnimplementedMarketstoreServer) Create added in v4.1.1 

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

func (*UnimplementedMarketstoreServer) Destroy 

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

func (*UnimplementedMarketstoreServer) ListSymbols 

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

func (*UnimplementedMarketstoreServer) Query 

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

func (*UnimplementedMarketstoreServer) ServerVersion 

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

func (*UnimplementedMarketstoreServer) Write 

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

type UnimplementedReplicationServer added in v4.1.0 

type UnimplementedReplicationServer struct {
}

UnimplementedReplicationServer can be embedded to have forward compatible implementations.

func (*UnimplementedReplicationServer) GetWALStream added in v4.1.0 

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

type WriteAheadLog added in v4.1.0 

type WriteAheadLog struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WriteAheadLog) Descriptor added in v4.1.0 

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

func (*WriteAheadLog) ProtoMessage added in v4.1.0 

func (*WriteAheadLog) ProtoMessage()

func (*WriteAheadLog) Reset added in v4.1.0 

func (m *WriteAheadLog) Reset()

func (*WriteAheadLog) String added in v4.1.0 

func (m *WriteAheadLog) String() string

func (*WriteAheadLog) XXX_DiscardUnknown added in v4.1.0 

func (m *WriteAheadLog) XXX_DiscardUnknown()

func (*WriteAheadLog) XXX_Marshal added in v4.1.0 

func (m *WriteAheadLog) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteAheadLog) XXX_Merge added in v4.1.0 

func (m *WriteAheadLog) XXX_Merge(src proto.Message)

func (*WriteAheadLog) XXX_Size added in v4.1.0 

func (m *WriteAheadLog) XXX_Size() int

func (*WriteAheadLog) XXX_Unmarshal added in v4.1.0 

func (m *WriteAheadLog) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*WriteRequest) Descriptor 

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

func (*WriteRequest) GetData 

func (m *WriteRequest) GetData() *NumpyMultiDataset

func (*WriteRequest) GetIsVariableLength 

func (m *WriteRequest) GetIsVariableLength() bool

func (*WriteRequest) ProtoMessage 

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) Reset 

func (m *WriteRequest) Reset()

func (*WriteRequest) String 

func (m *WriteRequest) String() string

func (*WriteRequest) XXX_DiscardUnknown 

func (m *WriteRequest) XXX_DiscardUnknown()

func (*WriteRequest) XXX_Marshal 

func (m *WriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteRequest) XXX_Merge 

func (m *WriteRequest) XXX_Merge(src proto.Message)

func (*WriteRequest) XXX_Size 

func (m *WriteRequest) XXX_Size() int

func (*WriteRequest) XXX_Unmarshal 

func (m *WriteRequest) XXX_Unmarshal(b []byte) error

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.