taas_proto

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Jul 6, 2023 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Result_name = map[int32]string{
		0: "Fail",
		1: "Success",
	}
	Result_value = map[string]int32{
		"Fail":    0,
		"Success": 1,
	}
)

Enum value maps for Result.

View Source 
var (
	TxnType_name = map[int32]string{
		0:  "ClientTxn",
		1:  "RemoteServerTxn",
		2:  "EpochEndFlag",
		3:  "CommittedTxn",
		4:  "BackUpTxn",
		5:  "BackUpEpochEndFlag",
		6:  "AbortSet",
		7:  "InsertSet",
		8:  "EpochShardingACK",
		9:  "BackUpACK",
		10: "AbortSetACK",
		11: "InsertSetACK",
		12: "EpochLogPushDownComplete",
		13: "NullMark",
	}
	TxnType_value = map[string]int32{
		"ClientTxn":                0,
		"RemoteServerTxn":          1,
		"EpochEndFlag":             2,
		"CommittedTxn":             3,
		"BackUpTxn":                4,
		"BackUpEpochEndFlag":       5,
		"AbortSet":                 6,
		"InsertSet":                7,
		"EpochShardingACK":         8,
		"BackUpACK":                9,
		"AbortSetACK":              10,
		"InsertSetACK":             11,
		"EpochLogPushDownComplete": 12,
		"NullMark":                 13,
	}
)

Enum value maps for TxnType.

View Source 
var (
	TxnState_name = map[int32]string{
		0: "Empty",
		1: "Abort",
		2: "Commit",
	}
	TxnState_value = map[string]int32{
		"Empty":  0,
		"Abort":  1,
		"Commit": 2,
	}
)

Enum value maps for TxnState.

View Source 
var (
	OpType_name = map[int32]string{
		0: "Read",
		1: "Insert",
		2: "Update",
		3: "Delete",
	}
	OpType_value = map[string]int32{
		"Read":   0,
		"Insert": 1,
		"Update": 2,
		"Delete": 3,
	}
)

Enum value maps for OpType.

View Source 
var File_client_proto protoreflect.FileDescriptor
View Source 
var File_kvdb_server_proto protoreflect.FileDescriptor
View Source 
var File_message_proto protoreflect.FileDescriptor
View Source 
var File_node_proto protoreflect.FileDescriptor
View Source 
var File_server_proto protoreflect.FileDescriptor
View Source 
var File_storage_proto protoreflect.FileDescriptor
View Source 
var File_transaction_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ChangeServerStateRequest 

type ChangeServerStateRequest struct {
	From         uint32 `protobuf:"varint,1,opt,name=from,proto3" json:"from,omitempty"`
	To           uint32 `protobuf:"varint,2,opt,name=to,proto3" json:"to,omitempty"`
	Target       uint32 `protobuf:"varint,3,opt,name=target,proto3" json:"target,omitempty"`
	State        uint32 `protobuf:"varint,4,opt,name=state,proto3" json:"state,omitempty"`
	PullServerId uint32 `protobuf:"varint,5,opt,name=pull_server_id,json=pullServerId,proto3" json:"pull_server_id,omitempty"`
	EpochId      uint64 `protobuf:"varint,6,opt,name=epoch_id,json=epochId,proto3" json:"epoch_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeServerStateRequest) Descriptor deprecated 

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

Deprecated: Use ChangeServerStateRequest.ProtoReflect.Descriptor instead.

func (*ChangeServerStateRequest) GetEpochId 

func (x *ChangeServerStateRequest) GetEpochId() uint64

func (*ChangeServerStateRequest) GetFrom 

func (x *ChangeServerStateRequest) GetFrom() uint32

func (*ChangeServerStateRequest) GetPullServerId 

func (x *ChangeServerStateRequest) GetPullServerId() uint32

func (*ChangeServerStateRequest) GetState 

func (x *ChangeServerStateRequest) GetState() uint32

func (*ChangeServerStateRequest) GetTarget 

func (x *ChangeServerStateRequest) GetTarget() uint32

func (*ChangeServerStateRequest) GetTo 

func (x *ChangeServerStateRequest) GetTo() uint32

func (*ChangeServerStateRequest) ProtoMessage 

func (*ChangeServerStateRequest) ProtoMessage()

func (*ChangeServerStateRequest) ProtoReflect 

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

func (*ChangeServerStateRequest) Reset 

func (x *ChangeServerStateRequest) Reset()

func (*ChangeServerStateRequest) String 

func (x *ChangeServerStateRequest) String() string

type ChangeServerStateResponse 

type ChangeServerStateResponse struct {
	From    uint32 `protobuf:"varint,1,opt,name=from,proto3" json:"from,omitempty"`
	To      uint32 `protobuf:"varint,2,opt,name=to,proto3" json:"to,omitempty"`
	Target  uint32 `protobuf:"varint,3,opt,name=target,proto3" json:"target,omitempty"`
	EpochId uint64 `protobuf:"varint,4,opt,name=epoch_id,json=epochId,proto3" json:"epoch_id,omitempty"`
	State   uint32 `protobuf:"varint,5,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeServerStateResponse) Descriptor deprecated 

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

Deprecated: Use ChangeServerStateResponse.ProtoReflect.Descriptor instead.

func (*ChangeServerStateResponse) GetEpochId 

func (x *ChangeServerStateResponse) GetEpochId() uint64

func (*ChangeServerStateResponse) GetFrom 

func (x *ChangeServerStateResponse) GetFrom() uint32

func (*ChangeServerStateResponse) GetState 

func (x *ChangeServerStateResponse) GetState() uint32

func (*ChangeServerStateResponse) GetTarget 

func (x *ChangeServerStateResponse) GetTarget() uint32

func (*ChangeServerStateResponse) GetTo 

func (x *ChangeServerStateResponse) GetTo() uint32

func (*ChangeServerStateResponse) ProtoMessage 

func (*ChangeServerStateResponse) ProtoMessage()

func (*ChangeServerStateResponse) ProtoReflect 

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

func (*ChangeServerStateResponse) Reset 

func (x *ChangeServerStateResponse) Reset()

func (*ChangeServerStateResponse) String 

func (x *ChangeServerStateResponse) String() string

type ClientReadRequest 

type ClientReadRequest struct {
	ClientIp string `protobuf:"bytes,1,opt,name=client_ip,json=clientIp,proto3" json:"client_ip,omitempty"`
	TxnId    uint64 `protobuf:"varint,2,opt,name=txn_id,json=txnId,proto3" json:"txn_id,omitempty"`
	Rows     []*Row `protobuf:"bytes,3,rep,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientReadRequest) Descriptor deprecated 

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

Deprecated: Use ClientReadRequest.ProtoReflect.Descriptor instead.

func (*ClientReadRequest) GetClientIp 

func (x *ClientReadRequest) GetClientIp() string

func (*ClientReadRequest) GetRows 

func (x *ClientReadRequest) GetRows() []*Row

func (*ClientReadRequest) GetTxnId 

func (x *ClientReadRequest) GetTxnId() uint64

func (*ClientReadRequest) ProtoMessage 

func (*ClientReadRequest) ProtoMessage()

func (*ClientReadRequest) ProtoReflect 

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

func (*ClientReadRequest) Reset 

func (x *ClientReadRequest) Reset()

func (*ClientReadRequest) String 

func (x *ClientReadRequest) String() string

type ClientReadResponse 

type ClientReadResponse struct {
	Result Result `protobuf:"varint,1,opt,name=result,proto3,enum=taas_proto.Result" json:"result,omitempty"`
	TxnId  uint64 `protobuf:"varint,2,opt,name=txn_id,json=txnId,proto3" json:"txn_id,omitempty"`
	Rows   []*Row `protobuf:"bytes,3,rep,name=rows,proto3" json:"rows,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientReadResponse) Descriptor deprecated 

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

Deprecated: Use ClientReadResponse.ProtoReflect.Descriptor instead.

func (*ClientReadResponse) GetResult 

func (x *ClientReadResponse) GetResult() Result

func (*ClientReadResponse) GetRows 

func (x *ClientReadResponse) GetRows() []*Row

func (*ClientReadResponse) GetTxnId 

func (x *ClientReadResponse) GetTxnId() uint64

func (*ClientReadResponse) ProtoMessage 

func (*ClientReadResponse) ProtoMessage()

func (*ClientReadResponse) ProtoReflect 

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

func (*ClientReadResponse) Reset 

func (x *ClientReadResponse) Reset()

func (*ClientReadResponse) String 

func (x *ClientReadResponse) String() string

type Column 

type Column struct {
	Id    uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`      // column id
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // column value/data
	// contains filtered or unexported fields
}

func (*Column) Descriptor deprecated 

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

Deprecated: Use Column.ProtoReflect.Descriptor instead.

func (*Column) GetId 

func (x *Column) GetId() uint32

func (*Column) GetValue 

func (x *Column) GetValue() []byte

func (*Column) ProtoMessage 

func (*Column) ProtoMessage()

func (*Column) ProtoReflect 

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

func (*Column) Reset 

func (x *Column) Reset()

func (*Column) String 

func (x *Column) String() string

type EpochReplicationAck 

type EpochReplicationAck struct {
	EpochId uint64 `protobuf:"varint,1,opt,name=epoch_id,json=epochId,proto3" json:"epoch_id,omitempty"`
	// contains filtered or unexported fields
}

func (*EpochReplicationAck) Descriptor deprecated 

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

Deprecated: Use EpochReplicationAck.ProtoReflect.Descriptor instead.

func (*EpochReplicationAck) GetEpochId 

func (x *EpochReplicationAck) GetEpochId() uint64

func (*EpochReplicationAck) ProtoMessage 

func (*EpochReplicationAck) ProtoMessage()

func (*EpochReplicationAck) ProtoReflect 

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

func (*EpochReplicationAck) Reset 

func (x *EpochReplicationAck) Reset()

func (*EpochReplicationAck) String 

func (x *EpochReplicationAck) String() string

type ForwardEpochRequest 

type ForwardEpochRequest struct {
	From    int32  `protobuf:"varint,1,opt,name=from,proto3" json:"from,omitempty"`
	To      int32  `protobuf:"varint,2,opt,name=to,proto3" json:"to,omitempty"`
	EpochId uint64 `protobuf:"varint,3,opt,name=epoch_id,json=epochId,proto3" json:"epoch_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ForwardEpochRequest) Descriptor deprecated 

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

Deprecated: Use ForwardEpochRequest.ProtoReflect.Descriptor instead.

func (*ForwardEpochRequest) GetEpochId 

func (x *ForwardEpochRequest) GetEpochId() uint64

func (*ForwardEpochRequest) GetFrom 

func (x *ForwardEpochRequest) GetFrom() int32

func (*ForwardEpochRequest) GetTo 

func (x *ForwardEpochRequest) GetTo() int32

func (*ForwardEpochRequest) ProtoMessage 

func (*ForwardEpochRequest) ProtoMessage()

func (*ForwardEpochRequest) ProtoReflect 

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

func (*ForwardEpochRequest) Reset 

func (x *ForwardEpochRequest) Reset()

func (*ForwardEpochRequest) String 

func (x *ForwardEpochRequest) String() string

type KeyMasterMetadata 

type KeyMasterMetadata struct {
	Key      []byte          `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Metadata *MasterMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyMasterMetadata) Descriptor deprecated 

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

Deprecated: Use KeyMasterMetadata.ProtoReflect.Descriptor instead.

func (*KeyMasterMetadata) GetKey 

func (x *KeyMasterMetadata) GetKey() []byte

func (*KeyMasterMetadata) GetMetadata 

func (x *KeyMasterMetadata) GetMetadata() *MasterMetadata

func (*KeyMasterMetadata) ProtoMessage 

func (*KeyMasterMetadata) ProtoMessage()

func (*KeyMasterMetadata) ProtoReflect 

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

func (*KeyMasterMetadata) Reset 

func (x *KeyMasterMetadata) Reset()

func (*KeyMasterMetadata) String 

func (x *KeyMasterMetadata) String() string

type KvDBData 

type KvDBData struct {
	OpType OpType `protobuf:"varint,1,opt,name=op_type,json=opType,proto3,enum=taas_proto.OpType" json:"op_type,omitempty"`
	Key    string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value  string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Csn    uint64 `protobuf:"varint,4,opt,name=csn,proto3" json:"csn,omitempty"`
	// contains filtered or unexported fields
}

func (*KvDBData) Descriptor deprecated 

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

Deprecated: Use KvDBData.ProtoReflect.Descriptor instead.

func (*KvDBData) GetCsn 

func (x *KvDBData) GetCsn() uint64

func (*KvDBData) GetKey 

func (x *KvDBData) GetKey() string

func (*KvDBData) GetOpType 

func (x *KvDBData) GetOpType() OpType

func (*KvDBData) GetValue 

func (x *KvDBData) GetValue() string

func (*KvDBData) ProtoMessage 

func (*KvDBData) ProtoMessage()

func (*KvDBData) ProtoReflect 

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

func (*KvDBData) Reset 

func (x *KvDBData) Reset()

func (*KvDBData) String 

func (x *KvDBData) String() string

type KvDBRequest 

type KvDBRequest struct {
	Data []*KvDBData `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*KvDBRequest) Descriptor deprecated 

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

Deprecated: Use KvDBRequest.ProtoReflect.Descriptor instead.

func (*KvDBRequest) GetData 

func (x *KvDBRequest) GetData() []*KvDBData

func (*KvDBRequest) ProtoMessage 

func (*KvDBRequest) ProtoMessage()

func (*KvDBRequest) ProtoReflect 

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

func (*KvDBRequest) Reset 

func (x *KvDBRequest) Reset()

func (*KvDBRequest) String 

func (x *KvDBRequest) String() string

type KvDBResponse 

type KvDBResponse struct {
	Result bool        `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	Data   []*KvDBData `protobuf:"bytes,2,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*KvDBResponse) Descriptor deprecated 

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

Deprecated: Use KvDBResponse.ProtoReflect.Descriptor instead.

func (*KvDBResponse) GetData 

func (x *KvDBResponse) GetData() []*KvDBData

func (*KvDBResponse) GetResult 

func (x *KvDBResponse) GetResult() bool

func (*KvDBResponse) ProtoMessage 

func (*KvDBResponse) ProtoMessage()

func (*KvDBResponse) ProtoReflect 

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

func (*KvDBResponse) Reset 

func (x *KvDBResponse) Reset()

func (*KvDBResponse) String 

func (x *KvDBResponse) String() string

type LookupMasterRequest 

type LookupMasterRequest struct {
	TxnIds []uint64 `protobuf:"varint,1,rep,packed,name=txn_ids,json=txnIds,proto3" json:"txn_ids,omitempty"`
	Keys   [][]byte `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*LookupMasterRequest) Descriptor deprecated 

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

Deprecated: Use LookupMasterRequest.ProtoReflect.Descriptor instead.

func (*LookupMasterRequest) GetKeys 

func (x *LookupMasterRequest) GetKeys() [][]byte

func (*LookupMasterRequest) GetTxnIds 

func (x *LookupMasterRequest) GetTxnIds() []uint64

func (*LookupMasterRequest) ProtoMessage 

func (*LookupMasterRequest) ProtoMessage()

func (*LookupMasterRequest) ProtoReflect 

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

func (*LookupMasterRequest) Reset 

func (x *LookupMasterRequest) Reset()

func (*LookupMasterRequest) String 

func (x *LookupMasterRequest) String() string

type LookupMasterResponse 

type LookupMasterResponse struct {
	EpochId       []uint64             `protobuf:"varint,1,rep,packed,name=epoch_id,json=epochId,proto3" json:"epoch_id,omitempty"`
	LookupResults []*KeyMasterMetadata `protobuf:"bytes,2,rep,name=lookup_results,json=lookupResults,proto3" json:"lookup_results,omitempty"`
	// contains filtered or unexported fields
}

func (*LookupMasterResponse) Descriptor deprecated 

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

Deprecated: Use LookupMasterResponse.ProtoReflect.Descriptor instead.

func (*LookupMasterResponse) GetEpochId 

func (x *LookupMasterResponse) GetEpochId() []uint64

func (*LookupMasterResponse) GetLookupResults 

func (x *LookupMasterResponse) GetLookupResults() []*KeyMasterMetadata

func (*LookupMasterResponse) ProtoMessage 

func (*LookupMasterResponse) ProtoMessage()

func (*LookupMasterResponse) ProtoReflect 

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

func (*LookupMasterResponse) Reset 

func (x *LookupMasterResponse) Reset()

func (*LookupMasterResponse) String 

func (x *LookupMasterResponse) String() string

type MasterMetadata 

type MasterMetadata struct {
	Master     uint32 `protobuf:"varint,1,opt,name=master,proto3" json:"master,omitempty"`
	EpochCount uint32 `protobuf:"varint,2,opt,name=epoch_count,json=epochCount,proto3" json:"epoch_count,omitempty"`
	// contains filtered or unexported fields
}

func (*MasterMetadata) Descriptor deprecated 

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

Deprecated: Use MasterMetadata.ProtoReflect.Descriptor instead.

func (*MasterMetadata) GetEpochCount 

func (x *MasterMetadata) GetEpochCount() uint32

func (*MasterMetadata) GetMaster 

func (x *MasterMetadata) GetMaster() uint32

func (*MasterMetadata) ProtoMessage 

func (*MasterMetadata) ProtoMessage()

func (*MasterMetadata) ProtoReflect 

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

func (*MasterMetadata) Reset 

func (x *MasterMetadata) Reset()

func (*MasterMetadata) String 

func (x *MasterMetadata) String() string

type Message 

type Message struct {

	// Types that are assignable to Type:
	//	*Message_Txn
	//	*Message_ReplyTxnResultToClient
	//	*Message_ClientReadRequest
	//	*Message_ClientReadResponse
	//	*Message_StoragePullRequest
	//	*Message_StoragePullResponse
	//	*Message_StoragePushResponse
	//	*Message_RaftRequest
	//	*Message_RaftResponse
	Type isMessage_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor deprecated 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetClientReadRequest 

func (x *Message) GetClientReadRequest() *ClientReadRequest

func (*Message) GetClientReadResponse 

func (x *Message) GetClientReadResponse() *ClientReadResponse

func (*Message) GetRaftRequest 

func (x *Message) GetRaftRequest() *RaftRequest

func (*Message) GetRaftResponse 

func (x *Message) GetRaftResponse() *RaftResponse

func (*Message) GetReplyTxnResultToClient 

func (x *Message) GetReplyTxnResultToClient() *ReplyTransactionToClient

func (*Message) GetStoragePullRequest 

func (x *Message) GetStoragePullRequest() *StoragePullRequest

func (*Message) GetStoragePullResponse 

func (x *Message) GetStoragePullResponse() *StoragePullResponse

func (*Message) GetStoragePushResponse 

func (x *Message) GetStoragePushResponse() *StoragePushResponse

func (*Message) GetTxn 

func (x *Message) GetTxn() *Transaction

func (*Message) GetType 

func (m *Message) GetType() isMessage_Type

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

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

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) String 

func (x *Message) String() string

type Message_ClientReadRequest 

type Message_ClientReadRequest struct {
	ClientReadRequest *ClientReadRequest `protobuf:"bytes,3,opt,name=client_read_request,json=clientReadRequest,proto3,oneof"`
}

type Message_ClientReadResponse 

type Message_ClientReadResponse struct {
	ClientReadResponse *ClientReadResponse `protobuf:"bytes,4,opt,name=client_read_response,json=clientReadResponse,proto3,oneof"`
}

type Message_RaftRequest 

type Message_RaftRequest struct {
	RaftRequest *RaftRequest `protobuf:"bytes,8,opt,name=raft_request,json=raftRequest,proto3,oneof"`
}

type Message_RaftResponse 

type Message_RaftResponse struct {
	RaftResponse *RaftResponse `protobuf:"bytes,9,opt,name=raft_response,json=raftResponse,proto3,oneof"`
}

type Message_ReplyTxnResultToClient 

type Message_ReplyTxnResultToClient struct {
	ReplyTxnResultToClient *ReplyTransactionToClient `protobuf:"bytes,2,opt,name=reply_txn_result_to_client,json=replyTxnResultToClient,proto3,oneof"`
}

type Message_StoragePullRequest 

type Message_StoragePullRequest struct {
	StoragePullRequest *StoragePullRequest `protobuf:"bytes,5,opt,name=storage_pull_request,json=storagePullRequest,proto3,oneof"`
}

type Message_StoragePullResponse 

type Message_StoragePullResponse struct {
	StoragePullResponse *StoragePullResponse `protobuf:"bytes,6,opt,name=storage_pull_response,json=storagePullResponse,proto3,oneof"`
}

type Message_StoragePushResponse 

type Message_StoragePushResponse struct {
	StoragePushResponse *StoragePushResponse `protobuf:"bytes,7,opt,name=storage_push_response,json=storagePushResponse,proto3,oneof"`
}

type Message_Txn 

type Message_Txn struct {
	Txn *Transaction `protobuf:"bytes,1,opt,name=txn,proto3,oneof"`
}

type Node 

type Node struct {
	Ip   string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	Id   uint32 `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*Node) Descriptor deprecated 

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

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetId 

func (x *Node) GetId() uint32

func (*Node) GetIp 

func (x *Node) GetIp() string

func (*Node) GetPort 

func (x *Node) GetPort() uint32

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect 

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

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) String 

func (x *Node) String() string

type OpType 

type OpType int32
const (
	OpType_Read   OpType = 0
	OpType_Insert OpType = 1
	OpType_Update OpType = 2
	OpType_Delete OpType = 3
)

func (OpType) Descriptor 

func (OpType) Descriptor() protoreflect.EnumDescriptor

func (OpType) Enum 

func (x OpType) Enum() *OpType

func (OpType) EnumDescriptor deprecated 

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

Deprecated: Use OpType.Descriptor instead.

func (OpType) Number 

func (x OpType) Number() protoreflect.EnumNumber

func (OpType) String 

func (x OpType) String() string

func (OpType) Type 

func (OpType) Type() protoreflect.EnumType

type Ping 

type Ping struct {
	From int32 `protobuf:"varint,1,opt,name=from,proto3" json:"from,omitempty"`
	To   int32 `protobuf:"varint,2,opt,name=to,proto3" json:"to,omitempty"`
	// contains filtered or unexported fields
}

func (*Ping) Descriptor deprecated 

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

Deprecated: Use Ping.ProtoReflect.Descriptor instead.

func (*Ping) GetFrom 

func (x *Ping) GetFrom() int32

func (*Ping) GetTo 

func (x *Ping) GetTo() int32

func (*Ping) ProtoMessage 

func (*Ping) ProtoMessage()

func (*Ping) ProtoReflect 

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

func (*Ping) Reset 

func (x *Ping) Reset()

func (*Ping) String 

func (x *Ping) String() string

type Pong 

type Pong struct {
	From    int32 `protobuf:"varint,1,opt,name=from,proto3" json:"from,omitempty"`
	To      int32 `protobuf:"varint,2,opt,name=to,proto3" json:"to,omitempty"`
	Time    int64 `protobuf:"varint,3,opt,name=time,proto3" json:"time,omitempty"`
	EpochId int64 `protobuf:"varint,4,opt,name=epoch_id,json=epochId,proto3" json:"epoch_id,omitempty"`
	// contains filtered or unexported fields
}

* For debugging and testing purposes

func (*Pong) Descriptor deprecated 

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

Deprecated: Use Pong.ProtoReflect.Descriptor instead.

func (*Pong) GetEpochId 

func (x *Pong) GetEpochId() int64

func (*Pong) GetFrom 

func (x *Pong) GetFrom() int32

func (*Pong) GetTime 

func (x *Pong) GetTime() int64

func (*Pong) GetTo 

func (x *Pong) GetTo() int32

func (*Pong) ProtoMessage 

func (*Pong) ProtoMessage()

func (*Pong) ProtoReflect 

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

func (*Pong) Reset 

func (x *Pong) Reset()

func (*Pong) String 

func (x *Pong) String() string

type RaftAcceptRequest 

type RaftAcceptRequest struct {
	From    uint32 `protobuf:"varint,1,opt,name=from,proto3" json:"from,omitempty"`
	To      uint32 `protobuf:"varint,2,opt,name=to,proto3" json:"to,omitempty"`
	EpochId uint64 `protobuf:"varint,3,opt,name=epoch_id,json=epochId,proto3" json:"epoch_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RaftAcceptRequest) Descriptor deprecated 

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

Deprecated: Use RaftAcceptRequest.ProtoReflect.Descriptor instead.

func (*RaftAcceptRequest) GetEpochId 

func (x *RaftAcceptRequest) GetEpochId() uint64

func (*RaftAcceptRequest) GetFrom 

func (x *RaftAcceptRequest) GetFrom() uint32

func (*RaftAcceptRequest) GetTo 

func (x *RaftAcceptRequest) GetTo() uint32

func (*RaftAcceptRequest) ProtoMessage 

func (*RaftAcceptRequest) ProtoMessage()

func (*RaftAcceptRequest) ProtoReflect 

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

func (*RaftAcceptRequest) Reset 

func (x *RaftAcceptRequest) Reset()

func (*RaftAcceptRequest) String 

func (x *RaftAcceptRequest) String() string

type RaftAcceptResponse 

type RaftAcceptResponse struct {
	From    uint32 `protobuf:"varint,1,opt,name=from,proto3" json:"from,omitempty"`
	To      uint32 `protobuf:"varint,2,opt,name=to,proto3" json:"to,omitempty"`
	EpochId uint64 `protobuf:"varint,3,opt,name=epoch_id,json=epochId,proto3" json:"epoch_id,omitempty"`
	Result  uint32 `protobuf:"varint,4,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*RaftAcceptResponse) Descriptor deprecated 

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

Deprecated: Use RaftAcceptResponse.ProtoReflect.Descriptor instead.

func (*RaftAcceptResponse) GetEpochId 

func (x *RaftAcceptResponse) GetEpochId() uint64

func (*RaftAcceptResponse) GetFrom 

func (x *RaftAcceptResponse) GetFrom() uint32

func (*RaftAcceptResponse) GetResult 

func (x *RaftAcceptResponse) GetResult() uint32

func (*RaftAcceptResponse) GetTo 

func (x *RaftAcceptResponse) GetTo() uint32

func (*RaftAcceptResponse) ProtoMessage 

func (*RaftAcceptResponse) ProtoMessage()

func (*RaftAcceptResponse) ProtoReflect 

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

func (*RaftAcceptResponse) Reset 

func (x *RaftAcceptResponse) Reset()

func (*RaftAcceptResponse) String 

func (x *RaftAcceptResponse) String() string

type RaftCommitRequest 

type RaftCommitRequest struct {
	From    uint32 `protobuf:"varint,1,opt,name=from,proto3" json:"from,omitempty"`
	To      uint32 `protobuf:"varint,2,opt,name=to,proto3" json:"to,omitempty"`
	EpochId uint64 `protobuf:"varint,3,opt,name=epoch_id,json=epochId,proto3" json:"epoch_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RaftCommitRequest) Descriptor deprecated 

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

Deprecated: Use RaftCommitRequest.ProtoReflect.Descriptor instead.

func (*RaftCommitRequest) GetEpochId 

func (x *RaftCommitRequest) GetEpochId() uint64

func (*RaftCommitRequest) GetFrom 

func (x *RaftCommitRequest) GetFrom() uint32

func (*RaftCommitRequest) GetTo 

func (x *RaftCommitRequest) GetTo() uint32

func (*RaftCommitRequest) ProtoMessage 

func (*RaftCommitRequest) ProtoMessage()

func (*RaftCommitRequest) ProtoReflect 

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

func (*RaftCommitRequest) Reset 

func (x *RaftCommitRequest) Reset()

func (*RaftCommitRequest) String 

func (x *RaftCommitRequest) String() string

type RaftCommitResponse 

type RaftCommitResponse struct {
	From    uint32 `protobuf:"varint,1,opt,name=from,proto3" json:"from,omitempty"`
	To      uint32 `protobuf:"varint,2,opt,name=to,proto3" json:"to,omitempty"`
	EpochId uint64 `protobuf:"varint,3,opt,name=epoch_id,json=epochId,proto3" json:"epoch_id,omitempty"`
	Result  uint32 `protobuf:"varint,4,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*RaftCommitResponse) Descriptor deprecated 

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

Deprecated: Use RaftCommitResponse.ProtoReflect.Descriptor instead.

func (*RaftCommitResponse) GetEpochId 

func (x *RaftCommitResponse) GetEpochId() uint64

func (*RaftCommitResponse) GetFrom 

func (x *RaftCommitResponse) GetFrom() uint32

func (*RaftCommitResponse) GetResult 

func (x *RaftCommitResponse) GetResult() uint32

func (*RaftCommitResponse) GetTo 

func (x *RaftCommitResponse) GetTo() uint32

func (*RaftCommitResponse) ProtoMessage 

func (*RaftCommitResponse) ProtoMessage()

func (*RaftCommitResponse) ProtoReflect 

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

func (*RaftCommitResponse) Reset 

func (x *RaftCommitResponse) Reset()

func (*RaftCommitResponse) String 

func (x *RaftCommitResponse) String() string

type RaftPropose 

type RaftPropose struct {
	Value uint64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*RaftPropose) Descriptor deprecated 

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

Deprecated: Use RaftPropose.ProtoReflect.Descriptor instead.

func (*RaftPropose) GetValue 

func (x *RaftPropose) GetValue() uint64

func (*RaftPropose) ProtoMessage 

func (*RaftPropose) ProtoMessage()

func (*RaftPropose) ProtoReflect 

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

func (*RaftPropose) Reset 

func (x *RaftPropose) Reset()

func (*RaftPropose) String 

func (x *RaftPropose) String() string

type RaftRequest 

type RaftRequest struct {

	// Types that are assignable to Type:
	//	*RaftRequest_Ping
	//	*RaftRequest_Signal
	//	*RaftRequest_LookupMaster
	//	*RaftRequest_ForwardEpoch
	//	*RaftRequest_EpochReplicationAck
	//	*RaftRequest_RaftPropose
	//	*RaftRequest_RaftAccept
	//	*RaftRequest_RaftCommit
	//	*RaftRequest_Stats
	//	*RaftRequest_ChangeServerState
	Type isRaftRequest_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*RaftRequest) Descriptor deprecated 

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

Deprecated: Use RaftRequest.ProtoReflect.Descriptor instead.

func (*RaftRequest) GetChangeServerState 

func (x *RaftRequest) GetChangeServerState() *ChangeServerStateRequest

func (*RaftRequest) GetEpochReplicationAck 

func (x *RaftRequest) GetEpochReplicationAck() *EpochReplicationAck

func (*RaftRequest) GetForwardEpoch 

func (x *RaftRequest) GetForwardEpoch() *ForwardEpochRequest

func (*RaftRequest) GetLookupMaster 

func (x *RaftRequest) GetLookupMaster() *LookupMasterRequest

func (*RaftRequest) GetPing 

func (x *RaftRequest) GetPing() *Ping

func (*RaftRequest) GetRaftAccept 

func (x *RaftRequest) GetRaftAccept() *RaftAcceptRequest

func (*RaftRequest) GetRaftCommit 

func (x *RaftRequest) GetRaftCommit() *RaftCommitRequest

func (*RaftRequest) GetRaftPropose 

func (x *RaftRequest) GetRaftPropose() *RaftPropose

func (*RaftRequest) GetSignal 

func (x *RaftRequest) GetSignal() *Signal

func (*RaftRequest) GetStats 

func (x *RaftRequest) GetStats() *StatsRequest

func (*RaftRequest) GetType 

func (m *RaftRequest) GetType() isRaftRequest_Type

func (*RaftRequest) ProtoMessage 

func (*RaftRequest) ProtoMessage()

func (*RaftRequest) ProtoReflect 

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

func (*RaftRequest) Reset 

func (x *RaftRequest) Reset()

func (*RaftRequest) String 

func (x *RaftRequest) String() string

type RaftRequest_ChangeServerState 

type RaftRequest_ChangeServerState struct {
	ChangeServerState *ChangeServerStateRequest `protobuf:"bytes,10,opt,name=change_server_state,json=changeServerState,proto3,oneof"`
}

type RaftRequest_EpochReplicationAck 

type RaftRequest_EpochReplicationAck struct {
	EpochReplicationAck *EpochReplicationAck `protobuf:"bytes,5,opt,name=epoch_replication_ack,json=epochReplicationAck,proto3,oneof"`
}

type RaftRequest_ForwardEpoch 

type RaftRequest_ForwardEpoch struct {
	ForwardEpoch *ForwardEpochRequest `protobuf:"bytes,4,opt,name=forward_epoch,json=forwardEpoch,proto3,oneof"`
}

type RaftRequest_LookupMaster 

type RaftRequest_LookupMaster struct {
	LookupMaster *LookupMasterRequest `protobuf:"bytes,3,opt,name=lookup_master,json=lookupMaster,proto3,oneof"`
}

type RaftRequest_Ping 

type RaftRequest_Ping struct {
	Ping *Ping `protobuf:"bytes,1,opt,name=ping,proto3,oneof"`
}

type RaftRequest_RaftAccept 

type RaftRequest_RaftAccept struct {
	RaftAccept *RaftAcceptRequest `protobuf:"bytes,7,opt,name=raft_accept,json=raftAccept,proto3,oneof"`
}

type RaftRequest_RaftCommit 

type RaftRequest_RaftCommit struct {
	RaftCommit *RaftCommitRequest `protobuf:"bytes,8,opt,name=raft_commit,json=raftCommit,proto3,oneof"`
}

type RaftRequest_RaftPropose 

type RaftRequest_RaftPropose struct {
	RaftPropose *RaftPropose `protobuf:"bytes,6,opt,name=raft_propose,json=raftPropose,proto3,oneof"`
}

type RaftRequest_Signal 

type RaftRequest_Signal struct {
	Signal *Signal `protobuf:"bytes,2,opt,name=signal,proto3,oneof"`
}

type RaftRequest_Stats 

type RaftRequest_Stats struct {
	Stats *StatsRequest `protobuf:"bytes,9,opt,name=stats,proto3,oneof"`
}

type RaftResponse 

type RaftResponse struct {

	// Types that are assignable to Type:
	//	*RaftResponse_Pong
	//	*RaftResponse_LookupMaster
	//	*RaftResponse_RaftAccept
	//	*RaftResponse_RaftCommit
	//	*RaftResponse_Stats
	//	*RaftResponse_ChangeServerState
	Type isRaftResponse_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

* A response is always preceeded by a Request

func (*RaftResponse) Descriptor deprecated 

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

Deprecated: Use RaftResponse.ProtoReflect.Descriptor instead.

func (*RaftResponse) GetChangeServerState 

func (x *RaftResponse) GetChangeServerState() *ChangeServerStateResponse

func (*RaftResponse) GetLookupMaster 

func (x *RaftResponse) GetLookupMaster() *LookupMasterResponse

func (*RaftResponse) GetPong 

func (x *RaftResponse) GetPong() *Pong

func (*RaftResponse) GetRaftAccept 

func (x *RaftResponse) GetRaftAccept() *RaftAcceptResponse

func (*RaftResponse) GetRaftCommit 

func (x *RaftResponse) GetRaftCommit() *RaftCommitResponse

func (*RaftResponse) GetStats 

func (x *RaftResponse) GetStats() *StatsResponse

func (*RaftResponse) GetType 

func (m *RaftResponse) GetType() isRaftResponse_Type

func (*RaftResponse) ProtoMessage 

func (*RaftResponse) ProtoMessage()

func (*RaftResponse) ProtoReflect 

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

func (*RaftResponse) Reset 

func (x *RaftResponse) Reset()

func (*RaftResponse) String 

func (x *RaftResponse) String() string

type RaftResponse_ChangeServerState 

type RaftResponse_ChangeServerState struct {
	ChangeServerState *ChangeServerStateResponse `protobuf:"bytes,6,opt,name=change_server_state,json=changeServerState,proto3,oneof"`
}

type RaftResponse_LookupMaster 

type RaftResponse_LookupMaster struct {
	LookupMaster *LookupMasterResponse `protobuf:"bytes,2,opt,name=lookup_master,json=lookupMaster,proto3,oneof"`
}

type RaftResponse_Pong 

type RaftResponse_Pong struct {
	Pong *Pong `protobuf:"bytes,1,opt,name=pong,proto3,oneof"`
}

type RaftResponse_RaftAccept 

type RaftResponse_RaftAccept struct {
	RaftAccept *RaftAcceptResponse `protobuf:"bytes,3,opt,name=raft_accept,json=raftAccept,proto3,oneof"`
}

type RaftResponse_RaftCommit 

type RaftResponse_RaftCommit struct {
	RaftCommit *RaftCommitResponse `protobuf:"bytes,4,opt,name=raft_commit,json=raftCommit,proto3,oneof"`
}

type RaftResponse_Stats 

type RaftResponse_Stats struct {
	Stats *StatsResponse `protobuf:"bytes,5,opt,name=stats,proto3,oneof"`
}

type ReplyTransactionToClient 

type ReplyTransactionToClient struct {
	ClientTxnId uint64   `protobuf:"varint,1,opt,name=client_txn_id,json=clientTxnId,proto3" json:"client_txn_id,omitempty"`
	TxnState    TxnState `protobuf:"varint,2,opt,name=txn_state,json=txnState,proto3,enum=taas_proto.TxnState" json:"txn_state,omitempty"`
	SendNode    *Node    `protobuf:"bytes,3,opt,name=send_node,json=sendNode,proto3" json:"send_node,omitempty"`
	RecvNode    *Node    `protobuf:"bytes,4,opt,name=recv_node,json=recvNode,proto3" json:"recv_node,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplyTransactionToClient) Descriptor deprecated 

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

Deprecated: Use ReplyTransactionToClient.ProtoReflect.Descriptor instead.

func (*ReplyTransactionToClient) GetClientTxnId 

func (x *ReplyTransactionToClient) GetClientTxnId() uint64

func (*ReplyTransactionToClient) GetRecvNode 

func (x *ReplyTransactionToClient) GetRecvNode() *Node

func (*ReplyTransactionToClient) GetSendNode 

func (x *ReplyTransactionToClient) GetSendNode() *Node

func (*ReplyTransactionToClient) GetTxnState 

func (x *ReplyTransactionToClient) GetTxnState() TxnState

func (*ReplyTransactionToClient) ProtoMessage 

func (*ReplyTransactionToClient) ProtoMessage()

func (*ReplyTransactionToClient) ProtoReflect 

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

func (*ReplyTransactionToClient) Reset 

func (x *ReplyTransactionToClient) Reset()

func (*ReplyTransactionToClient) String 

func (x *ReplyTransactionToClient) String() string

type Result 

type Result int32
const (
	Result_Fail    Result = 0
	Result_Success Result = 1
)

func (Result) Descriptor 

func (Result) Descriptor() protoreflect.EnumDescriptor

func (Result) Enum 

func (x Result) Enum() *Result

func (Result) EnumDescriptor deprecated 

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

Deprecated: Use Result.Descriptor instead.

func (Result) Number 

func (x Result) Number() protoreflect.EnumNumber

func (Result) String 

func (x Result) String() string

func (Result) Type 

func (Result) Type() protoreflect.EnumType

type Row 

type Row struct {
	OpType    OpType    `protobuf:"varint,1,opt,name=op_type,json=opType,proto3,enum=taas_proto.OpType" json:"op_type,omitempty"`
	TableName string    `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	Key       []byte    `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	Data      []byte    `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	Column    []*Column `protobuf:"bytes,5,rep,name=column,proto3" json:"column,omitempty"` // if needed
	Csn       uint64    `protobuf:"varint,6,opt,name=csn,proto3" json:"csn,omitempty"`
	// contains filtered or unexported fields
}

func (*Row) Descriptor deprecated 

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

Deprecated: Use Row.ProtoReflect.Descriptor instead.

func (*Row) GetColumn 

func (x *Row) GetColumn() []*Column

func (*Row) GetCsn 

func (x *Row) GetCsn() uint64

func (*Row) GetData 

func (x *Row) GetData() []byte

func (*Row) GetKey 

func (x *Row) GetKey() []byte

func (*Row) GetOpType 

func (x *Row) GetOpType() OpType

func (*Row) GetTableName 

func (x *Row) GetTableName() string

func (*Row) ProtoMessage 

func (*Row) ProtoMessage()

func (*Row) ProtoReflect 

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

func (*Row) Reset 

func (x *Row) Reset()

func (*Row) String 

func (x *Row) String() string

type Signal 

type Signal struct {
	From int32 `protobuf:"varint,1,opt,name=from,proto3" json:"from,omitempty"`
	// contains filtered or unexported fields
}

* Generic signal message

func (*Signal) Descriptor deprecated 

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

Deprecated: Use Signal.ProtoReflect.Descriptor instead.

func (*Signal) GetFrom 

func (x *Signal) GetFrom() int32

func (*Signal) ProtoMessage 

func (*Signal) ProtoMessage()

func (*Signal) ProtoReflect 

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

func (*Signal) Reset 

func (x *Signal) Reset()

func (*Signal) String 

func (x *Signal) String() string

type StatsRequest 

type StatsRequest struct {
	From  uint32 `protobuf:"varint,1,opt,name=from,proto3" json:"from,omitempty"`
	To    uint32 `protobuf:"varint,2,opt,name=to,proto3" json:"to,omitempty"`
	Level uint32 `protobuf:"varint,3,opt,name=level,proto3" json:"level,omitempty"`
	// contains filtered or unexported fields
}

func (*StatsRequest) Descriptor deprecated 

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

Deprecated: Use StatsRequest.ProtoReflect.Descriptor instead.

func (*StatsRequest) GetFrom 

func (x *StatsRequest) GetFrom() uint32

func (*StatsRequest) GetLevel 

func (x *StatsRequest) GetLevel() uint32

func (*StatsRequest) GetTo 

func (x *StatsRequest) GetTo() uint32

func (*StatsRequest) ProtoMessage 

func (*StatsRequest) ProtoMessage()

func (*StatsRequest) ProtoReflect 

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

func (*StatsRequest) Reset 

func (x *StatsRequest) Reset()

func (*StatsRequest) String 

func (x *StatsRequest) String() string

type StatsResponse 

type StatsResponse struct {
	From    uint32 `protobuf:"varint,1,opt,name=from,proto3" json:"from,omitempty"`
	To      uint64 `protobuf:"varint,2,opt,name=to,proto3" json:"to,omitempty"`
	EpochId uint64 `protobuf:"varint,3,opt,name=epoch_id,json=epochId,proto3" json:"epoch_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StatsResponse) Descriptor deprecated 

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

Deprecated: Use StatsResponse.ProtoReflect.Descriptor instead.

func (*StatsResponse) GetEpochId 

func (x *StatsResponse) GetEpochId() uint64

func (*StatsResponse) GetFrom 

func (x *StatsResponse) GetFrom() uint32

func (*StatsResponse) GetTo 

func (x *StatsResponse) GetTo() uint64

func (*StatsResponse) ProtoMessage 

func (*StatsResponse) ProtoMessage()

func (*StatsResponse) ProtoReflect 

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

func (*StatsResponse) Reset 

func (x *StatsResponse) Reset()

func (*StatsResponse) String 

func (x *StatsResponse) String() string

type StoragePullRequest 

type StoragePullRequest struct {
	EpochId  uint64 `protobuf:"varint,1,opt,name=epoch_id,json=epochId,proto3" json:"epoch_id,omitempty"`
	SendNode *Node  `protobuf:"bytes,2,opt,name=send_node,json=sendNode,proto3" json:"send_node,omitempty"`
	RecvNode *Node  `protobuf:"bytes,3,opt,name=recv_node,json=recvNode,proto3" json:"recv_node,omitempty"`
	// contains filtered or unexported fields
}

func (*StoragePullRequest) Descriptor deprecated 

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

Deprecated: Use StoragePullRequest.ProtoReflect.Descriptor instead.

func (*StoragePullRequest) GetEpochId 

func (x *StoragePullRequest) GetEpochId() uint64

func (*StoragePullRequest) GetRecvNode 

func (x *StoragePullRequest) GetRecvNode() *Node

func (*StoragePullRequest) GetSendNode 

func (x *StoragePullRequest) GetSendNode() *Node

func (*StoragePullRequest) ProtoMessage 

func (*StoragePullRequest) ProtoMessage()

func (*StoragePullRequest) ProtoReflect 

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

func (*StoragePullRequest) Reset 

func (x *StoragePullRequest) Reset()

func (*StoragePullRequest) String 

func (x *StoragePullRequest) String() string

type StoragePullResponse 

type StoragePullResponse struct {
	Result   Result         `protobuf:"varint,1,opt,name=result,proto3,enum=taas_proto.Result" json:"result,omitempty"`
	EpochId  uint64         `protobuf:"varint,2,opt,name=epoch_id,json=epochId,proto3" json:"epoch_id,omitempty"`
	TxnNum   uint64         `protobuf:"varint,3,opt,name=txn_num,json=txnNum,proto3" json:"txn_num,omitempty"`
	Txns     []*Transaction `protobuf:"bytes,4,rep,name=txns,proto3" json:"txns,omitempty"`
	SendNode *Node          `protobuf:"bytes,5,opt,name=send_node,json=sendNode,proto3" json:"send_node,omitempty"`
	RecvNode *Node          `protobuf:"bytes,6,opt,name=recv_node,json=recvNode,proto3" json:"recv_node,omitempty"`
	// contains filtered or unexported fields
}

func (*StoragePullResponse) Descriptor deprecated 

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

Deprecated: Use StoragePullResponse.ProtoReflect.Descriptor instead.

func (*StoragePullResponse) GetEpochId 

func (x *StoragePullResponse) GetEpochId() uint64

func (*StoragePullResponse) GetRecvNode 

func (x *StoragePullResponse) GetRecvNode() *Node

func (*StoragePullResponse) GetResult 

func (x *StoragePullResponse) GetResult() Result

func (*StoragePullResponse) GetSendNode 

func (x *StoragePullResponse) GetSendNode() *Node

func (*StoragePullResponse) GetTxnNum 

func (x *StoragePullResponse) GetTxnNum() uint64

func (*StoragePullResponse) GetTxns 

func (x *StoragePullResponse) GetTxns() []*Transaction

func (*StoragePullResponse) ProtoMessage 

func (*StoragePullResponse) ProtoMessage()

func (*StoragePullResponse) ProtoReflect 

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

func (*StoragePullResponse) Reset 

func (x *StoragePullResponse) Reset()

func (*StoragePullResponse) String 

func (x *StoragePullResponse) String() string

type StoragePushResponse 

type StoragePushResponse struct {
	Result   Result         `protobuf:"varint,1,opt,name=result,proto3,enum=taas_proto.Result" json:"result,omitempty"`
	EpochId  uint64         `protobuf:"varint,2,opt,name=epoch_id,json=epochId,proto3" json:"epoch_id,omitempty"`
	TxnNum   uint64         `protobuf:"varint,3,opt,name=txn_num,json=txnNum,proto3" json:"txn_num,omitempty"`
	Txns     []*Transaction `protobuf:"bytes,4,rep,name=txns,proto3" json:"txns,omitempty"`
	SendNode *Node          `protobuf:"bytes,5,opt,name=send_node,json=sendNode,proto3" json:"send_node,omitempty"`
	RecvNode *Node          `protobuf:"bytes,6,opt,name=recv_node,json=recvNode,proto3" json:"recv_node,omitempty"`
	// contains filtered or unexported fields
}

func (*StoragePushResponse) Descriptor deprecated 

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

Deprecated: Use StoragePushResponse.ProtoReflect.Descriptor instead.

func (*StoragePushResponse) GetEpochId 

func (x *StoragePushResponse) GetEpochId() uint64

func (*StoragePushResponse) GetRecvNode 

func (x *StoragePushResponse) GetRecvNode() *Node

func (*StoragePushResponse) GetResult 

func (x *StoragePushResponse) GetResult() Result

func (*StoragePushResponse) GetSendNode 

func (x *StoragePushResponse) GetSendNode() *Node

func (*StoragePushResponse) GetTxnNum 

func (x *StoragePushResponse) GetTxnNum() uint64

func (*StoragePushResponse) GetTxns 

func (x *StoragePushResponse) GetTxns() []*Transaction

func (*StoragePushResponse) ProtoMessage 

func (*StoragePushResponse) ProtoMessage()

func (*StoragePushResponse) ProtoReflect 

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

func (*StoragePushResponse) Reset 

func (x *StoragePushResponse) Reset()

func (*StoragePushResponse) String 

func (x *StoragePushResponse) String() string

type Transaction 

type Transaction struct {
	Row         []*Row   `protobuf:"bytes,1,rep,name=row,proto3" json:"row,omitempty"`
	StartEpoch  uint64   `protobuf:"varint,2,opt,name=start_epoch,json=startEpoch,proto3" json:"start_epoch,omitempty"`
	CommitEpoch uint64   `protobuf:"varint,3,opt,name=commit_epoch,json=commitEpoch,proto3" json:"commit_epoch,omitempty"`
	Csn         uint64   `protobuf:"varint,4,opt,name=csn,proto3" json:"csn,omitempty"`
	ServerIp    string   `protobuf:"bytes,5,opt,name=server_ip,json=serverIp,proto3" json:"server_ip,omitempty"`             // used to identify which remote server sends this txn to current server
	ServerId    uint32   `protobuf:"varint,6,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`            // used to identify which remote server sends this txn to current server
	ClientIp    string   `protobuf:"bytes,7,opt,name=client_ip,json=clientIp,proto3" json:"client_ip,omitempty"`             // used to identify which client sends this txn to current server
	ClientTxnId uint64   `protobuf:"varint,8,opt,name=client_txn_id,json=clientTxnId,proto3" json:"client_txn_id,omitempty"` // used to identify which txn it is in client
	TxnType     TxnType  `protobuf:"varint,9,opt,name=txn_type,json=txnType,proto3,enum=taas_proto.TxnType" json:"txn_type,omitempty"`
	TxnState    TxnState `protobuf:"varint,10,opt,name=txn_state,json=txnState,proto3,enum=taas_proto.TxnState" json:"txn_state,omitempty"`
	ShardingId  uint64   `protobuf:"varint,11,opt,name=sharding_id,json=shardingId,proto3" json:"sharding_id,omitempty"`
	// contains filtered or unexported fields
}

func (*Transaction) Descriptor deprecated 

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

Deprecated: Use Transaction.ProtoReflect.Descriptor instead.

func (*Transaction) GetClientIp 

func (x *Transaction) GetClientIp() string

func (*Transaction) GetClientTxnId 

func (x *Transaction) GetClientTxnId() uint64

func (*Transaction) GetCommitEpoch 

func (x *Transaction) GetCommitEpoch() uint64

func (*Transaction) GetCsn 

func (x *Transaction) GetCsn() uint64

func (*Transaction) GetRow 

func (x *Transaction) GetRow() []*Row

func (*Transaction) GetServerId 

func (x *Transaction) GetServerId() uint32

func (*Transaction) GetServerIp 

func (x *Transaction) GetServerIp() string

func (*Transaction) GetShardingId 

func (x *Transaction) GetShardingId() uint64

func (*Transaction) GetStartEpoch 

func (x *Transaction) GetStartEpoch() uint64

func (*Transaction) GetTxnState 

func (x *Transaction) GetTxnState() TxnState

func (*Transaction) GetTxnType 

func (x *Transaction) GetTxnType() TxnType

func (*Transaction) ProtoMessage 

func (*Transaction) ProtoMessage()

func (*Transaction) ProtoReflect 

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

func (*Transaction) Reset 

func (x *Transaction) Reset()

func (*Transaction) String 

func (x *Transaction) String() string

type TxnState 

type TxnState int32
const (
	TxnState_Empty  TxnState = 0
	TxnState_Abort  TxnState = 1
	TxnState_Commit TxnState = 2
)

func (TxnState) Descriptor 

func (TxnState) Descriptor() protoreflect.EnumDescriptor

func (TxnState) Enum 

func (x TxnState) Enum() *TxnState

func (TxnState) EnumDescriptor deprecated 

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

Deprecated: Use TxnState.Descriptor instead.

func (TxnState) Number 

func (x TxnState) Number() protoreflect.EnumNumber

func (TxnState) String 

func (x TxnState) String() string

func (TxnState) Type 

func (TxnState) Type() protoreflect.EnumType

type TxnType 

type TxnType int32
const (
	TxnType_ClientTxn                TxnType = 0 // client sends to txn
	TxnType_RemoteServerTxn          TxnType = 1 // txn sends to txn, transactions sharding
	TxnType_EpochEndFlag             TxnType = 2 // txn sends to txn, epoch transactions info
	TxnType_CommittedTxn             TxnType = 3 // txn sends to storage , redo log
	TxnType_BackUpTxn                TxnType = 4 // txn sends to txn, transactions backup
	TxnType_BackUpEpochEndFlag       TxnType = 5 // txn sends to txn, transactions backup info
	TxnType_AbortSet                 TxnType = 6 // epoch abort set
	TxnType_InsertSet                TxnType = 7 // epoch insert set backup
	TxnType_EpochShardingACK         TxnType = 8
	TxnType_BackUpACK                TxnType = 9
	TxnType_AbortSetACK              TxnType = 10
	TxnType_InsertSetACK             TxnType = 11
	TxnType_EpochLogPushDownComplete TxnType = 12
	TxnType_NullMark                 TxnType = 13
)

func (TxnType) Descriptor 

func (TxnType) Descriptor() protoreflect.EnumDescriptor

func (TxnType) Enum 

func (x TxnType) Enum() *TxnType

func (TxnType) EnumDescriptor deprecated 

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

Deprecated: Use TxnType.Descriptor instead.

func (TxnType) Number 

func (x TxnType) Number() protoreflect.EnumNumber

func (TxnType) String 

func (x TxnType) String() string

func (TxnType) Type 

func (TxnType) Type() protoreflect.EnumType

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.