proto

package
v4.1.0 Latest Latest
Warning

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

 Go to latest Published: Nov 25, 2020 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",
}
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,
}
View Source 
var DestinationID_name = map[int32]string{
	0: "WAL",
	1: "PRIMARY_STORE",
}
View Source 
var DestinationID_value = map[string]int32{
	"WAL":           0,
	"PRIMARY_STORE": 1,
}
View Source 
var FileStatus_name = map[int32]string{
	0: "IN_USE",
	1: "CLOSED",
}
View Source 
var FileStatus_value = map[string]int32{
	"IN_USE": 0,
	"CLOSED": 1,
}
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,
}
View Source 
var MessageID_name = map[int32]string{
	0: "TRANSACTION_GROUP",
	1: "TRANSACTION_INFO",
	2: "WAL_STATUS",
}
View Source 
var MessageID_value = map[string]int32{
	"TRANSACTION_GROUP": 0,
	"TRANSACTION_INFO":  1,
	"WAL_STATUS":        2,
}
View Source 
var RecordType_name = map[int32]string{
	0: "FIXED",
	1: "VARIABLE",
	2: "NO_TYPE",
}
View Source 
var RecordType_value = map[string]int32{
	"FIXED":    0,
	"VARIABLE": 1,
	"NO_TYPE":  2,
}
View Source 
var ReplayState_name = map[int32]string{
	0: "NOT_YET_PROCESSED",
	1: "REPLAYED",
	2: "REPLAY_IN_PROCESS",
}
View Source 
var ReplayState_value = map[string]int32{
	"NOT_YET_PROCESSED": 0,
	"REPLAYED":          1,
	"REPLAY_IN_PROCESS": 2,
}
View Source 
var TIStatus_name = map[int32]string{
	0: "PREPARING_TO_COMMIT",
	1: "COMMIT_INTENT_SENT",
	2: "COMMIT_COMPLETE",
}
View Source 
var TIStatus_value = map[string]int32{
	"PREPARING_TO_COMMIT": 0,
	"COMMIT_INTENT_SENT":  1,
	"COMMIT_COMPLETE":     2,
}

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 DataShape 

type DataShape struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type                 DataType `protobuf:"varint,2,opt,name=type,proto3,enum=proto.DataType" 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() DataType

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
)

func (DataType) EnumDescriptor 

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

func (DataType) String 

func (x DataType) String() string

type DestinationID added in v4.1.0 

type DestinationID int32
const (
	DestinationID_WAL           DestinationID = 0
	DestinationID_PRIMARY_STORE DestinationID = 1
)

func (DestinationID) EnumDescriptor added in v4.1.0 

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

func (DestinationID) String added in v4.1.0 

func (x DestinationID) String() string

type FileStatus added in v4.1.0 

type FileStatus int32
const (
	// Actively in use or not closed programatically
	FileStatus_IN_USE FileStatus = 0
	// Closed (no process is using file)
	FileStatus_CLOSED FileStatus = 1
)

func (FileStatus) EnumDescriptor added in v4.1.0 

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

func (FileStatus) String added in v4.1.0 

func (x FileStatus) 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 {
	//repeated WriteCommand write_commands = 1;
	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)
	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)
	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 MessageID added in v4.1.0 

type MessageID int32

Every message written to the WAL is prepended by the MID, indicating what type of message follows. The MID is structured on-disk: 

const (
	MessageID_TRANSACTION_GROUP MessageID = 0
	MessageID_TRANSACTION_INFO  MessageID = 1
	MessageID_WAL_STATUS        MessageID = 2
)

func (MessageID) EnumDescriptor added in v4.1.0 

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

func (MessageID) String added in v4.1.0 

func (x MessageID) String() string

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 RecordType added in v4.1.0 

type RecordType int32
const (
	RecordType_FIXED RecordType = 0
	// for variable-length record
	RecordType_VARIABLE RecordType = 1
	RecordType_NO_TYPE  RecordType = 2
)

func (RecordType) EnumDescriptor added in v4.1.0 

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

func (RecordType) String added in v4.1.0 

func (x RecordType) String() string

type ReplayState added in v4.1.0 

type ReplayState int32
const (
	// Not yet processed for replay
	ReplayState_NOT_YET_PROCESSED ReplayState = 0
	// Replayed successfully
	ReplayState_REPLAYED ReplayState = 1
	// Replay in process
	ReplayState_REPLAY_IN_PROCESS ReplayState = 2
)

func (ReplayState) EnumDescriptor added in v4.1.0 

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

func (ReplayState) String added in v4.1.0 

func (x ReplayState) String() string

type ReplicationClient added in v4.1.0 

type ReplicationClient interface {
	// rpc GetWALStream (GetWALStreamRequest) returns (stream WALMessage);
	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 {
	// rpc GetWALStream (GetWALStreamRequest) returns (stream WALMessage);
	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 TIStatus added in v4.1.0 

type TIStatus int32

Note: Commit intent state is for future multi-party commit support. Typical processes will only use states 0 and 2 

const (
	TIStatus_PREPARING_TO_COMMIT TIStatus = 0
	TIStatus_COMMIT_INTENT_SENT  TIStatus = 1
	TIStatus_COMMIT_COMPLETE     TIStatus = 2
)

func (TIStatus) EnumDescriptor added in v4.1.0 

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

func (TIStatus) String added in v4.1.0 

func (x TIStatus) String() string

type TransactionGroup added in v4.1.0 

type TransactionGroup struct {
	// The length of the TG data for this TGID, starting with the TGID and excluding the checksum
	Length int64 `protobuf:"varint,1,opt,name=length,proto3" json:"length,omitempty"`
	// A "locally unique" transaction group identifier, can be a clock value
	// This ID will be used for the position that indicates that replication is done until that point
	Id int64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// The count of WTSets in this TG
	WtCount int64 `protobuf:"varint,3,opt,name=wt_count,json=wtCount,proto3" json:"wt_count,omitempty"`
	// The contents of the WTSets
	WtGroup []*WriteTransactionSet `protobuf:"bytes,4,rep,name=wt_group,json=wtGroup,proto3" json:"wt_group,omitempty"`
	// MD5 checksum of the TG contents prior to the checksum
	Checksum             []byte   `protobuf:"bytes,5,opt,name=checksum,proto3" json:"checksum,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Transaction Group (TG): A group of data committed at one time to WAL and primary store Each TG is composed of some number of WTSets and is the smallest unit of data committed to disk. A TG has an ID that is used to verify whether the TG has been successfully written. A TG has the following structure:

func (*TransactionGroup) Descriptor added in v4.1.0 

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

func (*TransactionGroup) GetChecksum added in v4.1.0 

func (m *TransactionGroup) GetChecksum() []byte

func (*TransactionGroup) GetId added in v4.1.0 

func (m *TransactionGroup) GetId() int64

func (*TransactionGroup) GetLength added in v4.1.0 

func (m *TransactionGroup) GetLength() int64

func (*TransactionGroup) GetWtCount added in v4.1.0 

func (m *TransactionGroup) GetWtCount() int64

func (*TransactionGroup) GetWtGroup added in v4.1.0 

func (m *TransactionGroup) GetWtGroup() []*WriteTransactionSet

func (*TransactionGroup) ProtoMessage added in v4.1.0 

func (*TransactionGroup) ProtoMessage()

func (*TransactionGroup) Reset added in v4.1.0 

func (m *TransactionGroup) Reset()

func (*TransactionGroup) String added in v4.1.0 

func (m *TransactionGroup) String() string

func (*TransactionGroup) XXX_DiscardUnknown added in v4.1.0 

func (m *TransactionGroup) XXX_DiscardUnknown()

func (*TransactionGroup) XXX_Marshal added in v4.1.0 

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

func (*TransactionGroup) XXX_Merge added in v4.1.0 

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

func (*TransactionGroup) XXX_Size added in v4.1.0 

func (m *TransactionGroup) XXX_Size() int

func (*TransactionGroup) XXX_Unmarshal added in v4.1.0 

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

type TransactionInfo added in v4.1.0 

type TransactionInfo struct {
	TransactionGroupId   int64         `protobuf:"varint,1,opt,name=transaction_group_id,json=transactionGroupId,proto3" json:"transaction_group_id,omitempty"`
	DestinationId        DestinationID `` /* 126-byte string literal not displayed */
	Status               TIStatus      `protobuf:"varint,3,opt,name=status,proto3,enum=proto.TIStatus" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

A transaction info message marks the write status of transactions. It is used in two situations: When a TG is written to the WAL and when the BW writes a TG to the primary store. The on-disk format of a TI is

func (*TransactionInfo) Descriptor added in v4.1.0 

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

func (*TransactionInfo) GetDestinationId added in v4.1.0 

func (m *TransactionInfo) GetDestinationId() DestinationID

func (*TransactionInfo) GetStatus added in v4.1.0 

func (m *TransactionInfo) GetStatus() TIStatus

func (*TransactionInfo) GetTransactionGroupId added in v4.1.0 

func (m *TransactionInfo) GetTransactionGroupId() int64

func (*TransactionInfo) ProtoMessage added in v4.1.0 

func (*TransactionInfo) ProtoMessage()

func (*TransactionInfo) Reset added in v4.1.0 

func (m *TransactionInfo) Reset()

func (*TransactionInfo) String added in v4.1.0 

func (m *TransactionInfo) String() string

func (*TransactionInfo) XXX_DiscardUnknown added in v4.1.0 

func (m *TransactionInfo) XXX_DiscardUnknown()

func (*TransactionInfo) XXX_Marshal added in v4.1.0 

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

func (*TransactionInfo) XXX_Merge added in v4.1.0 

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

func (*TransactionInfo) XXX_Size added in v4.1.0 

func (m *TransactionInfo) XXX_Size() int

func (*TransactionInfo) XXX_Unmarshal added in v4.1.0 

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

type UnimplementedMarketstoreServer 

type UnimplementedMarketstoreServer struct {
}

UnimplementedMarketstoreServer can be embedded to have forward compatible implementations.

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 WALStatus added in v4.1.0 

type WALStatus struct {
	FileStatus  FileStatus  `protobuf:"varint,1,opt,name=file_status,json=fileStatus,proto3,enum=proto.FileStatus" json:"file_status,omitempty"`
	ReplayState ReplayState `protobuf:"varint,2,opt,name=replay_state,json=replayState,proto3,enum=proto.ReplayState" json:"replay_state,omitempty"`
	// PID of the process using this WAL file
	OwningPid            int64    `protobuf:"varint,3,opt,name=owning_pid,json=owningPid,proto3" json:"owning_pid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WALStatus) Descriptor added in v4.1.0 

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

func (*WALStatus) GetFileStatus added in v4.1.0 

func (m *WALStatus) GetFileStatus() FileStatus

func (*WALStatus) GetOwningPid added in v4.1.0 

func (m *WALStatus) GetOwningPid() int64

func (*WALStatus) GetReplayState added in v4.1.0 

func (m *WALStatus) GetReplayState() ReplayState

func (*WALStatus) ProtoMessage added in v4.1.0 

func (*WALStatus) ProtoMessage()

func (*WALStatus) Reset added in v4.1.0 

func (m *WALStatus) Reset()

func (*WALStatus) String added in v4.1.0 

func (m *WALStatus) String() string

func (*WALStatus) XXX_DiscardUnknown added in v4.1.0 

func (m *WALStatus) XXX_DiscardUnknown()

func (*WALStatus) XXX_Marshal added in v4.1.0 

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

func (*WALStatus) XXX_Merge added in v4.1.0 

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

func (*WALStatus) XXX_Size added in v4.1.0 

func (m *WALStatus) XXX_Size() int

func (*WALStatus) XXX_Unmarshal added in v4.1.0 

func (m *WALStatus) XXX_Unmarshal(b []byte) 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 WriteCommand added in v4.1.0 

type WriteCommand struct {
	// Direct or Indirect IO (for variable or fixed length records)
	RecordType           RecordType `protobuf:"varint,1,opt,name=record_type,json=recordType,proto3,enum=proto.RecordType" json:"record_type,omitempty"`
	WalKeyPath           string     `protobuf:"bytes,2,opt,name=wal_key_path,json=walKeyPath,proto3" json:"wal_key_path,omitempty"`
	VariableRecordLength int32      `protobuf:"varint,3,opt,name=variable_record_length,json=variableRecordLength,proto3" json:"variable_record_length,omitempty"`
	Offset               int64      `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"`
	Index                int64      `protobuf:"varint,5,opt,name=index,proto3" json:"index,omitempty"`
	Data                 []byte     `protobuf:"bytes,6,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*WriteCommand) Descriptor added in v4.1.0 

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

func (*WriteCommand) GetData added in v4.1.0 

func (m *WriteCommand) GetData() []byte

func (*WriteCommand) GetIndex added in v4.1.0 

func (m *WriteCommand) GetIndex() int64

func (*WriteCommand) GetOffset added in v4.1.0 

func (m *WriteCommand) GetOffset() int64

func (*WriteCommand) GetRecordType added in v4.1.0 

func (m *WriteCommand) GetRecordType() RecordType

func (*WriteCommand) GetVariableRecordLength added in v4.1.0 

func (m *WriteCommand) GetVariableRecordLength() int32

func (*WriteCommand) GetWalKeyPath added in v4.1.0 

func (m *WriteCommand) GetWalKeyPath() string

func (*WriteCommand) ProtoMessage added in v4.1.0 

func (*WriteCommand) ProtoMessage()

func (*WriteCommand) Reset added in v4.1.0 

func (m *WriteCommand) Reset()

func (*WriteCommand) String added in v4.1.0 

func (m *WriteCommand) String() string

func (*WriteCommand) XXX_DiscardUnknown added in v4.1.0 

func (m *WriteCommand) XXX_DiscardUnknown()

func (*WriteCommand) XXX_Marshal added in v4.1.0 

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

func (*WriteCommand) XXX_Merge added in v4.1.0 

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

func (*WriteCommand) XXX_Size added in v4.1.0 

func (m *WriteCommand) XXX_Size() int

func (*WriteCommand) XXX_Unmarshal added in v4.1.0 

func (m *WriteCommand) 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

type WriteTransactionSet added in v4.1.0 

type WriteTransactionSet struct {
	// Direct or Indirect IO (for variable or fixed length records)
	RecordType RecordType `protobuf:"varint,1,opt,name=record_type,json=recordType,proto3,enum=proto.RecordType" json:"record_type,omitempty"`
	// Length of FilePath string
	FpLen int32 `protobuf:"varint,2,opt,name=fp_len,json=fpLen,proto3" json:"fp_len,omitempty"`
	// FilePath is relative to the root directory, string is ASCII encoded without a trailing null
	Filepath string `protobuf:"bytes,3,opt,name=filepath,proto3" json:"filepath,omitempty"`
	// Year associated with this file
	Year int32 `protobuf:"varint,4,opt,name=year,proto3" json:"year,omitempty"`
	// Number of intervals per day in this file
	Intervals int64 `protobuf:"varint,5,opt,name=intervals,proto3" json:"intervals,omitempty"`
	// Count of records in this WT set
	RecordCount int32 `protobuf:"varint,6,opt,name=record_count,json=recordCount,proto3" json:"record_count,omitempty"`
	// Length of each data element in this set in bytes, excluding the index
	DataOnlyLen int64 `protobuf:"varint,7,opt,name=data_only_len,json=dataOnlyLen,proto3" json:"data_only_len,omitempty"`
	// Interval Index based on the intervals/day of the target file
	Index []int64 `protobuf:"varint,8,rep,packed,name=index,proto3" json:"index,omitempty"`
	// Data bytes
	Buffer               []byte   `protobuf:"bytes,9,opt,name=buffer,proto3" json:"buffer,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WriteTransactionSet) Descriptor added in v4.1.0 

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

func (*WriteTransactionSet) GetBuffer added in v4.1.0 

func (m *WriteTransactionSet) GetBuffer() []byte

func (*WriteTransactionSet) GetDataOnlyLen added in v4.1.0 

func (m *WriteTransactionSet) GetDataOnlyLen() int64

func (*WriteTransactionSet) GetFilepath added in v4.1.0 

func (m *WriteTransactionSet) GetFilepath() string

func (*WriteTransactionSet) GetFpLen added in v4.1.0 

func (m *WriteTransactionSet) GetFpLen() int32

func (*WriteTransactionSet) GetIndex added in v4.1.0 

func (m *WriteTransactionSet) GetIndex() []int64

func (*WriteTransactionSet) GetIntervals added in v4.1.0 

func (m *WriteTransactionSet) GetIntervals() int64

func (*WriteTransactionSet) GetRecordCount added in v4.1.0 

func (m *WriteTransactionSet) GetRecordCount() int32

func (*WriteTransactionSet) GetRecordType added in v4.1.0 

func (m *WriteTransactionSet) GetRecordType() RecordType

func (*WriteTransactionSet) GetYear added in v4.1.0 

func (m *WriteTransactionSet) GetYear() int32

func (*WriteTransactionSet) ProtoMessage added in v4.1.0 

func (*WriteTransactionSet) ProtoMessage()

func (*WriteTransactionSet) Reset added in v4.1.0 

func (m *WriteTransactionSet) Reset()

func (*WriteTransactionSet) String added in v4.1.0 

func (m *WriteTransactionSet) String() string

func (*WriteTransactionSet) XXX_DiscardUnknown added in v4.1.0 

func (m *WriteTransactionSet) XXX_DiscardUnknown()

func (*WriteTransactionSet) XXX_Marshal added in v4.1.0 

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

func (*WriteTransactionSet) XXX_Merge added in v4.1.0 

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

func (*WriteTransactionSet) XXX_Size added in v4.1.0 

func (m *WriteTransactionSet) XXX_Size() int

func (*WriteTransactionSet) XXX_Unmarshal added in v4.1.0 

func (m *WriteTransactionSet) 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.