Versions in this module Expand all Collapse all v0 v0.3.0 Mar 9, 2022 v0.2.0 Jan 5, 2022 Changes in this version + var AdminCmdType_name = map[int32]string + var AdminCmdType_value = map[string]int32 + var CmdType_name = map[int32]string + var CmdType_value = map[string]int32 + var ErrIntOverflowRpc = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthRpc = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupRpc = fmt.Errorf("proto: unexpected end of group") + var UpdatePolicy_name = map[int32]string + var UpdatePolicy_value = map[string]int32 + type AdminCmdType int32 + const AdminCmdType_BatchSplit + const AdminCmdType_CompactLog + const AdminCmdType_ComputeHash + const AdminCmdType_ConfigChange + const AdminCmdType_TransferLeader + const AdminCmdType_UpdateLabels + const AdminCmdType_UpdateMetadata + const AdminCmdType_VerifyHash + func (AdminCmdType) EnumDescriptor() ([]byte, []int) + func (x AdminCmdType) String() string + type BatchSplitRequest struct + Context []byte + Requests []SplitRequest + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BatchSplitRequest) Descriptor() ([]byte, []int) + func (*BatchSplitRequest) ProtoMessage() + func (m *BatchSplitRequest) GetContext() []byte + func (m *BatchSplitRequest) GetRequests() []SplitRequest + func (m *BatchSplitRequest) Marshal() (dAtA []byte, err error) + func (m *BatchSplitRequest) MarshalTo(dAtA []byte) (int, error) + func (m *BatchSplitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchSplitRequest) Reset() + func (m *BatchSplitRequest) Size() (n int) + func (m *BatchSplitRequest) String() string + func (m *BatchSplitRequest) Unmarshal(dAtA []byte) error + func (m *BatchSplitRequest) XXX_DiscardUnknown() + func (m *BatchSplitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BatchSplitRequest) XXX_Merge(src proto.Message) + func (m *BatchSplitRequest) XXX_Size() int + func (m *BatchSplitRequest) XXX_Unmarshal(b []byte) error + type BatchSplitResponse struct + Shards []meta.Shard + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*BatchSplitResponse) Descriptor() ([]byte, []int) + func (*BatchSplitResponse) ProtoMessage() + func (m *BatchSplitResponse) GetShards() []meta.Shard + func (m *BatchSplitResponse) Marshal() (dAtA []byte, err error) + func (m *BatchSplitResponse) MarshalTo(dAtA []byte) (int, error) + func (m *BatchSplitResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *BatchSplitResponse) Reset() + func (m *BatchSplitResponse) Size() (n int) + func (m *BatchSplitResponse) String() string + func (m *BatchSplitResponse) Unmarshal(dAtA []byte) error + func (m *BatchSplitResponse) XXX_DiscardUnknown() + func (m *BatchSplitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *BatchSplitResponse) XXX_Merge(src proto.Message) + func (m *BatchSplitResponse) XXX_Size() int + func (m *BatchSplitResponse) XXX_Unmarshal(b []byte) error + type CmdType int32 + const CmdType_Admin + const CmdType_Read + const CmdType_Write + func (CmdType) EnumDescriptor() ([]byte, []int) + func (x CmdType) String() string + type CompactLogRequest struct + CompactIndex uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CompactLogRequest) Descriptor() ([]byte, []int) + func (*CompactLogRequest) ProtoMessage() + func (m *CompactLogRequest) GetCompactIndex() uint64 + func (m *CompactLogRequest) Marshal() (dAtA []byte, err error) + func (m *CompactLogRequest) MarshalTo(dAtA []byte) (int, error) + func (m *CompactLogRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CompactLogRequest) Reset() + func (m *CompactLogRequest) Size() (n int) + func (m *CompactLogRequest) String() string + func (m *CompactLogRequest) Unmarshal(dAtA []byte) error + func (m *CompactLogRequest) XXX_DiscardUnknown() + func (m *CompactLogRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CompactLogRequest) XXX_Merge(src proto.Message) + func (m *CompactLogRequest) XXX_Size() int + func (m *CompactLogRequest) XXX_Unmarshal(b []byte) error + type CompactLogResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CompactLogResponse) Descriptor() ([]byte, []int) + func (*CompactLogResponse) ProtoMessage() + func (m *CompactLogResponse) Marshal() (dAtA []byte, err error) + func (m *CompactLogResponse) MarshalTo(dAtA []byte) (int, error) + func (m *CompactLogResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *CompactLogResponse) Reset() + func (m *CompactLogResponse) Size() (n int) + func (m *CompactLogResponse) String() string + func (m *CompactLogResponse) Unmarshal(dAtA []byte) error + func (m *CompactLogResponse) XXX_DiscardUnknown() + func (m *CompactLogResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CompactLogResponse) XXX_Merge(src proto.Message) + func (m *CompactLogResponse) XXX_Size() int + func (m *CompactLogResponse) XXX_Unmarshal(b []byte) error + type ConfigChangeRequest struct + ChangeType metapb.ConfigChangeType + Replica metapb.Replica + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ConfigChangeRequest) Descriptor() ([]byte, []int) + func (*ConfigChangeRequest) ProtoMessage() + func (m *ConfigChangeRequest) GetChangeType() metapb.ConfigChangeType + func (m *ConfigChangeRequest) GetReplica() metapb.Replica + func (m *ConfigChangeRequest) Marshal() (dAtA []byte, err error) + func (m *ConfigChangeRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ConfigChangeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ConfigChangeRequest) Reset() + func (m *ConfigChangeRequest) Size() (n int) + func (m *ConfigChangeRequest) String() string + func (m *ConfigChangeRequest) Unmarshal(dAtA []byte) error + func (m *ConfigChangeRequest) XXX_DiscardUnknown() + func (m *ConfigChangeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ConfigChangeRequest) XXX_Merge(src proto.Message) + func (m *ConfigChangeRequest) XXX_Size() int + func (m *ConfigChangeRequest) XXX_Unmarshal(b []byte) error + type ConfigChangeResponse struct + Shard meta.Shard + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ConfigChangeResponse) Descriptor() ([]byte, []int) + func (*ConfigChangeResponse) ProtoMessage() + func (m *ConfigChangeResponse) GetShard() meta.Shard + func (m *ConfigChangeResponse) Marshal() (dAtA []byte, err error) + func (m *ConfigChangeResponse) MarshalTo(dAtA []byte) (int, error) + func (m *ConfigChangeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ConfigChangeResponse) Reset() + func (m *ConfigChangeResponse) Size() (n int) + func (m *ConfigChangeResponse) String() string + func (m *ConfigChangeResponse) Unmarshal(dAtA []byte) error + func (m *ConfigChangeResponse) XXX_DiscardUnknown() + func (m *ConfigChangeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ConfigChangeResponse) XXX_Merge(src proto.Message) + func (m *ConfigChangeResponse) XXX_Size() int + func (m *ConfigChangeResponse) XXX_Unmarshal(b []byte) error + type Request struct + Cmd []byte + CustomType uint64 + Epoch metapb.ResourceEpoch + Group uint64 + ID []byte + IgnoreEpochCheck bool + Key []byte + PID int64 + StopAt int64 + ToShard uint64 + Type CmdType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Request) Descriptor() ([]byte, []int) + func (*Request) ProtoMessage() + func (m *Request) GetCmd() []byte + func (m *Request) GetCustomType() uint64 + func (m *Request) GetEpoch() metapb.ResourceEpoch + func (m *Request) GetGroup() uint64 + func (m *Request) GetID() []byte + func (m *Request) GetIgnoreEpochCheck() bool + func (m *Request) GetKey() []byte + func (m *Request) GetPID() int64 + func (m *Request) GetStopAt() int64 + func (m *Request) GetToShard() uint64 + func (m *Request) GetType() CmdType + func (m *Request) Marshal() (dAtA []byte, err error) + func (m *Request) MarshalTo(dAtA []byte) (int, error) + func (m *Request) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Request) Reset() + func (m *Request) Size() (n int) + func (m *Request) String() string + func (m *Request) Unmarshal(dAtA []byte) error + func (m *Request) XXX_DiscardUnknown() + func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Request) XXX_Merge(src proto.Message) + func (m *Request) XXX_Size() int + func (m *Request) XXX_Unmarshal(b []byte) error + type RequestBatch struct + Header RequestBatchHeader + Requests []Request + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RequestBatch) Descriptor() ([]byte, []int) + func (*RequestBatch) ProtoMessage() + func (m *RequestBatch) GetAdminCmdType() AdminCmdType + func (m *RequestBatch) GetAdminRequest() Request + func (m *RequestBatch) GetBatchSplitRequest() BatchSplitRequest + func (m *RequestBatch) GetCompactLogRequest() CompactLogRequest + func (m *RequestBatch) GetConfigChangeRequest() ConfigChangeRequest + func (m *RequestBatch) GetHeader() RequestBatchHeader + func (m *RequestBatch) GetRequests() []Request + func (m *RequestBatch) GetTransferLeaderRequest() TransferLeaderRequest + func (m *RequestBatch) GetUpdateLabelsRequest() UpdateLabelsRequest + func (m *RequestBatch) GetUpdateMetadataRequest() UpdateMetadataRequest + func (m *RequestBatch) IsAdmin() bool + func (m *RequestBatch) IsEmpty() bool + func (m *RequestBatch) Marshal() (dAtA []byte, err error) + func (m *RequestBatch) MarshalTo(dAtA []byte) (int, error) + func (m *RequestBatch) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RequestBatch) Reset() + func (m *RequestBatch) Size() (n int) + func (m *RequestBatch) String() string + func (m *RequestBatch) Unmarshal(dAtA []byte) error + func (m *RequestBatch) XXX_DiscardUnknown() + func (m *RequestBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RequestBatch) XXX_Merge(src proto.Message) + func (m *RequestBatch) XXX_Size() int + func (m *RequestBatch) XXX_Unmarshal(b []byte) error + type RequestBatchHeader struct + ID []byte + Replica metapb.Replica + ShardID uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*RequestBatchHeader) Descriptor() ([]byte, []int) + func (*RequestBatchHeader) ProtoMessage() + func (m *RequestBatchHeader) GetID() []byte + func (m *RequestBatchHeader) GetReplica() metapb.Replica + func (m *RequestBatchHeader) GetShardID() uint64 + func (m *RequestBatchHeader) IsEmpty() bool + func (m *RequestBatchHeader) Marshal() (dAtA []byte, err error) + func (m *RequestBatchHeader) MarshalTo(dAtA []byte) (int, error) + func (m *RequestBatchHeader) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *RequestBatchHeader) Reset() + func (m *RequestBatchHeader) Size() (n int) + func (m *RequestBatchHeader) String() string + func (m *RequestBatchHeader) Unmarshal(dAtA []byte) error + func (m *RequestBatchHeader) XXX_DiscardUnknown() + func (m *RequestBatchHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *RequestBatchHeader) XXX_Merge(src proto.Message) + func (m *RequestBatchHeader) XXX_Size() int + func (m *RequestBatchHeader) XXX_Unmarshal(b []byte) error + type Response struct + CustomType uint64 + Error errorpb.Error + ID []byte + PID int64 + Type CmdType + Value []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Response) Descriptor() ([]byte, []int) + func (*Response) ProtoMessage() + func (m *Response) GetCustomType() uint64 + func (m *Response) GetError() errorpb.Error + func (m *Response) GetID() []byte + func (m *Response) GetPID() int64 + func (m *Response) GetType() CmdType + func (m *Response) GetValue() []byte + func (m *Response) Marshal() (dAtA []byte, err error) + func (m *Response) MarshalTo(dAtA []byte) (int, error) + func (m *Response) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Response) Reset() + func (m *Response) Size() (n int) + func (m *Response) String() string + func (m *Response) Unmarshal(dAtA []byte) error + func (m *Response) XXX_DiscardUnknown() + func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Response) XXX_Merge(src proto.Message) + func (m *Response) XXX_Size() int + func (m *Response) XXX_Unmarshal(b []byte) error + type ResponseBatch struct + Header ResponseBatchHeader + Responses []Response + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ResponseBatch) Descriptor() ([]byte, []int) + func (*ResponseBatch) ProtoMessage() + func (m *ResponseBatch) GetAdminCmdType() AdminCmdType + func (m *ResponseBatch) GetAdminResponse() Response + func (m *ResponseBatch) GetBatchSplitResponse() BatchSplitResponse + func (m *ResponseBatch) GetCompactLogResponse() CompactLogResponse + func (m *ResponseBatch) GetConfigChangeResponse() ConfigChangeResponse + func (m *ResponseBatch) GetHeader() ResponseBatchHeader + func (m *ResponseBatch) GetResponses() []Response + func (m *ResponseBatch) GetTransferLeaderResponse() TransferLeaderResponse + func (m *ResponseBatch) GetUpdateLabelsResponse() UpdateLabelsResponse + func (m *ResponseBatch) GetUpdateMetadataResponse() UpdateMetadataResponse + func (m *ResponseBatch) IsAdmin() bool + func (m *ResponseBatch) Marshal() (dAtA []byte, err error) + func (m *ResponseBatch) MarshalTo(dAtA []byte) (int, error) + func (m *ResponseBatch) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResponseBatch) Reset() + func (m *ResponseBatch) Size() (n int) + func (m *ResponseBatch) String() string + func (m *ResponseBatch) Unmarshal(dAtA []byte) error + func (m *ResponseBatch) XXX_DiscardUnknown() + func (m *ResponseBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResponseBatch) XXX_Merge(src proto.Message) + func (m *ResponseBatch) XXX_Size() int + func (m *ResponseBatch) XXX_Unmarshal(b []byte) error + type ResponseBatchHeader struct + Error errorpb.Error + ID []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ResponseBatchHeader) Descriptor() ([]byte, []int) + func (*ResponseBatchHeader) ProtoMessage() + func (m *ResponseBatchHeader) GetError() errorpb.Error + func (m *ResponseBatchHeader) GetID() []byte + func (m *ResponseBatchHeader) IsEmpty() bool + func (m *ResponseBatchHeader) Marshal() (dAtA []byte, err error) + func (m *ResponseBatchHeader) MarshalTo(dAtA []byte) (int, error) + func (m *ResponseBatchHeader) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ResponseBatchHeader) Reset() + func (m *ResponseBatchHeader) Size() (n int) + func (m *ResponseBatchHeader) String() string + func (m *ResponseBatchHeader) Unmarshal(dAtA []byte) error + func (m *ResponseBatchHeader) XXX_DiscardUnknown() + func (m *ResponseBatchHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ResponseBatchHeader) XXX_Merge(src proto.Message) + func (m *ResponseBatchHeader) XXX_Size() int + func (m *ResponseBatchHeader) XXX_Unmarshal(b []byte) error + type SplitRequest struct + End []byte + NewReplicas []metapb.Replica + NewShardID uint64 + Start []byte + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*SplitRequest) Descriptor() ([]byte, []int) + func (*SplitRequest) ProtoMessage() + func (m *SplitRequest) GetEnd() []byte + func (m *SplitRequest) GetNewReplicas() []metapb.Replica + func (m *SplitRequest) GetNewShardID() uint64 + func (m *SplitRequest) GetStart() []byte + func (m *SplitRequest) Marshal() (dAtA []byte, err error) + func (m *SplitRequest) MarshalTo(dAtA []byte) (int, error) + func (m *SplitRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SplitRequest) Reset() + func (m *SplitRequest) Size() (n int) + func (m *SplitRequest) String() string + func (m *SplitRequest) Unmarshal(dAtA []byte) error + func (m *SplitRequest) XXX_DiscardUnknown() + func (m *SplitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SplitRequest) XXX_Merge(src proto.Message) + func (m *SplitRequest) XXX_Size() int + func (m *SplitRequest) XXX_Unmarshal(b []byte) error + type TransferLeaderRequest struct + Replica metapb.Replica + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TransferLeaderRequest) Descriptor() ([]byte, []int) + func (*TransferLeaderRequest) ProtoMessage() + func (m *TransferLeaderRequest) GetReplica() metapb.Replica + func (m *TransferLeaderRequest) Marshal() (dAtA []byte, err error) + func (m *TransferLeaderRequest) MarshalTo(dAtA []byte) (int, error) + func (m *TransferLeaderRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TransferLeaderRequest) Reset() + func (m *TransferLeaderRequest) Size() (n int) + func (m *TransferLeaderRequest) String() string + func (m *TransferLeaderRequest) Unmarshal(dAtA []byte) error + func (m *TransferLeaderRequest) XXX_DiscardUnknown() + func (m *TransferLeaderRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TransferLeaderRequest) XXX_Merge(src proto.Message) + func (m *TransferLeaderRequest) XXX_Size() int + func (m *TransferLeaderRequest) XXX_Unmarshal(b []byte) error + type TransferLeaderResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*TransferLeaderResponse) Descriptor() ([]byte, []int) + func (*TransferLeaderResponse) ProtoMessage() + func (m *TransferLeaderResponse) Marshal() (dAtA []byte, err error) + func (m *TransferLeaderResponse) MarshalTo(dAtA []byte) (int, error) + func (m *TransferLeaderResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TransferLeaderResponse) Reset() + func (m *TransferLeaderResponse) Size() (n int) + func (m *TransferLeaderResponse) String() string + func (m *TransferLeaderResponse) Unmarshal(dAtA []byte) error + func (m *TransferLeaderResponse) XXX_DiscardUnknown() + func (m *TransferLeaderResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TransferLeaderResponse) XXX_Merge(src proto.Message) + func (m *TransferLeaderResponse) XXX_Size() int + func (m *TransferLeaderResponse) XXX_Unmarshal(b []byte) error + type UpdateLabelsRequest struct + Labels []metapb.Pair + Policy UpdatePolicy + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateLabelsRequest) Descriptor() ([]byte, []int) + func (*UpdateLabelsRequest) ProtoMessage() + func (m *UpdateLabelsRequest) GetLabels() []metapb.Pair + func (m *UpdateLabelsRequest) GetPolicy() UpdatePolicy + func (m *UpdateLabelsRequest) Marshal() (dAtA []byte, err error) + func (m *UpdateLabelsRequest) MarshalTo(dAtA []byte) (int, error) + func (m *UpdateLabelsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UpdateLabelsRequest) Reset() + func (m *UpdateLabelsRequest) Size() (n int) + func (m *UpdateLabelsRequest) String() string + func (m *UpdateLabelsRequest) Unmarshal(dAtA []byte) error + func (m *UpdateLabelsRequest) XXX_DiscardUnknown() + func (m *UpdateLabelsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateLabelsRequest) XXX_Merge(src proto.Message) + func (m *UpdateLabelsRequest) XXX_Size() int + func (m *UpdateLabelsRequest) XXX_Unmarshal(b []byte) error + type UpdateLabelsResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateLabelsResponse) Descriptor() ([]byte, []int) + func (*UpdateLabelsResponse) ProtoMessage() + func (m *UpdateLabelsResponse) Marshal() (dAtA []byte, err error) + func (m *UpdateLabelsResponse) MarshalTo(dAtA []byte) (int, error) + func (m *UpdateLabelsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UpdateLabelsResponse) Reset() + func (m *UpdateLabelsResponse) Size() (n int) + func (m *UpdateLabelsResponse) String() string + func (m *UpdateLabelsResponse) Unmarshal(dAtA []byte) error + func (m *UpdateLabelsResponse) XXX_DiscardUnknown() + func (m *UpdateLabelsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateLabelsResponse) XXX_Merge(src proto.Message) + func (m *UpdateLabelsResponse) XXX_Size() int + func (m *UpdateLabelsResponse) XXX_Unmarshal(b []byte) error + type UpdateMetadataRequest struct + Metadata meta.ShardLocalState + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateMetadataRequest) Descriptor() ([]byte, []int) + func (*UpdateMetadataRequest) ProtoMessage() + func (m *UpdateMetadataRequest) GetMetadata() meta.ShardLocalState + func (m *UpdateMetadataRequest) Marshal() (dAtA []byte, err error) + func (m *UpdateMetadataRequest) MarshalTo(dAtA []byte) (int, error) + func (m *UpdateMetadataRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UpdateMetadataRequest) Reset() + func (m *UpdateMetadataRequest) Size() (n int) + func (m *UpdateMetadataRequest) String() string + func (m *UpdateMetadataRequest) Unmarshal(dAtA []byte) error + func (m *UpdateMetadataRequest) XXX_DiscardUnknown() + func (m *UpdateMetadataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateMetadataRequest) XXX_Merge(src proto.Message) + func (m *UpdateMetadataRequest) XXX_Size() int + func (m *UpdateMetadataRequest) XXX_Unmarshal(b []byte) error + type UpdateMetadataResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateMetadataResponse) Descriptor() ([]byte, []int) + func (*UpdateMetadataResponse) ProtoMessage() + func (m *UpdateMetadataResponse) Marshal() (dAtA []byte, err error) + func (m *UpdateMetadataResponse) MarshalTo(dAtA []byte) (int, error) + func (m *UpdateMetadataResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *UpdateMetadataResponse) Reset() + func (m *UpdateMetadataResponse) Size() (n int) + func (m *UpdateMetadataResponse) String() string + func (m *UpdateMetadataResponse) Unmarshal(dAtA []byte) error + func (m *UpdateMetadataResponse) XXX_DiscardUnknown() + func (m *UpdateMetadataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateMetadataResponse) XXX_Merge(src proto.Message) + func (m *UpdateMetadataResponse) XXX_Size() int + func (m *UpdateMetadataResponse) XXX_Unmarshal(b []byte) error + type UpdatePolicy int32 + const UpdatePolicy_Add + const UpdatePolicy_Clear + const UpdatePolicy_Remove + const UpdatePolicy_Reset + func (UpdatePolicy) EnumDescriptor() ([]byte, []int) + func (x UpdatePolicy) String() string + type VerifyHashRequest struct + Context []byte + Hash []byte + Index uint64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*VerifyHashRequest) Descriptor() ([]byte, []int) + func (*VerifyHashRequest) ProtoMessage() + func (m *VerifyHashRequest) GetContext() []byte + func (m *VerifyHashRequest) GetHash() []byte + func (m *VerifyHashRequest) GetIndex() uint64 + func (m *VerifyHashRequest) Marshal() (dAtA []byte, err error) + func (m *VerifyHashRequest) MarshalTo(dAtA []byte) (int, error) + func (m *VerifyHashRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *VerifyHashRequest) Reset() + func (m *VerifyHashRequest) Size() (n int) + func (m *VerifyHashRequest) String() string + func (m *VerifyHashRequest) Unmarshal(dAtA []byte) error + func (m *VerifyHashRequest) XXX_DiscardUnknown() + func (m *VerifyHashRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *VerifyHashRequest) XXX_Merge(src proto.Message) + func (m *VerifyHashRequest) XXX_Size() int + func (m *VerifyHashRequest) XXX_Unmarshal(b []byte) error + type VerifyHashResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*VerifyHashResponse) Descriptor() ([]byte, []int) + func (*VerifyHashResponse) ProtoMessage() + func (m *VerifyHashResponse) Marshal() (dAtA []byte, err error) + func (m *VerifyHashResponse) MarshalTo(dAtA []byte) (int, error) + func (m *VerifyHashResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *VerifyHashResponse) Reset() + func (m *VerifyHashResponse) Size() (n int) + func (m *VerifyHashResponse) String() string + func (m *VerifyHashResponse) Unmarshal(dAtA []byte) error + func (m *VerifyHashResponse) XXX_DiscardUnknown() + func (m *VerifyHashResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *VerifyHashResponse) XXX_Merge(src proto.Message) + func (m *VerifyHashResponse) XXX_Size() int + func (m *VerifyHashResponse) XXX_Unmarshal(b []byte) error
Go to main page