rpc

package
v0.0.2 Latest Latest
Warning

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

 Go to latest Published: Sep 5, 2019 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var HealthCheckResponse_ServingStatus_name = map[int32]string{
	0: "UNKNOWN",
	1: "SERVING",
	2: "NOT_SERVING",
}
View Source 
var HealthCheckResponse_ServingStatus_value = map[string]int32{
	"UNKNOWN":     0,
	"SERVING":     1,
	"NOT_SERVING": 2,
}

Functions

func RegisterPeerDataNodeServer 

func RegisterPeerDataNodeServer(s *grpc.Server, srv PeerDataNodeServer)

Types

type ArchiveVersion 

type ArchiveVersion struct {
	ArchiveVersion       uint32   `protobuf:"varint,1,opt,name=archiveVersion,proto3" json:"archiveVersion,omitempty"`
	BackfillSeq          uint32   `protobuf:"varint,2,opt,name=backfillSeq,proto3" json:"backfillSeq,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ArchiveVersion) Descriptor 

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

func (*ArchiveVersion) GetArchiveVersion 

func (m *ArchiveVersion) GetArchiveVersion() uint32

func (*ArchiveVersion) GetBackfillSeq 

func (m *ArchiveVersion) GetBackfillSeq() uint32

func (*ArchiveVersion) ProtoMessage 

func (*ArchiveVersion) ProtoMessage()

func (*ArchiveVersion) Reset 

func (m *ArchiveVersion) Reset()

func (*ArchiveVersion) String 

func (m *ArchiveVersion) String() string

func (*ArchiveVersion) XXX_DiscardUnknown 

func (m *ArchiveVersion) XXX_DiscardUnknown()

func (*ArchiveVersion) XXX_Marshal 

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

func (*ArchiveVersion) XXX_Merge 

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

func (*ArchiveVersion) XXX_Size 

func (m *ArchiveVersion) XXX_Size() int

func (*ArchiveVersion) XXX_Unmarshal 

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

type BackfillCheckpoint 

type BackfillCheckpoint struct {
	RedoFileID           int64    `protobuf:"varint,1,opt,name=redoFileID,proto3" json:"redoFileID,omitempty"`
	RedoFileOffset       uint32   `protobuf:"varint,2,opt,name=redoFileOffset,proto3" json:"redoFileOffset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BackfillCheckpoint) Descriptor 

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

func (*BackfillCheckpoint) GetRedoFileID 

func (m *BackfillCheckpoint) GetRedoFileID() int64

func (*BackfillCheckpoint) GetRedoFileOffset 

func (m *BackfillCheckpoint) GetRedoFileOffset() uint32

func (*BackfillCheckpoint) ProtoMessage 

func (*BackfillCheckpoint) ProtoMessage()

func (*BackfillCheckpoint) Reset 

func (m *BackfillCheckpoint) Reset()

func (*BackfillCheckpoint) String 

func (m *BackfillCheckpoint) String() string

func (*BackfillCheckpoint) XXX_DiscardUnknown 

func (m *BackfillCheckpoint) XXX_DiscardUnknown()

func (*BackfillCheckpoint) XXX_Marshal 

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

func (*BackfillCheckpoint) XXX_Merge 

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

func (*BackfillCheckpoint) XXX_Size 

func (m *BackfillCheckpoint) XXX_Size() int

func (*BackfillCheckpoint) XXX_Unmarshal 

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

type BatchMetaData 

type BatchMetaData struct {
	BatchID              int32                  `protobuf:"varint,1,opt,name=batchID,proto3" json:"batchID,omitempty"`
	Size                 uint32                 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	ArchiveVersion       *ArchiveVersion        `protobuf:"bytes,3,opt,name=archiveVersion,proto3" json:"archiveVersion,omitempty"`
	Vps                  []*VectorPartyMetaData `protobuf:"bytes,4,rep,name=vps,proto3" json:"vps,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*BatchMetaData) Descriptor 

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

func (*BatchMetaData) GetArchiveVersion 

func (m *BatchMetaData) GetArchiveVersion() *ArchiveVersion

func (*BatchMetaData) GetBatchID 

func (m *BatchMetaData) GetBatchID() int32

func (*BatchMetaData) GetSize 

func (m *BatchMetaData) GetSize() uint32

func (*BatchMetaData) GetVps 

func (m *BatchMetaData) GetVps() []*VectorPartyMetaData

func (*BatchMetaData) ProtoMessage 

func (*BatchMetaData) ProtoMessage()

func (*BatchMetaData) Reset 

func (m *BatchMetaData) Reset()

func (*BatchMetaData) String 

func (m *BatchMetaData) String() string

func (*BatchMetaData) XXX_DiscardUnknown 

func (m *BatchMetaData) XXX_DiscardUnknown()

func (*BatchMetaData) XXX_Marshal 

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

func (*BatchMetaData) XXX_Merge 

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

func (*BatchMetaData) XXX_Size 

func (m *BatchMetaData) XXX_Size() int

func (*BatchMetaData) XXX_Unmarshal 

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

type BenchmarkRequest 

type BenchmarkRequest struct {
	File                 string   `protobuf:"bytes,1,opt,name=file,proto3" json:"file,omitempty"`
	ChunkSize            int32    `protobuf:"varint,2,opt,name=chunkSize,proto3" json:"chunkSize,omitempty"`
	BufferSize           int32    `protobuf:"varint,3,opt,name=bufferSize,proto3" json:"bufferSize,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BenchmarkRequest) Descriptor 

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

func (*BenchmarkRequest) GetBufferSize 

func (m *BenchmarkRequest) GetBufferSize() int32

func (*BenchmarkRequest) GetChunkSize 

func (m *BenchmarkRequest) GetChunkSize() int32

func (*BenchmarkRequest) GetFile 

func (m *BenchmarkRequest) GetFile() string

func (*BenchmarkRequest) ProtoMessage 

func (*BenchmarkRequest) ProtoMessage()

func (*BenchmarkRequest) Reset 

func (m *BenchmarkRequest) Reset()

func (*BenchmarkRequest) String 

func (m *BenchmarkRequest) String() string

func (*BenchmarkRequest) XXX_DiscardUnknown 

func (m *BenchmarkRequest) XXX_DiscardUnknown()

func (*BenchmarkRequest) XXX_Marshal 

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

func (*BenchmarkRequest) XXX_Merge 

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

func (*BenchmarkRequest) XXX_Size 

func (m *BenchmarkRequest) XXX_Size() int

func (*BenchmarkRequest) XXX_Unmarshal 

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

type DimensionTableShardMetaData 

type DimensionTableShardMetaData struct {
	SnapshotVersion      *SnapshotVersion `protobuf:"bytes,1,opt,name=snapshotVersion,proto3" json:"snapshotVersion,omitempty"`
	LastBatchID          int32            `protobuf:"varint,2,opt,name=lastBatchID,proto3" json:"lastBatchID,omitempty"`
	LastBatchSize        int32            `protobuf:"varint,3,opt,name=lastBatchSize,proto3" json:"lastBatchSize,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*DimensionTableShardMetaData) Descriptor 

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

func (*DimensionTableShardMetaData) GetLastBatchID 

func (m *DimensionTableShardMetaData) GetLastBatchID() int32

func (*DimensionTableShardMetaData) GetLastBatchSize 

func (m *DimensionTableShardMetaData) GetLastBatchSize() int32

func (*DimensionTableShardMetaData) GetSnapshotVersion 

func (m *DimensionTableShardMetaData) GetSnapshotVersion() *SnapshotVersion

func (*DimensionTableShardMetaData) ProtoMessage 

func (*DimensionTableShardMetaData) ProtoMessage()

func (*DimensionTableShardMetaData) Reset 

func (m *DimensionTableShardMetaData) Reset()

func (*DimensionTableShardMetaData) String 

func (m *DimensionTableShardMetaData) String() string

func (*DimensionTableShardMetaData) XXX_DiscardUnknown 

func (m *DimensionTableShardMetaData) XXX_DiscardUnknown()

func (*DimensionTableShardMetaData) XXX_Marshal 

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

func (*DimensionTableShardMetaData) XXX_Merge 

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

func (*DimensionTableShardMetaData) XXX_Size 

func (m *DimensionTableShardMetaData) XXX_Size() int

func (*DimensionTableShardMetaData) XXX_Unmarshal 

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

type FactTableShardMetaData 

type FactTableShardMetaData struct {
	HighWatermark        uint32              `protobuf:"varint,1,opt,name=highWatermark,proto3" json:"highWatermark,omitempty"`
	BackfillCheckpoint   *BackfillCheckpoint `protobuf:"bytes,2,opt,name=backfillCheckpoint,proto3" json:"backfillCheckpoint,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*FactTableShardMetaData) Descriptor 

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

func (*FactTableShardMetaData) GetBackfillCheckpoint 

func (m *FactTableShardMetaData) GetBackfillCheckpoint() *BackfillCheckpoint

func (*FactTableShardMetaData) GetHighWatermark 

func (m *FactTableShardMetaData) GetHighWatermark() uint32

func (*FactTableShardMetaData) ProtoMessage 

func (*FactTableShardMetaData) ProtoMessage()

func (*FactTableShardMetaData) Reset 

func (m *FactTableShardMetaData) Reset()

func (*FactTableShardMetaData) String 

func (m *FactTableShardMetaData) String() string

func (*FactTableShardMetaData) XXX_DiscardUnknown 

func (m *FactTableShardMetaData) XXX_DiscardUnknown()

func (*FactTableShardMetaData) XXX_Marshal 

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

func (*FactTableShardMetaData) XXX_Merge 

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

func (*FactTableShardMetaData) XXX_Size 

func (m *FactTableShardMetaData) XXX_Size() int

func (*FactTableShardMetaData) XXX_Unmarshal 

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

type HealthCheckRequest 

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

func (*HealthCheckRequest) Descriptor 

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

func (*HealthCheckRequest) GetService 

func (m *HealthCheckRequest) GetService() string

func (*HealthCheckRequest) ProtoMessage 

func (*HealthCheckRequest) ProtoMessage()

func (*HealthCheckRequest) Reset 

func (m *HealthCheckRequest) Reset()

func (*HealthCheckRequest) String 

func (m *HealthCheckRequest) String() string

func (*HealthCheckRequest) XXX_DiscardUnknown 

func (m *HealthCheckRequest) XXX_DiscardUnknown()

func (*HealthCheckRequest) XXX_Marshal 

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

func (*HealthCheckRequest) XXX_Merge 

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

func (*HealthCheckRequest) XXX_Size 

func (m *HealthCheckRequest) XXX_Size() int

func (*HealthCheckRequest) XXX_Unmarshal 

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

type HealthCheckResponse 

type HealthCheckResponse struct {
	Status               HealthCheckResponse_ServingStatus `protobuf:"varint,1,opt,name=status,proto3,enum=rpc.HealthCheckResponse_ServingStatus" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                          `json:"-"`
	XXX_unrecognized     []byte                            `json:"-"`
	XXX_sizecache        int32                             `json:"-"`
}

func (*HealthCheckResponse) Descriptor 

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

func (*HealthCheckResponse) GetStatus 

func (m *HealthCheckResponse) GetStatus() HealthCheckResponse_ServingStatus

func (*HealthCheckResponse) ProtoMessage 

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) Reset 

func (m *HealthCheckResponse) Reset()

func (*HealthCheckResponse) String 

func (m *HealthCheckResponse) String() string

func (*HealthCheckResponse) XXX_DiscardUnknown 

func (m *HealthCheckResponse) XXX_DiscardUnknown()

func (*HealthCheckResponse) XXX_Marshal 

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

func (*HealthCheckResponse) XXX_Merge 

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

func (*HealthCheckResponse) XXX_Size 

func (m *HealthCheckResponse) XXX_Size() int

func (*HealthCheckResponse) XXX_Unmarshal 

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

type HealthCheckResponse_ServingStatus 

type HealthCheckResponse_ServingStatus int32
const (
	HealthCheckResponse_UNKNOWN     HealthCheckResponse_ServingStatus = 0
	HealthCheckResponse_SERVING     HealthCheckResponse_ServingStatus = 1
	HealthCheckResponse_NOT_SERVING HealthCheckResponse_ServingStatus = 2
)

func (HealthCheckResponse_ServingStatus) EnumDescriptor 

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

func (HealthCheckResponse_ServingStatus) String 

func (x HealthCheckResponse_ServingStatus) String() string

type KafkaOffset 

type KafkaOffset struct {
	CheckPointOffset     int64    `protobuf:"varint,1,opt,name=checkPointOffset,proto3" json:"checkPointOffset,omitempty"`
	CommitOffset         int64    `protobuf:"varint,2,opt,name=commitOffset,proto3" json:"commitOffset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KafkaOffset) Descriptor 

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

func (*KafkaOffset) GetCheckPointOffset 

func (m *KafkaOffset) GetCheckPointOffset() int64

func (*KafkaOffset) GetCommitOffset 

func (m *KafkaOffset) GetCommitOffset() int64

func (*KafkaOffset) ProtoMessage 

func (*KafkaOffset) ProtoMessage()

func (*KafkaOffset) Reset 

func (m *KafkaOffset) Reset()

func (*KafkaOffset) String 

func (m *KafkaOffset) String() string

func (*KafkaOffset) XXX_DiscardUnknown 

func (m *KafkaOffset) XXX_DiscardUnknown()

func (*KafkaOffset) XXX_Marshal 

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

func (*KafkaOffset) XXX_Merge 

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

func (*KafkaOffset) XXX_Size 

func (m *KafkaOffset) XXX_Size() int

func (*KafkaOffset) XXX_Unmarshal 

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

type KeepAliveResponse 

type KeepAliveResponse struct {
	ID                   int64    `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Ttl                  int64    `protobuf:"varint,2,opt,name=ttl,proto3" json:"ttl,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KeepAliveResponse) Descriptor 

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

func (*KeepAliveResponse) GetID 

func (m *KeepAliveResponse) GetID() int64

func (*KeepAliveResponse) GetTtl 

func (m *KeepAliveResponse) GetTtl() int64

func (*KeepAliveResponse) ProtoMessage 

func (*KeepAliveResponse) ProtoMessage()

func (*KeepAliveResponse) Reset 

func (m *KeepAliveResponse) Reset()

func (*KeepAliveResponse) String 

func (m *KeepAliveResponse) String() string

func (*KeepAliveResponse) XXX_DiscardUnknown 

func (m *KeepAliveResponse) XXX_DiscardUnknown()

func (*KeepAliveResponse) XXX_Marshal 

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

func (*KeepAliveResponse) XXX_Merge 

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

func (*KeepAliveResponse) XXX_Size 

func (m *KeepAliveResponse) XXX_Size() int

func (*KeepAliveResponse) XXX_Unmarshal 

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

type PeerDataNodeClient 

type PeerDataNodeClient interface {
	Health(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (*HealthCheckResponse, error)
	// StartSession starts a session for data streaming
	StartSession(ctx context.Context, in *StartSessionRequest, opts ...grpc.CallOption) (*Session, error)
	// KeepAlive sends keep alive message to the peer data service to
	// renew session and get new ttl for the session
	KeepAlive(ctx context.Context, opts ...grpc.CallOption) (PeerDataNode_KeepAliveClient, error)
	// FetchTableShardMetaData fetches metadata for given table shard
	FetchTableShardMetaData(ctx context.Context, in *TableShardMetaDataRequest, opts ...grpc.CallOption) (*TableShardMetaData, error)
	// FetchVectorPartyRawData fetches raw data for specified vector party
	FetchVectorPartyRawData(ctx context.Context, in *VectorPartyRawDataRequest, opts ...grpc.CallOption) (PeerDataNode_FetchVectorPartyRawDataClient, error)
	// benchmark function to test performance using different config for file transfer
	BenchmarkFileTransfer(ctx context.Context, in *BenchmarkRequest, opts ...grpc.CallOption) (PeerDataNode_BenchmarkFileTransferClient, error)
}

PeerDataNodeClient is the client API for PeerDataNode service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPeerDataNodeClient 

func NewPeerDataNodeClient(cc *grpc.ClientConn) PeerDataNodeClient

type PeerDataNodeServer 

type PeerDataNodeServer interface {
	Health(context.Context, *HealthCheckRequest) (*HealthCheckResponse, error)
	// StartSession starts a session for data streaming
	StartSession(context.Context, *StartSessionRequest) (*Session, error)
	// KeepAlive sends keep alive message to the peer data service to
	// renew session and get new ttl for the session
	KeepAlive(PeerDataNode_KeepAliveServer) error
	// FetchTableShardMetaData fetches metadata for given table shard
	FetchTableShardMetaData(context.Context, *TableShardMetaDataRequest) (*TableShardMetaData, error)
	// FetchVectorPartyRawData fetches raw data for specified vector party
	FetchVectorPartyRawData(*VectorPartyRawDataRequest, PeerDataNode_FetchVectorPartyRawDataServer) error
	// benchmark function to test performance using different config for file transfer
	BenchmarkFileTransfer(*BenchmarkRequest, PeerDataNode_BenchmarkFileTransferServer) error
}

PeerDataNodeServer is the server API for PeerDataNode service.

type PeerDataNode_BenchmarkFileTransferClient 

type PeerDataNode_BenchmarkFileTransferClient interface {
	Recv() (*VectorPartyRawData, error)
	grpc.ClientStream
}

type PeerDataNode_BenchmarkFileTransferServer 

type PeerDataNode_BenchmarkFileTransferServer interface {
	Send(*VectorPartyRawData) error
	grpc.ServerStream
}

type PeerDataNode_FetchVectorPartyRawDataClient 

type PeerDataNode_FetchVectorPartyRawDataClient interface {
	Recv() (*VectorPartyRawData, error)
	grpc.ClientStream
}

type PeerDataNode_FetchVectorPartyRawDataServer 

type PeerDataNode_FetchVectorPartyRawDataServer interface {
	Send(*VectorPartyRawData) error
	grpc.ServerStream
}

type PeerDataNode_KeepAliveClient 

type PeerDataNode_KeepAliveClient interface {
	Send(*Session) error
	Recv() (*KeepAliveResponse, error)
	grpc.ClientStream
}

type PeerDataNode_KeepAliveServer 

type PeerDataNode_KeepAliveServer interface {
	Send(*KeepAliveResponse) error
	Recv() (*Session, error)
	grpc.ServerStream
}

type Session 

type Session struct {
	ID                   int64    `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	NodeID               string   `protobuf:"bytes,2,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Session) Descriptor 

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

func (*Session) GetID 

func (m *Session) GetID() int64

func (*Session) GetNodeID 

func (m *Session) GetNodeID() string

func (*Session) ProtoMessage 

func (*Session) ProtoMessage()

func (*Session) Reset 

func (m *Session) Reset()

func (*Session) String 

func (m *Session) String() string

func (*Session) XXX_DiscardUnknown 

func (m *Session) XXX_DiscardUnknown()

func (*Session) XXX_Marshal 

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

func (*Session) XXX_Merge 

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

func (*Session) XXX_Size 

func (m *Session) XXX_Size() int

func (*Session) XXX_Unmarshal 

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

type SnapshotVersion 

type SnapshotVersion struct {
	RedoFileID           int64    `protobuf:"varint,1,opt,name=redoFileID,proto3" json:"redoFileID,omitempty"`
	RedoFileOffset       uint32   `protobuf:"varint,2,opt,name=redoFileOffset,proto3" json:"redoFileOffset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SnapshotVersion) Descriptor 

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

func (*SnapshotVersion) GetRedoFileID 

func (m *SnapshotVersion) GetRedoFileID() int64

func (*SnapshotVersion) GetRedoFileOffset 

func (m *SnapshotVersion) GetRedoFileOffset() uint32

func (*SnapshotVersion) ProtoMessage 

func (*SnapshotVersion) ProtoMessage()

func (*SnapshotVersion) Reset 

func (m *SnapshotVersion) Reset()

func (*SnapshotVersion) String 

func (m *SnapshotVersion) String() string

func (*SnapshotVersion) XXX_DiscardUnknown 

func (m *SnapshotVersion) XXX_DiscardUnknown()

func (*SnapshotVersion) XXX_Marshal 

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

func (*SnapshotVersion) XXX_Merge 

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

func (*SnapshotVersion) XXX_Size 

func (m *SnapshotVersion) XXX_Size() int

func (*SnapshotVersion) XXX_Unmarshal 

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

type StartSessionRequest 

type StartSessionRequest struct {
	Table                string   `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	Shard                uint32   `protobuf:"varint,2,opt,name=shard,proto3" json:"shard,omitempty"`
	Ttl                  int64    `protobuf:"varint,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
	NodeID               string   `protobuf:"bytes,4,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StartSessionRequest) Descriptor 

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

func (*StartSessionRequest) GetNodeID 

func (m *StartSessionRequest) GetNodeID() string

func (*StartSessionRequest) GetShard 

func (m *StartSessionRequest) GetShard() uint32

func (*StartSessionRequest) GetTable 

func (m *StartSessionRequest) GetTable() string

func (*StartSessionRequest) GetTtl 

func (m *StartSessionRequest) GetTtl() int64

func (*StartSessionRequest) ProtoMessage 

func (*StartSessionRequest) ProtoMessage()

func (*StartSessionRequest) Reset 

func (m *StartSessionRequest) Reset()

func (*StartSessionRequest) String 

func (m *StartSessionRequest) String() string

func (*StartSessionRequest) XXX_DiscardUnknown 

func (m *StartSessionRequest) XXX_DiscardUnknown()

func (*StartSessionRequest) XXX_Marshal 

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

func (*StartSessionRequest) XXX_Merge 

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

func (*StartSessionRequest) XXX_Size 

func (m *StartSessionRequest) XXX_Size() int

func (*StartSessionRequest) XXX_Unmarshal 

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

type TableShardMetaData 

type TableShardMetaData struct {
	Table       string       `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	Incarnation int32        `protobuf:"varint,2,opt,name=incarnation,proto3" json:"incarnation,omitempty"`
	Shard       uint32       `protobuf:"varint,3,opt,name=shard,proto3" json:"shard,omitempty"`
	KafkaOffset *KafkaOffset `protobuf:"bytes,4,opt,name=kafkaOffset,proto3" json:"kafkaOffset,omitempty"`
	// Types that are valid to be assigned to Meta:
	//	*TableShardMetaData_FactMeta
	//	*TableShardMetaData_DimensionMeta
	Meta                 isTableShardMetaData_Meta `protobuf_oneof:"meta"`
	Batches              []*BatchMetaData          `protobuf:"bytes,7,rep,name=batches,proto3" json:"batches,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*TableShardMetaData) Descriptor 

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

func (*TableShardMetaData) GetBatches 

func (m *TableShardMetaData) GetBatches() []*BatchMetaData

func (*TableShardMetaData) GetDimensionMeta 

func (m *TableShardMetaData) GetDimensionMeta() *DimensionTableShardMetaData

func (*TableShardMetaData) GetFactMeta 

func (m *TableShardMetaData) GetFactMeta() *FactTableShardMetaData

func (*TableShardMetaData) GetIncarnation 

func (m *TableShardMetaData) GetIncarnation() int32

func (*TableShardMetaData) GetKafkaOffset 

func (m *TableShardMetaData) GetKafkaOffset() *KafkaOffset

func (*TableShardMetaData) GetMeta 

func (m *TableShardMetaData) GetMeta() isTableShardMetaData_Meta

func (*TableShardMetaData) GetShard 

func (m *TableShardMetaData) GetShard() uint32

func (*TableShardMetaData) GetTable 

func (m *TableShardMetaData) GetTable() string

func (*TableShardMetaData) ProtoMessage 

func (*TableShardMetaData) ProtoMessage()

func (*TableShardMetaData) Reset 

func (m *TableShardMetaData) Reset()

func (*TableShardMetaData) String 

func (m *TableShardMetaData) String() string

func (*TableShardMetaData) XXX_DiscardUnknown 

func (m *TableShardMetaData) XXX_DiscardUnknown()

func (*TableShardMetaData) XXX_Marshal 

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

func (*TableShardMetaData) XXX_Merge 

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

func (*TableShardMetaData) XXX_OneofWrappers 

func (*TableShardMetaData) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*TableShardMetaData) XXX_Size 

func (m *TableShardMetaData) XXX_Size() int

func (*TableShardMetaData) XXX_Unmarshal 

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

type TableShardMetaDataRequest 

type TableShardMetaDataRequest struct {
	Table                string   `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	Incarnation          int32    `protobuf:"varint,2,opt,name=incarnation,proto3" json:"incarnation,omitempty"`
	Shard                uint32   `protobuf:"varint,3,opt,name=shard,proto3" json:"shard,omitempty"`
	StartBatchID         int32    `protobuf:"varint,4,opt,name=startBatchID,proto3" json:"startBatchID,omitempty"`
	EndBatchID           int32    `protobuf:"varint,5,opt,name=endBatchID,proto3" json:"endBatchID,omitempty"`
	SessionID            int64    `protobuf:"varint,6,opt,name=sessionID,proto3" json:"sessionID,omitempty"`
	NodeID               string   `protobuf:"bytes,7,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TableShardMetaDataRequest) Descriptor 

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

func (*TableShardMetaDataRequest) GetEndBatchID 

func (m *TableShardMetaDataRequest) GetEndBatchID() int32

func (*TableShardMetaDataRequest) GetIncarnation 

func (m *TableShardMetaDataRequest) GetIncarnation() int32

func (*TableShardMetaDataRequest) GetNodeID 

func (m *TableShardMetaDataRequest) GetNodeID() string

func (*TableShardMetaDataRequest) GetSessionID 

func (m *TableShardMetaDataRequest) GetSessionID() int64

func (*TableShardMetaDataRequest) GetShard 

func (m *TableShardMetaDataRequest) GetShard() uint32

func (*TableShardMetaDataRequest) GetStartBatchID 

func (m *TableShardMetaDataRequest) GetStartBatchID() int32

func (*TableShardMetaDataRequest) GetTable 

func (m *TableShardMetaDataRequest) GetTable() string

func (*TableShardMetaDataRequest) ProtoMessage 

func (*TableShardMetaDataRequest) ProtoMessage()

func (*TableShardMetaDataRequest) Reset 

func (m *TableShardMetaDataRequest) Reset()

func (*TableShardMetaDataRequest) String 

func (m *TableShardMetaDataRequest) String() string

func (*TableShardMetaDataRequest) XXX_DiscardUnknown 

func (m *TableShardMetaDataRequest) XXX_DiscardUnknown()

func (*TableShardMetaDataRequest) XXX_Marshal 

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

func (*TableShardMetaDataRequest) XXX_Merge 

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

func (*TableShardMetaDataRequest) XXX_Size 

func (m *TableShardMetaDataRequest) XXX_Size() int

func (*TableShardMetaDataRequest) XXX_Unmarshal 

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

type TableShardMetaData_DimensionMeta 

type TableShardMetaData_DimensionMeta struct {
	DimensionMeta *DimensionTableShardMetaData `protobuf:"bytes,6,opt,name=dimensionMeta,proto3,oneof"`
}

type TableShardMetaData_FactMeta 

type TableShardMetaData_FactMeta struct {
	FactMeta *FactTableShardMetaData `protobuf:"bytes,5,opt,name=factMeta,proto3,oneof"`
}

type VectorPartyMetaData 

type VectorPartyMetaData struct {
	ColumnID             uint32   `protobuf:"varint,1,opt,name=columnID,proto3" json:"columnID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VectorPartyMetaData) Descriptor 

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

func (*VectorPartyMetaData) GetColumnID 

func (m *VectorPartyMetaData) GetColumnID() uint32

func (*VectorPartyMetaData) ProtoMessage 

func (*VectorPartyMetaData) ProtoMessage()

func (*VectorPartyMetaData) Reset 

func (m *VectorPartyMetaData) Reset()

func (*VectorPartyMetaData) String 

func (m *VectorPartyMetaData) String() string

func (*VectorPartyMetaData) XXX_DiscardUnknown 

func (m *VectorPartyMetaData) XXX_DiscardUnknown()

func (*VectorPartyMetaData) XXX_Marshal 

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

func (*VectorPartyMetaData) XXX_Merge 

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

func (*VectorPartyMetaData) XXX_Size 

func (m *VectorPartyMetaData) XXX_Size() int

func (*VectorPartyMetaData) XXX_Unmarshal 

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

type VectorPartyRawData 

type VectorPartyRawData struct {
	Chunk                []byte   `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VectorPartyRawData) Descriptor 

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

func (*VectorPartyRawData) GetChunk 

func (m *VectorPartyRawData) GetChunk() []byte

func (*VectorPartyRawData) ProtoMessage 

func (*VectorPartyRawData) ProtoMessage()

func (*VectorPartyRawData) Reset 

func (m *VectorPartyRawData) Reset()

func (*VectorPartyRawData) String 

func (m *VectorPartyRawData) String() string

func (*VectorPartyRawData) XXX_DiscardUnknown 

func (m *VectorPartyRawData) XXX_DiscardUnknown()

func (*VectorPartyRawData) XXX_Marshal 

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

func (*VectorPartyRawData) XXX_Merge 

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

func (*VectorPartyRawData) XXX_Size 

func (m *VectorPartyRawData) XXX_Size() int

func (*VectorPartyRawData) XXX_Unmarshal 

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

type VectorPartyRawDataRequest 

type VectorPartyRawDataRequest struct {
	Table       string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	Incarnation int32  `protobuf:"varint,2,opt,name=incarnation,proto3" json:"incarnation,omitempty"`
	Shard       uint32 `protobuf:"varint,3,opt,name=shard,proto3" json:"shard,omitempty"`
	BatchID     int32  `protobuf:"varint,4,opt,name=batchID,proto3" json:"batchID,omitempty"`
	// Types that are valid to be assigned to Version:
	//	*VectorPartyRawDataRequest_ArchiveVersion
	//	*VectorPartyRawDataRequest_SnapshotVersion
	Version              isVectorPartyRawDataRequest_Version `protobuf_oneof:"version"`
	ColumnID             uint32                              `protobuf:"varint,7,opt,name=columnID,proto3" json:"columnID,omitempty"`
	SessionID            int64                               `protobuf:"varint,8,opt,name=sessionID,proto3" json:"sessionID,omitempty"`
	NodeID               string                              `protobuf:"bytes,9,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                            `json:"-"`
	XXX_unrecognized     []byte                              `json:"-"`
	XXX_sizecache        int32                               `json:"-"`
}

func (*VectorPartyRawDataRequest) Descriptor 

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

func (*VectorPartyRawDataRequest) GetArchiveVersion 

func (m *VectorPartyRawDataRequest) GetArchiveVersion() *ArchiveVersion

func (*VectorPartyRawDataRequest) GetBatchID 

func (m *VectorPartyRawDataRequest) GetBatchID() int32

func (*VectorPartyRawDataRequest) GetColumnID 

func (m *VectorPartyRawDataRequest) GetColumnID() uint32

func (*VectorPartyRawDataRequest) GetIncarnation 

func (m *VectorPartyRawDataRequest) GetIncarnation() int32

func (*VectorPartyRawDataRequest) GetNodeID 

func (m *VectorPartyRawDataRequest) GetNodeID() string

func (*VectorPartyRawDataRequest) GetSessionID 

func (m *VectorPartyRawDataRequest) GetSessionID() int64

func (*VectorPartyRawDataRequest) GetShard 

func (m *VectorPartyRawDataRequest) GetShard() uint32

func (*VectorPartyRawDataRequest) GetSnapshotVersion 

func (m *VectorPartyRawDataRequest) GetSnapshotVersion() *SnapshotVersion

func (*VectorPartyRawDataRequest) GetTable 

func (m *VectorPartyRawDataRequest) GetTable() string

func (*VectorPartyRawDataRequest) GetVersion 

func (m *VectorPartyRawDataRequest) GetVersion() isVectorPartyRawDataRequest_Version

func (*VectorPartyRawDataRequest) ProtoMessage 

func (*VectorPartyRawDataRequest) ProtoMessage()

func (*VectorPartyRawDataRequest) Reset 

func (m *VectorPartyRawDataRequest) Reset()

func (*VectorPartyRawDataRequest) String 

func (m *VectorPartyRawDataRequest) String() string

func (*VectorPartyRawDataRequest) XXX_DiscardUnknown 

func (m *VectorPartyRawDataRequest) XXX_DiscardUnknown()

func (*VectorPartyRawDataRequest) XXX_Marshal 

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

func (*VectorPartyRawDataRequest) XXX_Merge 

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

func (*VectorPartyRawDataRequest) XXX_OneofWrappers 

func (*VectorPartyRawDataRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*VectorPartyRawDataRequest) XXX_Size 

func (m *VectorPartyRawDataRequest) XXX_Size() int

func (*VectorPartyRawDataRequest) XXX_Unmarshal 

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

type VectorPartyRawDataRequest_ArchiveVersion 

type VectorPartyRawDataRequest_ArchiveVersion struct {
	ArchiveVersion *ArchiveVersion `protobuf:"bytes,5,opt,name=archiveVersion,proto3,oneof"`
}

type VectorPartyRawDataRequest_SnapshotVersion 

type VectorPartyRawDataRequest_SnapshotVersion struct {
	SnapshotVersion *SnapshotVersion `protobuf:"bytes,6,opt,name=snapshotVersion,proto3,oneof"`
}

Source Files

View all Source files

Directories

Path Synopsis

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.