rpc

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: Mar 9, 2022 License: Apache-2.0 Imports: 9 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRpc = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRpc   = fmt.Errorf("proto: integer overflow")
)
View Source 
var AdminCmdType_name = map[int32]string{
	0: "ConfigChange",
	1: "CompactLog",
	2: "TransferLeader",
	3: "ComputeHash",
	4: "VerifyHash",
	5: "BatchSplit",
	6: "UpdateMetadata",
	7: "UpdateLabels",
}
View Source 
var AdminCmdType_value = map[string]int32{
	"ConfigChange":   0,
	"CompactLog":     1,
	"TransferLeader": 2,
	"ComputeHash":    3,
	"VerifyHash":     4,
	"BatchSplit":     5,
	"UpdateMetadata": 6,
	"UpdateLabels":   7,
}
View Source 
var CmdType_name = map[int32]string{
	0: "Write",
	1: "Read",
	2: "Admin",
}
View Source 
var CmdType_value = map[string]int32{
	"Write": 0,
	"Read":  1,
	"Admin": 2,
}
View Source 
var UpdatePolicy_name = map[int32]string{
	0: "Add",
	1: "Remove",
	2: "Reset",
	3: "Clear",
}
View Source 
var UpdatePolicy_value = map[string]int32{
	"Add":    0,
	"Remove": 1,
	"Reset":  2,
	"Clear":  3,
}

Functions

This section is empty.

Types

type AdminCmdType 

type AdminCmdType int32

AdminCmdType admin cmd type 

const (
	AdminCmdType_ConfigChange   AdminCmdType = 0
	AdminCmdType_CompactLog     AdminCmdType = 1
	AdminCmdType_TransferLeader AdminCmdType = 2
	AdminCmdType_ComputeHash    AdminCmdType = 3
	AdminCmdType_VerifyHash     AdminCmdType = 4
	AdminCmdType_BatchSplit     AdminCmdType = 5
	AdminCmdType_UpdateMetadata AdminCmdType = 6
	AdminCmdType_UpdateLabels   AdminCmdType = 7
)

func (AdminCmdType) EnumDescriptor 

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

func (AdminCmdType) String 

func (x AdminCmdType) String() string

type BatchSplitRequest 

type BatchSplitRequest struct {
	// The requests for splitting a shard into multiple shards.
	// We split Shard A [0, 10) into B [0, 5) and C [5, 10), the len(requests) = 2, and
	// Shard A will not used after split completed.
	Requests             []SplitRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests"`
	Context              []byte         `protobuf:"bytes,2,opt,name=context,proto3" json:"context,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

BatchSplitRequest batch split requests.

func (*BatchSplitRequest) Descriptor 

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

func (*BatchSplitRequest) GetContext 

func (m *BatchSplitRequest) GetContext() []byte

func (*BatchSplitRequest) GetRequests 

func (m *BatchSplitRequest) GetRequests() []SplitRequest

func (*BatchSplitRequest) Marshal 

func (m *BatchSplitRequest) Marshal() (dAtA []byte, err error)

func (*BatchSplitRequest) MarshalTo 

func (m *BatchSplitRequest) MarshalTo(dAtA []byte) (int, error)

func (*BatchSplitRequest) ProtoMessage 

func (*BatchSplitRequest) ProtoMessage()

func (*BatchSplitRequest) Reset 

func (m *BatchSplitRequest) Reset()

func (*BatchSplitRequest) Size 

func (m *BatchSplitRequest) Size() (n int)

func (*BatchSplitRequest) String 

func (m *BatchSplitRequest) String() string

func (*BatchSplitRequest) Unmarshal 

func (m *BatchSplitRequest) Unmarshal(dAtA []byte) error

func (*BatchSplitRequest) XXX_DiscardUnknown 

func (m *BatchSplitRequest) XXX_DiscardUnknown()

func (*BatchSplitRequest) XXX_Marshal 

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

func (*BatchSplitRequest) XXX_Merge 

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

func (*BatchSplitRequest) XXX_Size 

func (m *BatchSplitRequest) XXX_Size() int

func (*BatchSplitRequest) XXX_Unmarshal 

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

type BatchSplitResponse 

type BatchSplitResponse struct {
	Shards               []meta.Shard `protobuf:"bytes,1,rep,name=shards,proto3" json:"shards"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*BatchSplitResponse) Descriptor 

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

func (*BatchSplitResponse) GetShards 

func (m *BatchSplitResponse) GetShards() []meta.Shard

func (*BatchSplitResponse) Marshal 

func (m *BatchSplitResponse) Marshal() (dAtA []byte, err error)

func (*BatchSplitResponse) MarshalTo 

func (m *BatchSplitResponse) MarshalTo(dAtA []byte) (int, error)

func (*BatchSplitResponse) ProtoMessage 

func (*BatchSplitResponse) ProtoMessage()

func (*BatchSplitResponse) Reset 

func (m *BatchSplitResponse) Reset()

func (*BatchSplitResponse) Size 

func (m *BatchSplitResponse) Size() (n int)

func (*BatchSplitResponse) String 

func (m *BatchSplitResponse) String() string

func (*BatchSplitResponse) Unmarshal 

func (m *BatchSplitResponse) Unmarshal(dAtA []byte) error

func (*BatchSplitResponse) XXX_DiscardUnknown 

func (m *BatchSplitResponse) XXX_DiscardUnknown()

func (*BatchSplitResponse) XXX_Marshal 

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

func (*BatchSplitResponse) XXX_Merge 

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

func (*BatchSplitResponse) XXX_Size 

func (m *BatchSplitResponse) XXX_Size() int

func (*BatchSplitResponse) XXX_Unmarshal 

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

type CmdType 

type CmdType int32
const (
	CmdType_Write CmdType = 0
	CmdType_Read  CmdType = 1
	CmdType_Admin CmdType = 2
)

func (CmdType) EnumDescriptor 

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

func (CmdType) String 

func (x CmdType) String() string

type CompactLogRequest 

type CompactLogRequest struct {
	CompactIndex         uint64   `protobuf:"varint,1,opt,name=compactIndex,proto3" json:"compactIndex,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CompactLogRequest compact raft log

func (*CompactLogRequest) Descriptor 

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

func (*CompactLogRequest) GetCompactIndex 

func (m *CompactLogRequest) GetCompactIndex() uint64

func (*CompactLogRequest) Marshal 

func (m *CompactLogRequest) Marshal() (dAtA []byte, err error)

func (*CompactLogRequest) MarshalTo 

func (m *CompactLogRequest) MarshalTo(dAtA []byte) (int, error)

func (*CompactLogRequest) ProtoMessage 

func (*CompactLogRequest) ProtoMessage()

func (*CompactLogRequest) Reset 

func (m *CompactLogRequest) Reset()

func (*CompactLogRequest) Size 

func (m *CompactLogRequest) Size() (n int)

func (*CompactLogRequest) String 

func (m *CompactLogRequest) String() string

func (*CompactLogRequest) Unmarshal 

func (m *CompactLogRequest) Unmarshal(dAtA []byte) error

func (*CompactLogRequest) XXX_DiscardUnknown 

func (m *CompactLogRequest) XXX_DiscardUnknown()

func (*CompactLogRequest) XXX_Marshal 

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

func (*CompactLogRequest) XXX_Merge 

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

func (*CompactLogRequest) XXX_Size 

func (m *CompactLogRequest) XXX_Size() int

func (*CompactLogRequest) XXX_Unmarshal 

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

type CompactLogResponse 

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

CompactLogResponse compact raft log

func (*CompactLogResponse) Descriptor 

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

func (*CompactLogResponse) Marshal 

func (m *CompactLogResponse) Marshal() (dAtA []byte, err error)

func (*CompactLogResponse) MarshalTo 

func (m *CompactLogResponse) MarshalTo(dAtA []byte) (int, error)

func (*CompactLogResponse) ProtoMessage 

func (*CompactLogResponse) ProtoMessage()

func (*CompactLogResponse) Reset 

func (m *CompactLogResponse) Reset()

func (*CompactLogResponse) Size 

func (m *CompactLogResponse) Size() (n int)

func (*CompactLogResponse) String 

func (m *CompactLogResponse) String() string

func (*CompactLogResponse) Unmarshal 

func (m *CompactLogResponse) Unmarshal(dAtA []byte) error

func (*CompactLogResponse) XXX_DiscardUnknown 

func (m *CompactLogResponse) XXX_DiscardUnknown()

func (*CompactLogResponse) XXX_Marshal 

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

func (*CompactLogResponse) XXX_Merge 

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

func (*CompactLogResponse) XXX_Size 

func (m *CompactLogResponse) XXX_Size() int

func (*CompactLogResponse) XXX_Unmarshal 

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

type ConfigChangeRequest 

type ConfigChangeRequest struct {
	// This can be only called in internal RaftStore now.
	ChangeType           metapb.ConfigChangeType `protobuf:"varint,1,opt,name=changeType,proto3,enum=metapb.ConfigChangeType" json:"changeType,omitempty"`
	Replica              metapb.Replica          `protobuf:"bytes,2,opt,name=replica,proto3" json:"replica"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

func (*ConfigChangeRequest) Descriptor 

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

func (*ConfigChangeRequest) GetChangeType 

func (m *ConfigChangeRequest) GetChangeType() metapb.ConfigChangeType

func (*ConfigChangeRequest) GetReplica 

func (m *ConfigChangeRequest) GetReplica() metapb.Replica

func (*ConfigChangeRequest) Marshal 

func (m *ConfigChangeRequest) Marshal() (dAtA []byte, err error)

func (*ConfigChangeRequest) MarshalTo 

func (m *ConfigChangeRequest) MarshalTo(dAtA []byte) (int, error)

func (*ConfigChangeRequest) ProtoMessage 

func (*ConfigChangeRequest) ProtoMessage()

func (*ConfigChangeRequest) Reset 

func (m *ConfigChangeRequest) Reset()

func (*ConfigChangeRequest) Size 

func (m *ConfigChangeRequest) Size() (n int)

func (*ConfigChangeRequest) String 

func (m *ConfigChangeRequest) String() string

func (*ConfigChangeRequest) Unmarshal 

func (m *ConfigChangeRequest) Unmarshal(dAtA []byte) error

func (*ConfigChangeRequest) XXX_DiscardUnknown 

func (m *ConfigChangeRequest) XXX_DiscardUnknown()

func (*ConfigChangeRequest) XXX_Marshal 

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

func (*ConfigChangeRequest) XXX_Merge 

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

func (*ConfigChangeRequest) XXX_Size 

func (m *ConfigChangeRequest) XXX_Size() int

func (*ConfigChangeRequest) XXX_Unmarshal 

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

type ConfigChangeResponse 

type ConfigChangeResponse struct {
	Shard                meta.Shard `protobuf:"bytes,1,opt,name=shard,proto3" json:"shard"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

ConfigChangeResponse change peer response

func (*ConfigChangeResponse) Descriptor 

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

func (*ConfigChangeResponse) GetShard 

func (m *ConfigChangeResponse) GetShard() meta.Shard

func (*ConfigChangeResponse) Marshal 

func (m *ConfigChangeResponse) Marshal() (dAtA []byte, err error)

func (*ConfigChangeResponse) MarshalTo 

func (m *ConfigChangeResponse) MarshalTo(dAtA []byte) (int, error)

func (*ConfigChangeResponse) ProtoMessage 

func (*ConfigChangeResponse) ProtoMessage()

func (*ConfigChangeResponse) Reset 

func (m *ConfigChangeResponse) Reset()

func (*ConfigChangeResponse) Size 

func (m *ConfigChangeResponse) Size() (n int)

func (*ConfigChangeResponse) String 

func (m *ConfigChangeResponse) String() string

func (*ConfigChangeResponse) Unmarshal 

func (m *ConfigChangeResponse) Unmarshal(dAtA []byte) error

func (*ConfigChangeResponse) XXX_DiscardUnknown 

func (m *ConfigChangeResponse) XXX_DiscardUnknown()

func (*ConfigChangeResponse) XXX_Marshal 

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

func (*ConfigChangeResponse) XXX_Merge 

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

func (*ConfigChangeResponse) XXX_Size 

func (m *ConfigChangeResponse) XXX_Size() int

func (*ConfigChangeResponse) XXX_Unmarshal 

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

type Request 

type Request struct {
	ID                   []byte               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Group                uint64               `protobuf:"varint,2,opt,name=group,proto3" json:"group,omitempty"`
	Type                 CmdType              `protobuf:"varint,3,opt,name=type,proto3,enum=rpc.CmdType" json:"type,omitempty"`
	CustomType           uint64               `protobuf:"varint,4,opt,name=customType,proto3" json:"customType,omitempty"`
	Key                  []byte               `protobuf:"bytes,5,opt,name=key,proto3" json:"key,omitempty"`
	Cmd                  []byte               `protobuf:"bytes,6,opt,name=cmd,proto3" json:"cmd,omitempty"`
	PID                  int64                `protobuf:"varint,7,opt,name=pid,proto3" json:"pid,omitempty"`
	StopAt               int64                `protobuf:"varint,8,opt,name=stopAt,proto3" json:"stopAt,omitempty"`
	ToShard              uint64               `protobuf:"varint,9,opt,name=toShard,proto3" json:"toShard,omitempty"`
	IgnoreEpochCheck     bool                 `protobuf:"varint,10,opt,name=ignoreEpochCheck,proto3" json:"ignoreEpochCheck,omitempty"`
	Epoch                metapb.ResourceEpoch `protobuf:"bytes,11,opt,name=epoch,proto3" json:"epoch"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Request request

func (*Request) Descriptor 

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

func (*Request) GetCmd 

func (m *Request) GetCmd() []byte

func (*Request) GetCustomType 

func (m *Request) GetCustomType() uint64

func (*Request) GetEpoch 

func (m *Request) GetEpoch() metapb.ResourceEpoch

func (*Request) GetGroup 

func (m *Request) GetGroup() uint64

func (*Request) GetID 

func (m *Request) GetID() []byte

func (*Request) GetIgnoreEpochCheck 

func (m *Request) GetIgnoreEpochCheck() bool

func (*Request) GetKey 

func (m *Request) GetKey() []byte

func (*Request) GetPID 

func (m *Request) GetPID() int64

func (*Request) GetStopAt 

func (m *Request) GetStopAt() int64

func (*Request) GetToShard 

func (m *Request) GetToShard() uint64

func (*Request) GetType 

func (m *Request) GetType() CmdType

func (*Request) Marshal 

func (m *Request) Marshal() (dAtA []byte, err error)

func (*Request) MarshalTo 

func (m *Request) MarshalTo(dAtA []byte) (int, error)

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) Size 

func (m *Request) Size() (n int)

func (*Request) String 

func (m *Request) String() string

func (*Request) Unmarshal 

func (m *Request) Unmarshal(dAtA []byte) error

func (*Request) XXX_DiscardUnknown 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal 

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

func (*Request) XXX_Merge 

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

func (*Request) XXX_Size 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal 

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

type RequestBatch 

type RequestBatch struct {
	Header               RequestBatchHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"`
	Requests             []Request          `protobuf:"bytes,2,rep,name=requests,proto3" json:"requests"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

RequestBatch we can't include both normal requests and administrator request at same time.

func (*RequestBatch) Descriptor 

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

func (*RequestBatch) GetAdminCmdType 

func (m *RequestBatch) GetAdminCmdType() AdminCmdType

GetAdminCmdType returns the admin cmd type

func (*RequestBatch) GetAdminRequest 

func (m *RequestBatch) GetAdminRequest() Request

GetAdminRequest returns the admin request

func (*RequestBatch) GetBatchSplitRequest 

func (m *RequestBatch) GetBatchSplitRequest() BatchSplitRequest

GetBatchSplitRequest return BatchSplitRequest request

func (*RequestBatch) GetCompactLogRequest 

func (m *RequestBatch) GetCompactLogRequest() CompactLogRequest

GetCompactLogRequest return CompactLogRequest request

func (*RequestBatch) GetConfigChangeRequest 

func (m *RequestBatch) GetConfigChangeRequest() ConfigChangeRequest

GetConfigChangeRequest return ConfigChangeRequest request

func (*RequestBatch) GetHeader 

func (m *RequestBatch) GetHeader() RequestBatchHeader

func (*RequestBatch) GetRequests 

func (m *RequestBatch) GetRequests() []Request

func (*RequestBatch) GetTransferLeaderRequest 

func (m *RequestBatch) GetTransferLeaderRequest() TransferLeaderRequest

GetTransferLeaderRequest return TransferLeaderRequest request

func (*RequestBatch) GetUpdateLabelsRequest 

func (m *RequestBatch) GetUpdateLabelsRequest() UpdateLabelsRequest

GetUpdateLabelsRequest return UpdateLabelsRequest request

func (*RequestBatch) GetUpdateMetadataRequest 

func (m *RequestBatch) GetUpdateMetadataRequest() UpdateMetadataRequest

GetUpdateMetadataRequest return UpdateMetadataRequest request

func (*RequestBatch) IsAdmin 

func (m *RequestBatch) IsAdmin() bool

IsAdmin returns true if has a admin request

func (*RequestBatch) IsEmpty 

func (m *RequestBatch) IsEmpty() bool

IsEmpty returns true if is a empty batch

func (*RequestBatch) Marshal 

func (m *RequestBatch) Marshal() (dAtA []byte, err error)

func (*RequestBatch) MarshalTo 

func (m *RequestBatch) MarshalTo(dAtA []byte) (int, error)

func (*RequestBatch) ProtoMessage 

func (*RequestBatch) ProtoMessage()

func (*RequestBatch) Reset 

func (m *RequestBatch) Reset()

func (*RequestBatch) Size 

func (m *RequestBatch) Size() (n int)

func (*RequestBatch) String 

func (m *RequestBatch) String() string

func (*RequestBatch) Unmarshal 

func (m *RequestBatch) Unmarshal(dAtA []byte) error

func (*RequestBatch) XXX_DiscardUnknown 

func (m *RequestBatch) XXX_DiscardUnknown()

func (*RequestBatch) XXX_Marshal 

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

func (*RequestBatch) XXX_Merge 

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

func (*RequestBatch) XXX_Size 

func (m *RequestBatch) XXX_Size() int

func (*RequestBatch) XXX_Unmarshal 

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

type RequestBatchHeader 

type RequestBatchHeader struct {
	ID                   []byte         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ShardID              uint64         `protobuf:"varint,2,opt,name=shardID,proto3" json:"shardID,omitempty"`
	Replica              metapb.Replica `protobuf:"bytes,3,opt,name=replica,proto3" json:"replica"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

RequestHeader raft request header, it contains the shard's metadata

func (*RequestBatchHeader) Descriptor 

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

func (*RequestBatchHeader) GetID 

func (m *RequestBatchHeader) GetID() []byte

func (*RequestBatchHeader) GetReplica 

func (m *RequestBatchHeader) GetReplica() metapb.Replica

func (*RequestBatchHeader) GetShardID 

func (m *RequestBatchHeader) GetShardID() uint64

func (*RequestBatchHeader) IsEmpty 

func (m *RequestBatchHeader) IsEmpty() bool

IsEmpty returns true if is a empty header

func (*RequestBatchHeader) Marshal 

func (m *RequestBatchHeader) Marshal() (dAtA []byte, err error)

func (*RequestBatchHeader) MarshalTo 

func (m *RequestBatchHeader) MarshalTo(dAtA []byte) (int, error)

func (*RequestBatchHeader) ProtoMessage 

func (*RequestBatchHeader) ProtoMessage()

func (*RequestBatchHeader) Reset 

func (m *RequestBatchHeader) Reset()

func (*RequestBatchHeader) Size 

func (m *RequestBatchHeader) Size() (n int)

func (*RequestBatchHeader) String 

func (m *RequestBatchHeader) String() string

func (*RequestBatchHeader) Unmarshal 

func (m *RequestBatchHeader) Unmarshal(dAtA []byte) error

func (*RequestBatchHeader) XXX_DiscardUnknown 

func (m *RequestBatchHeader) XXX_DiscardUnknown()

func (*RequestBatchHeader) XXX_Marshal 

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

func (*RequestBatchHeader) XXX_Merge 

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

func (*RequestBatchHeader) XXX_Size 

func (m *RequestBatchHeader) XXX_Size() int

func (*RequestBatchHeader) XXX_Unmarshal 

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

type Response 

type Response struct {
	ID                   []byte        `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type                 CmdType       `protobuf:"varint,2,opt,name=type,proto3,enum=rpc.CmdType" json:"type,omitempty"`
	CustomType           uint64        `protobuf:"varint,3,opt,name=customType,proto3" json:"customType,omitempty"`
	Value                []byte        `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	PID                  int64         `protobuf:"varint,5,opt,name=pid,proto3" json:"pid,omitempty"`
	Error                errorpb.Error `protobuf:"bytes,6,opt,name=error,proto3" json:"error"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

Response response

func (*Response) Descriptor 

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

func (*Response) GetCustomType 

func (m *Response) GetCustomType() uint64

func (*Response) GetError 

func (m *Response) GetError() errorpb.Error

func (*Response) GetID 

func (m *Response) GetID() []byte

func (*Response) GetPID 

func (m *Response) GetPID() int64

func (*Response) GetType 

func (m *Response) GetType() CmdType

func (*Response) GetValue 

func (m *Response) GetValue() []byte

func (*Response) Marshal 

func (m *Response) Marshal() (dAtA []byte, err error)

func (*Response) MarshalTo 

func (m *Response) MarshalTo(dAtA []byte) (int, error)

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) Size 

func (m *Response) Size() (n int)

func (*Response) String 

func (m *Response) String() string

func (*Response) Unmarshal 

func (m *Response) Unmarshal(dAtA []byte) error

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

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

func (*Response) XXX_Merge 

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

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

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

type ResponseBatch 

type ResponseBatch struct {
	Header               ResponseBatchHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"`
	Responses            []Response          `protobuf:"bytes,2,rep,name=responses,proto3" json:"responses"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

ResponseBatch response batch

func (*ResponseBatch) Descriptor 

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

func (*ResponseBatch) GetAdminCmdType 

func (m *ResponseBatch) GetAdminCmdType() AdminCmdType

GetAdminCmdType returns the admin cmd type

func (*ResponseBatch) GetAdminResponse 

func (m *ResponseBatch) GetAdminResponse() Response

GetAdminResponse returns the admin Response

func (*ResponseBatch) GetBatchSplitResponse 

func (m *ResponseBatch) GetBatchSplitResponse() BatchSplitResponse

GetBatchSplitResponse return BatchSplitResponse Response

func (*ResponseBatch) GetCompactLogResponse 

func (m *ResponseBatch) GetCompactLogResponse() CompactLogResponse

GetCompactLogResponse return CompactLogResponse Response

func (*ResponseBatch) GetConfigChangeResponse 

func (m *ResponseBatch) GetConfigChangeResponse() ConfigChangeResponse

GetConfigChangeResponse return ConfigChangeResponse Response

func (*ResponseBatch) GetHeader 

func (m *ResponseBatch) GetHeader() ResponseBatchHeader

func (*ResponseBatch) GetResponses 

func (m *ResponseBatch) GetResponses() []Response

func (*ResponseBatch) GetTransferLeaderResponse 

func (m *ResponseBatch) GetTransferLeaderResponse() TransferLeaderResponse

GetTransferLeaderResponse return TransferLeaderResponse Response

func (*ResponseBatch) GetUpdateLabelsResponse 

func (m *ResponseBatch) GetUpdateLabelsResponse() UpdateLabelsResponse

GetUpdateLabelsResponse return UpdateLabelsResponse Response

func (*ResponseBatch) GetUpdateMetadataResponse 

func (m *ResponseBatch) GetUpdateMetadataResponse() UpdateMetadataResponse

GetUpdateMetadataResponse return UpdateMetadataResponse Response

func (*ResponseBatch) IsAdmin 

func (m *ResponseBatch) IsAdmin() bool

IsAdmin returns true if has a admin request

func (*ResponseBatch) Marshal 

func (m *ResponseBatch) Marshal() (dAtA []byte, err error)

func (*ResponseBatch) MarshalTo 

func (m *ResponseBatch) MarshalTo(dAtA []byte) (int, error)

func (*ResponseBatch) ProtoMessage 

func (*ResponseBatch) ProtoMessage()

func (*ResponseBatch) Reset 

func (m *ResponseBatch) Reset()

func (*ResponseBatch) Size 

func (m *ResponseBatch) Size() (n int)

func (*ResponseBatch) String 

func (m *ResponseBatch) String() string

func (*ResponseBatch) Unmarshal 

func (m *ResponseBatch) Unmarshal(dAtA []byte) error

func (*ResponseBatch) XXX_DiscardUnknown 

func (m *ResponseBatch) XXX_DiscardUnknown()

func (*ResponseBatch) XXX_Marshal 

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

func (*ResponseBatch) XXX_Merge 

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

func (*ResponseBatch) XXX_Size 

func (m *ResponseBatch) XXX_Size() int

func (*ResponseBatch) XXX_Unmarshal 

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

type ResponseBatchHeader 

type ResponseBatchHeader struct {
	ID                   []byte        `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Error                errorpb.Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ResponseBatchHeader) Descriptor 

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

func (*ResponseBatchHeader) GetError 

func (m *ResponseBatchHeader) GetError() errorpb.Error

func (*ResponseBatchHeader) GetID 

func (m *ResponseBatchHeader) GetID() []byte

func (*ResponseBatchHeader) IsEmpty 

func (m *ResponseBatchHeader) IsEmpty() bool

IsEmpty returns true if is a empty header

func (*ResponseBatchHeader) Marshal 

func (m *ResponseBatchHeader) Marshal() (dAtA []byte, err error)

func (*ResponseBatchHeader) MarshalTo 

func (m *ResponseBatchHeader) MarshalTo(dAtA []byte) (int, error)

func (*ResponseBatchHeader) ProtoMessage 

func (*ResponseBatchHeader) ProtoMessage()

func (*ResponseBatchHeader) Reset 

func (m *ResponseBatchHeader) Reset()

func (*ResponseBatchHeader) Size 

func (m *ResponseBatchHeader) Size() (n int)

func (*ResponseBatchHeader) String 

func (m *ResponseBatchHeader) String() string

func (*ResponseBatchHeader) Unmarshal 

func (m *ResponseBatchHeader) Unmarshal(dAtA []byte) error

func (*ResponseBatchHeader) XXX_DiscardUnknown 

func (m *ResponseBatchHeader) XXX_DiscardUnknown()

func (*ResponseBatchHeader) XXX_Marshal 

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

func (*ResponseBatchHeader) XXX_Merge 

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

func (*ResponseBatchHeader) XXX_Size 

func (m *ResponseBatchHeader) XXX_Size() int

func (*ResponseBatchHeader) XXX_Unmarshal 

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

type SplitRequest 

type SplitRequest struct {
	// The start of the sub shard range
	Start []byte `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	// The end of the sub shard range
	End []byte `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"`
	// The new shard id
	NewShardID uint64 `protobuf:"varint,3,opt,name=newShardID,proto3" json:"newShardID,omitempty"`
	// The new replcias of the new shard
	NewReplicas          []metapb.Replica `protobuf:"bytes,4,rep,name=newReplicas,proto3" json:"newReplicas"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*SplitRequest) Descriptor 

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

func (*SplitRequest) GetEnd 

func (m *SplitRequest) GetEnd() []byte

func (*SplitRequest) GetNewReplicas 

func (m *SplitRequest) GetNewReplicas() []metapb.Replica

func (*SplitRequest) GetNewShardID 

func (m *SplitRequest) GetNewShardID() uint64

func (*SplitRequest) GetStart 

func (m *SplitRequest) GetStart() []byte

func (*SplitRequest) Marshal 

func (m *SplitRequest) Marshal() (dAtA []byte, err error)

func (*SplitRequest) MarshalTo 

func (m *SplitRequest) MarshalTo(dAtA []byte) (int, error)

func (*SplitRequest) ProtoMessage 

func (*SplitRequest) ProtoMessage()

func (*SplitRequest) Reset 

func (m *SplitRequest) Reset()

func (*SplitRequest) Size 

func (m *SplitRequest) Size() (n int)

func (*SplitRequest) String 

func (m *SplitRequest) String() string

func (*SplitRequest) Unmarshal 

func (m *SplitRequest) Unmarshal(dAtA []byte) error

func (*SplitRequest) XXX_DiscardUnknown 

func (m *SplitRequest) XXX_DiscardUnknown()

func (*SplitRequest) XXX_Marshal 

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

func (*SplitRequest) XXX_Merge 

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

func (*SplitRequest) XXX_Size 

func (m *SplitRequest) XXX_Size() int

func (*SplitRequest) XXX_Unmarshal 

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

type TransferLeaderRequest 

type TransferLeaderRequest struct {
	Replica              metapb.Replica `protobuf:"bytes,1,opt,name=replica,proto3" json:"replica"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

TransferLeaderRequest transfer leader

func (*TransferLeaderRequest) Descriptor 

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

func (*TransferLeaderRequest) GetReplica 

func (m *TransferLeaderRequest) GetReplica() metapb.Replica

func (*TransferLeaderRequest) Marshal 

func (m *TransferLeaderRequest) Marshal() (dAtA []byte, err error)

func (*TransferLeaderRequest) MarshalTo 

func (m *TransferLeaderRequest) MarshalTo(dAtA []byte) (int, error)

func (*TransferLeaderRequest) ProtoMessage 

func (*TransferLeaderRequest) ProtoMessage()

func (*TransferLeaderRequest) Reset 

func (m *TransferLeaderRequest) Reset()

func (*TransferLeaderRequest) Size 

func (m *TransferLeaderRequest) Size() (n int)

func (*TransferLeaderRequest) String 

func (m *TransferLeaderRequest) String() string

func (*TransferLeaderRequest) Unmarshal 

func (m *TransferLeaderRequest) Unmarshal(dAtA []byte) error

func (*TransferLeaderRequest) XXX_DiscardUnknown 

func (m *TransferLeaderRequest) XXX_DiscardUnknown()

func (*TransferLeaderRequest) XXX_Marshal 

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

func (*TransferLeaderRequest) XXX_Merge 

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

func (*TransferLeaderRequest) XXX_Size 

func (m *TransferLeaderRequest) XXX_Size() int

func (*TransferLeaderRequest) XXX_Unmarshal 

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

type TransferLeaderResponse 

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

func (*TransferLeaderResponse) Descriptor 

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

func (*TransferLeaderResponse) Marshal 

func (m *TransferLeaderResponse) Marshal() (dAtA []byte, err error)

func (*TransferLeaderResponse) MarshalTo 

func (m *TransferLeaderResponse) MarshalTo(dAtA []byte) (int, error)

func (*TransferLeaderResponse) ProtoMessage 

func (*TransferLeaderResponse) ProtoMessage()

func (*TransferLeaderResponse) Reset 

func (m *TransferLeaderResponse) Reset()

func (*TransferLeaderResponse) Size 

func (m *TransferLeaderResponse) Size() (n int)

func (*TransferLeaderResponse) String 

func (m *TransferLeaderResponse) String() string

func (*TransferLeaderResponse) Unmarshal 

func (m *TransferLeaderResponse) Unmarshal(dAtA []byte) error

func (*TransferLeaderResponse) XXX_DiscardUnknown 

func (m *TransferLeaderResponse) XXX_DiscardUnknown()

func (*TransferLeaderResponse) XXX_Marshal 

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

func (*TransferLeaderResponse) XXX_Merge 

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

func (*TransferLeaderResponse) XXX_Size 

func (m *TransferLeaderResponse) XXX_Size() int

func (*TransferLeaderResponse) XXX_Unmarshal 

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

type UpdateLabelsRequest 

type UpdateLabelsRequest struct {
	Labels               []metapb.Pair `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels"`
	Policy               UpdatePolicy  `protobuf:"varint,2,opt,name=policy,proto3,enum=rpc.UpdatePolicy" json:"policy,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*UpdateLabelsRequest) Descriptor 

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

func (*UpdateLabelsRequest) GetLabels 

func (m *UpdateLabelsRequest) GetLabels() []metapb.Pair

func (*UpdateLabelsRequest) GetPolicy 

func (m *UpdateLabelsRequest) GetPolicy() UpdatePolicy

func (*UpdateLabelsRequest) Marshal 

func (m *UpdateLabelsRequest) Marshal() (dAtA []byte, err error)

func (*UpdateLabelsRequest) MarshalTo 

func (m *UpdateLabelsRequest) MarshalTo(dAtA []byte) (int, error)

func (*UpdateLabelsRequest) ProtoMessage 

func (*UpdateLabelsRequest) ProtoMessage()

func (*UpdateLabelsRequest) Reset 

func (m *UpdateLabelsRequest) Reset()

func (*UpdateLabelsRequest) Size 

func (m *UpdateLabelsRequest) Size() (n int)

func (*UpdateLabelsRequest) String 

func (m *UpdateLabelsRequest) String() string

func (*UpdateLabelsRequest) Unmarshal 

func (m *UpdateLabelsRequest) Unmarshal(dAtA []byte) error

func (*UpdateLabelsRequest) XXX_DiscardUnknown 

func (m *UpdateLabelsRequest) XXX_DiscardUnknown()

func (*UpdateLabelsRequest) XXX_Marshal 

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

func (*UpdateLabelsRequest) XXX_Merge 

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

func (*UpdateLabelsRequest) XXX_Size 

func (m *UpdateLabelsRequest) XXX_Size() int

func (*UpdateLabelsRequest) XXX_Unmarshal 

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

type UpdateLabelsResponse 

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

func (*UpdateLabelsResponse) Descriptor 

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

func (*UpdateLabelsResponse) Marshal 

func (m *UpdateLabelsResponse) Marshal() (dAtA []byte, err error)

func (*UpdateLabelsResponse) MarshalTo 

func (m *UpdateLabelsResponse) MarshalTo(dAtA []byte) (int, error)

func (*UpdateLabelsResponse) ProtoMessage 

func (*UpdateLabelsResponse) ProtoMessage()

func (*UpdateLabelsResponse) Reset 

func (m *UpdateLabelsResponse) Reset()

func (*UpdateLabelsResponse) Size 

func (m *UpdateLabelsResponse) Size() (n int)

func (*UpdateLabelsResponse) String 

func (m *UpdateLabelsResponse) String() string

func (*UpdateLabelsResponse) Unmarshal 

func (m *UpdateLabelsResponse) Unmarshal(dAtA []byte) error

func (*UpdateLabelsResponse) XXX_DiscardUnknown 

func (m *UpdateLabelsResponse) XXX_DiscardUnknown()

func (*UpdateLabelsResponse) XXX_Marshal 

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

func (*UpdateLabelsResponse) XXX_Merge 

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

func (*UpdateLabelsResponse) XXX_Size 

func (m *UpdateLabelsResponse) XXX_Size() int

func (*UpdateLabelsResponse) XXX_Unmarshal 

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

type UpdateMetadataRequest 

type UpdateMetadataRequest struct {
	Metadata             meta.ShardLocalState `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*UpdateMetadataRequest) Descriptor 

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

func (*UpdateMetadataRequest) GetMetadata 

func (m *UpdateMetadataRequest) GetMetadata() meta.ShardLocalState

func (*UpdateMetadataRequest) Marshal 

func (m *UpdateMetadataRequest) Marshal() (dAtA []byte, err error)

func (*UpdateMetadataRequest) MarshalTo 

func (m *UpdateMetadataRequest) MarshalTo(dAtA []byte) (int, error)

func (*UpdateMetadataRequest) ProtoMessage 

func (*UpdateMetadataRequest) ProtoMessage()

func (*UpdateMetadataRequest) Reset 

func (m *UpdateMetadataRequest) Reset()

func (*UpdateMetadataRequest) Size 

func (m *UpdateMetadataRequest) Size() (n int)

func (*UpdateMetadataRequest) String 

func (m *UpdateMetadataRequest) String() string

func (*UpdateMetadataRequest) Unmarshal 

func (m *UpdateMetadataRequest) Unmarshal(dAtA []byte) error

func (*UpdateMetadataRequest) XXX_DiscardUnknown 

func (m *UpdateMetadataRequest) XXX_DiscardUnknown()

func (*UpdateMetadataRequest) XXX_Marshal 

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

func (*UpdateMetadataRequest) XXX_Merge 

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

func (*UpdateMetadataRequest) XXX_Size 

func (m *UpdateMetadataRequest) XXX_Size() int

func (*UpdateMetadataRequest) XXX_Unmarshal 

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

type UpdateMetadataResponse 

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

func (*UpdateMetadataResponse) Descriptor 

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

func (*UpdateMetadataResponse) Marshal 

func (m *UpdateMetadataResponse) Marshal() (dAtA []byte, err error)

func (*UpdateMetadataResponse) MarshalTo 

func (m *UpdateMetadataResponse) MarshalTo(dAtA []byte) (int, error)

func (*UpdateMetadataResponse) ProtoMessage 

func (*UpdateMetadataResponse) ProtoMessage()

func (*UpdateMetadataResponse) Reset 

func (m *UpdateMetadataResponse) Reset()

func (*UpdateMetadataResponse) Size 

func (m *UpdateMetadataResponse) Size() (n int)

func (*UpdateMetadataResponse) String 

func (m *UpdateMetadataResponse) String() string

func (*UpdateMetadataResponse) Unmarshal 

func (m *UpdateMetadataResponse) Unmarshal(dAtA []byte) error

func (*UpdateMetadataResponse) XXX_DiscardUnknown 

func (m *UpdateMetadataResponse) XXX_DiscardUnknown()

func (*UpdateMetadataResponse) XXX_Marshal 

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

func (*UpdateMetadataResponse) XXX_Merge 

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

func (*UpdateMetadataResponse) XXX_Size 

func (m *UpdateMetadataResponse) XXX_Size() int

func (*UpdateMetadataResponse) XXX_Unmarshal 

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

type UpdatePolicy 

type UpdatePolicy int32

UpdatePolicy update policy 

const (
	// Add add or update
	UpdatePolicy_Add UpdatePolicy = 0
	// Remove remove
	UpdatePolicy_Remove UpdatePolicy = 1
	// Reset reset
	UpdatePolicy_Reset UpdatePolicy = 2
	// Clear clear
	UpdatePolicy_Clear UpdatePolicy = 3
)

func (UpdatePolicy) EnumDescriptor 

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

func (UpdatePolicy) String 

func (x UpdatePolicy) String() string

type VerifyHashRequest 

type VerifyHashRequest struct {
	Index                uint64   `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Hash                 []byte   `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	Context              []byte   `protobuf:"bytes,3,opt,name=context,proto3" json:"context,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VerifyHashRequest) Descriptor 

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

func (*VerifyHashRequest) GetContext 

func (m *VerifyHashRequest) GetContext() []byte

func (*VerifyHashRequest) GetHash 

func (m *VerifyHashRequest) GetHash() []byte

func (*VerifyHashRequest) GetIndex 

func (m *VerifyHashRequest) GetIndex() uint64

func (*VerifyHashRequest) Marshal 

func (m *VerifyHashRequest) Marshal() (dAtA []byte, err error)

func (*VerifyHashRequest) MarshalTo 

func (m *VerifyHashRequest) MarshalTo(dAtA []byte) (int, error)

func (*VerifyHashRequest) ProtoMessage 

func (*VerifyHashRequest) ProtoMessage()

func (*VerifyHashRequest) Reset 

func (m *VerifyHashRequest) Reset()

func (*VerifyHashRequest) Size 

func (m *VerifyHashRequest) Size() (n int)

func (*VerifyHashRequest) String 

func (m *VerifyHashRequest) String() string

func (*VerifyHashRequest) Unmarshal 

func (m *VerifyHashRequest) Unmarshal(dAtA []byte) error

func (*VerifyHashRequest) XXX_DiscardUnknown 

func (m *VerifyHashRequest) XXX_DiscardUnknown()

func (*VerifyHashRequest) XXX_Marshal 

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

func (*VerifyHashRequest) XXX_Merge 

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

func (*VerifyHashRequest) XXX_Size 

func (m *VerifyHashRequest) XXX_Size() int

func (*VerifyHashRequest) XXX_Unmarshal 

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

type VerifyHashResponse 

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

func (*VerifyHashResponse) Descriptor 

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

func (*VerifyHashResponse) Marshal 

func (m *VerifyHashResponse) Marshal() (dAtA []byte, err error)

func (*VerifyHashResponse) MarshalTo 

func (m *VerifyHashResponse) MarshalTo(dAtA []byte) (int, error)

func (*VerifyHashResponse) ProtoMessage 

func (*VerifyHashResponse) ProtoMessage()

func (*VerifyHashResponse) Reset 

func (m *VerifyHashResponse) Reset()

func (*VerifyHashResponse) Size 

func (m *VerifyHashResponse) Size() (n int)

func (*VerifyHashResponse) String 

func (m *VerifyHashResponse) String() string

func (*VerifyHashResponse) Unmarshal 

func (m *VerifyHashResponse) Unmarshal(dAtA []byte) error

func (*VerifyHashResponse) XXX_DiscardUnknown 

func (m *VerifyHashResponse) XXX_DiscardUnknown()

func (*VerifyHashResponse) XXX_Marshal 

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

func (*VerifyHashResponse) XXX_Merge 

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

func (*VerifyHashResponse) XXX_Size 

func (m *VerifyHashResponse) XXX_Size() int

func (*VerifyHashResponse) XXX_Unmarshal 

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