Documentation
¶
Overview ¶
Package etcdserverpb is a generated protocol buffer package.
It is generated from these files:
etcdserver.proto raft_internal.proto rpc.proto
It has these top-level messages:
Request Metadata InternalRaftRequest EmptyResponse ResponseHeader RangeRequest RangeResponse PutRequest PutResponse DeleteRangeRequest DeleteRangeResponse RequestUnion ResponseUnion Compare TxnRequest TxnResponse CompactionRequest CompactionResponse HashRequest HashResponse WatchRequest WatchCreateRequest WatchCancelRequest WatchResponse LeaseCreateRequest LeaseCreateResponse LeaseRevokeRequest LeaseRevokeResponse LeaseKeepAliveRequest LeaseKeepAliveResponse Member MemberAddRequest MemberAddResponse MemberRemoveRequest MemberRemoveResponse MemberUpdateRequest MemberUpdateResponse MemberListRequest MemberListResponse DefragmentRequest DefragmentResponse AuthEnableRequest AuthDisableRequest AuthenticateRequest UserAddRequest UserGetRequest UserDeleteRequest UserChangePasswordRequest UserGrantRequest UserRevokeRequest RoleAddRequest RoleGetRequest RoleDeleteRequest RoleGrantRequest RoleRevokeRequest AuthEnableResponse AuthDisableResponse AuthenticateResponse UserAddResponse UserGetResponse UserDeleteResponse UserChangePasswordResponse UserGrantResponse UserRevokeResponse RoleAddResponse RoleGetResponse RoleDeleteResponse RoleGrantResponse RoleRevokeResponse
Index ¶
- Variables
- func RegisterAuthServer(s *grpc.Server, srv AuthServer)
- func RegisterClusterServer(s *grpc.Server, srv ClusterServer)
- func RegisterKVServer(s *grpc.Server, srv KVServer)
- func RegisterLeaseServer(s *grpc.Server, srv LeaseServer)
- func RegisterMaintenanceServer(s *grpc.Server, srv MaintenanceServer)
- func RegisterWatchServer(s *grpc.Server, srv WatchServer)
- type AuthClient
- type AuthDisableRequest
- func (m *AuthDisableRequest) Marshal() (data []byte, err error)
- func (m *AuthDisableRequest) MarshalTo(data []byte) (int, error)
- func (*AuthDisableRequest) ProtoMessage()
- func (m *AuthDisableRequest) Reset()
- func (m *AuthDisableRequest) Size() (n int)
- func (m *AuthDisableRequest) String() string
- func (m *AuthDisableRequest) Unmarshal(data []byte) error
- type AuthDisableResponse
- func (m *AuthDisableResponse) GetHeader() *ResponseHeader
- func (m *AuthDisableResponse) Marshal() (data []byte, err error)
- func (m *AuthDisableResponse) MarshalTo(data []byte) (int, error)
- func (*AuthDisableResponse) ProtoMessage()
- func (m *AuthDisableResponse) Reset()
- func (m *AuthDisableResponse) Size() (n int)
- func (m *AuthDisableResponse) String() string
- func (m *AuthDisableResponse) Unmarshal(data []byte) error
- type AuthEnableRequest
- func (m *AuthEnableRequest) Marshal() (data []byte, err error)
- func (m *AuthEnableRequest) MarshalTo(data []byte) (int, error)
- func (*AuthEnableRequest) ProtoMessage()
- func (m *AuthEnableRequest) Reset()
- func (m *AuthEnableRequest) Size() (n int)
- func (m *AuthEnableRequest) String() string
- func (m *AuthEnableRequest) Unmarshal(data []byte) error
- type AuthEnableResponse
- func (m *AuthEnableResponse) GetHeader() *ResponseHeader
- func (m *AuthEnableResponse) Marshal() (data []byte, err error)
- func (m *AuthEnableResponse) MarshalTo(data []byte) (int, error)
- func (*AuthEnableResponse) ProtoMessage()
- func (m *AuthEnableResponse) Reset()
- func (m *AuthEnableResponse) Size() (n int)
- func (m *AuthEnableResponse) String() string
- func (m *AuthEnableResponse) Unmarshal(data []byte) error
- type AuthServer
- type AuthenticateRequest
- func (m *AuthenticateRequest) Marshal() (data []byte, err error)
- func (m *AuthenticateRequest) MarshalTo(data []byte) (int, error)
- func (*AuthenticateRequest) ProtoMessage()
- func (m *AuthenticateRequest) Reset()
- func (m *AuthenticateRequest) Size() (n int)
- func (m *AuthenticateRequest) String() string
- func (m *AuthenticateRequest) Unmarshal(data []byte) error
- type AuthenticateResponse
- func (m *AuthenticateResponse) GetHeader() *ResponseHeader
- func (m *AuthenticateResponse) Marshal() (data []byte, err error)
- func (m *AuthenticateResponse) MarshalTo(data []byte) (int, error)
- func (*AuthenticateResponse) ProtoMessage()
- func (m *AuthenticateResponse) Reset()
- func (m *AuthenticateResponse) Size() (n int)
- func (m *AuthenticateResponse) String() string
- func (m *AuthenticateResponse) Unmarshal(data []byte) error
- type ClusterClient
- type ClusterServer
- type CompactionRequest
- func (m *CompactionRequest) Marshal() (data []byte, err error)
- func (m *CompactionRequest) MarshalTo(data []byte) (int, error)
- func (*CompactionRequest) ProtoMessage()
- func (m *CompactionRequest) Reset()
- func (m *CompactionRequest) Size() (n int)
- func (m *CompactionRequest) String() string
- func (m *CompactionRequest) Unmarshal(data []byte) error
- type CompactionResponse
- func (m *CompactionResponse) GetHeader() *ResponseHeader
- func (m *CompactionResponse) Marshal() (data []byte, err error)
- func (m *CompactionResponse) MarshalTo(data []byte) (int, error)
- func (*CompactionResponse) ProtoMessage()
- func (m *CompactionResponse) Reset()
- func (m *CompactionResponse) Size() (n int)
- func (m *CompactionResponse) String() string
- func (m *CompactionResponse) Unmarshal(data []byte) error
- type Compare
- func (m *Compare) GetCreateRevision() int64
- func (m *Compare) GetModRevision() int64
- func (m *Compare) GetTargetUnion() isCompare_TargetUnion
- func (m *Compare) GetValue() []byte
- func (m *Compare) GetVersion() int64
- func (m *Compare) Marshal() (data []byte, err error)
- func (m *Compare) MarshalTo(data []byte) (int, error)
- func (*Compare) ProtoMessage()
- func (m *Compare) Reset()
- func (m *Compare) Size() (n int)
- func (m *Compare) String() string
- func (m *Compare) Unmarshal(data []byte) error
- func (*Compare) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- type Compare_CompareResult
- type Compare_CompareTarget
- type Compare_CreateRevision
- type Compare_ModRevision
- type Compare_Value
- type Compare_Version
- type DefragmentRequest
- func (m *DefragmentRequest) Marshal() (data []byte, err error)
- func (m *DefragmentRequest) MarshalTo(data []byte) (int, error)
- func (*DefragmentRequest) ProtoMessage()
- func (m *DefragmentRequest) Reset()
- func (m *DefragmentRequest) Size() (n int)
- func (m *DefragmentRequest) String() string
- func (m *DefragmentRequest) Unmarshal(data []byte) error
- type DefragmentResponse
- func (m *DefragmentResponse) GetHeader() *ResponseHeader
- func (m *DefragmentResponse) Marshal() (data []byte, err error)
- func (m *DefragmentResponse) MarshalTo(data []byte) (int, error)
- func (*DefragmentResponse) ProtoMessage()
- func (m *DefragmentResponse) Reset()
- func (m *DefragmentResponse) Size() (n int)
- func (m *DefragmentResponse) String() string
- func (m *DefragmentResponse) Unmarshal(data []byte) error
- type DeleteRangeRequest
- func (m *DeleteRangeRequest) Marshal() (data []byte, err error)
- func (m *DeleteRangeRequest) MarshalTo(data []byte) (int, error)
- func (*DeleteRangeRequest) ProtoMessage()
- func (m *DeleteRangeRequest) Reset()
- func (m *DeleteRangeRequest) Size() (n int)
- func (m *DeleteRangeRequest) String() string
- func (m *DeleteRangeRequest) Unmarshal(data []byte) error
- type DeleteRangeResponse
- func (m *DeleteRangeResponse) GetHeader() *ResponseHeader
- func (m *DeleteRangeResponse) Marshal() (data []byte, err error)
- func (m *DeleteRangeResponse) MarshalTo(data []byte) (int, error)
- func (*DeleteRangeResponse) ProtoMessage()
- func (m *DeleteRangeResponse) Reset()
- func (m *DeleteRangeResponse) Size() (n int)
- func (m *DeleteRangeResponse) String() string
- func (m *DeleteRangeResponse) Unmarshal(data []byte) error
- type EmptyResponse
- func (m *EmptyResponse) Marshal() (data []byte, err error)
- func (m *EmptyResponse) MarshalTo(data []byte) (int, error)
- func (*EmptyResponse) ProtoMessage()
- func (m *EmptyResponse) Reset()
- func (m *EmptyResponse) Size() (n int)
- func (m *EmptyResponse) String() string
- func (m *EmptyResponse) Unmarshal(data []byte) error
- type HashRequest
- func (m *HashRequest) Marshal() (data []byte, err error)
- func (m *HashRequest) MarshalTo(data []byte) (int, error)
- func (*HashRequest) ProtoMessage()
- func (m *HashRequest) Reset()
- func (m *HashRequest) Size() (n int)
- func (m *HashRequest) String() string
- func (m *HashRequest) Unmarshal(data []byte) error
- type HashResponse
- func (m *HashResponse) GetHeader() *ResponseHeader
- func (m *HashResponse) Marshal() (data []byte, err error)
- func (m *HashResponse) MarshalTo(data []byte) (int, error)
- func (*HashResponse) ProtoMessage()
- func (m *HashResponse) Reset()
- func (m *HashResponse) Size() (n int)
- func (m *HashResponse) String() string
- func (m *HashResponse) Unmarshal(data []byte) error
- type InternalRaftRequest
- func (m *InternalRaftRequest) Marshal() (data []byte, err error)
- func (m *InternalRaftRequest) MarshalTo(data []byte) (int, error)
- func (*InternalRaftRequest) ProtoMessage()
- func (m *InternalRaftRequest) Reset()
- func (m *InternalRaftRequest) Size() (n int)
- func (m *InternalRaftRequest) String() string
- func (m *InternalRaftRequest) Unmarshal(data []byte) error
- type KVClient
- type KVServer
- type LeaseClient
- type LeaseCreateRequest
- func (m *LeaseCreateRequest) Marshal() (data []byte, err error)
- func (m *LeaseCreateRequest) MarshalTo(data []byte) (int, error)
- func (*LeaseCreateRequest) ProtoMessage()
- func (m *LeaseCreateRequest) Reset()
- func (m *LeaseCreateRequest) Size() (n int)
- func (m *LeaseCreateRequest) String() string
- func (m *LeaseCreateRequest) Unmarshal(data []byte) error
- type LeaseCreateResponse
- func (m *LeaseCreateResponse) GetHeader() *ResponseHeader
- func (m *LeaseCreateResponse) Marshal() (data []byte, err error)
- func (m *LeaseCreateResponse) MarshalTo(data []byte) (int, error)
- func (*LeaseCreateResponse) ProtoMessage()
- func (m *LeaseCreateResponse) Reset()
- func (m *LeaseCreateResponse) Size() (n int)
- func (m *LeaseCreateResponse) String() string
- func (m *LeaseCreateResponse) Unmarshal(data []byte) error
- type LeaseKeepAliveRequest
- func (m *LeaseKeepAliveRequest) Marshal() (data []byte, err error)
- func (m *LeaseKeepAliveRequest) MarshalTo(data []byte) (int, error)
- func (*LeaseKeepAliveRequest) ProtoMessage()
- func (m *LeaseKeepAliveRequest) Reset()
- func (m *LeaseKeepAliveRequest) Size() (n int)
- func (m *LeaseKeepAliveRequest) String() string
- func (m *LeaseKeepAliveRequest) Unmarshal(data []byte) error
- type LeaseKeepAliveResponse
- func (m *LeaseKeepAliveResponse) GetHeader() *ResponseHeader
- func (m *LeaseKeepAliveResponse) Marshal() (data []byte, err error)
- func (m *LeaseKeepAliveResponse) MarshalTo(data []byte) (int, error)
- func (*LeaseKeepAliveResponse) ProtoMessage()
- func (m *LeaseKeepAliveResponse) Reset()
- func (m *LeaseKeepAliveResponse) Size() (n int)
- func (m *LeaseKeepAliveResponse) String() string
- func (m *LeaseKeepAliveResponse) Unmarshal(data []byte) error
- type LeaseRevokeRequest
- func (m *LeaseRevokeRequest) Marshal() (data []byte, err error)
- func (m *LeaseRevokeRequest) MarshalTo(data []byte) (int, error)
- func (*LeaseRevokeRequest) ProtoMessage()
- func (m *LeaseRevokeRequest) Reset()
- func (m *LeaseRevokeRequest) Size() (n int)
- func (m *LeaseRevokeRequest) String() string
- func (m *LeaseRevokeRequest) Unmarshal(data []byte) error
- type LeaseRevokeResponse
- func (m *LeaseRevokeResponse) GetHeader() *ResponseHeader
- func (m *LeaseRevokeResponse) Marshal() (data []byte, err error)
- func (m *LeaseRevokeResponse) MarshalTo(data []byte) (int, error)
- func (*LeaseRevokeResponse) ProtoMessage()
- func (m *LeaseRevokeResponse) Reset()
- func (m *LeaseRevokeResponse) Size() (n int)
- func (m *LeaseRevokeResponse) String() string
- func (m *LeaseRevokeResponse) Unmarshal(data []byte) error
- type LeaseServer
- type Lease_LeaseKeepAliveClient
- type Lease_LeaseKeepAliveServer
- type MaintenanceClient
- type MaintenanceServer
- type Member
- type MemberAddRequest
- func (m *MemberAddRequest) Marshal() (data []byte, err error)
- func (m *MemberAddRequest) MarshalTo(data []byte) (int, error)
- func (*MemberAddRequest) ProtoMessage()
- func (m *MemberAddRequest) Reset()
- func (m *MemberAddRequest) Size() (n int)
- func (m *MemberAddRequest) String() string
- func (m *MemberAddRequest) Unmarshal(data []byte) error
- type MemberAddResponse
- func (m *MemberAddResponse) GetHeader() *ResponseHeader
- func (m *MemberAddResponse) GetMember() *Member
- func (m *MemberAddResponse) Marshal() (data []byte, err error)
- func (m *MemberAddResponse) MarshalTo(data []byte) (int, error)
- func (*MemberAddResponse) ProtoMessage()
- func (m *MemberAddResponse) Reset()
- func (m *MemberAddResponse) Size() (n int)
- func (m *MemberAddResponse) String() string
- func (m *MemberAddResponse) Unmarshal(data []byte) error
- type MemberListRequest
- func (m *MemberListRequest) Marshal() (data []byte, err error)
- func (m *MemberListRequest) MarshalTo(data []byte) (int, error)
- func (*MemberListRequest) ProtoMessage()
- func (m *MemberListRequest) Reset()
- func (m *MemberListRequest) Size() (n int)
- func (m *MemberListRequest) String() string
- func (m *MemberListRequest) Unmarshal(data []byte) error
- type MemberListResponse
- func (m *MemberListResponse) GetHeader() *ResponseHeader
- func (m *MemberListResponse) GetMembers() []*Member
- func (m *MemberListResponse) Marshal() (data []byte, err error)
- func (m *MemberListResponse) MarshalTo(data []byte) (int, error)
- func (*MemberListResponse) ProtoMessage()
- func (m *MemberListResponse) Reset()
- func (m *MemberListResponse) Size() (n int)
- func (m *MemberListResponse) String() string
- func (m *MemberListResponse) Unmarshal(data []byte) error
- type MemberRemoveRequest
- func (m *MemberRemoveRequest) Marshal() (data []byte, err error)
- func (m *MemberRemoveRequest) MarshalTo(data []byte) (int, error)
- func (*MemberRemoveRequest) ProtoMessage()
- func (m *MemberRemoveRequest) Reset()
- func (m *MemberRemoveRequest) Size() (n int)
- func (m *MemberRemoveRequest) String() string
- func (m *MemberRemoveRequest) Unmarshal(data []byte) error
- type MemberRemoveResponse
- func (m *MemberRemoveResponse) GetHeader() *ResponseHeader
- func (m *MemberRemoveResponse) Marshal() (data []byte, err error)
- func (m *MemberRemoveResponse) MarshalTo(data []byte) (int, error)
- func (*MemberRemoveResponse) ProtoMessage()
- func (m *MemberRemoveResponse) Reset()
- func (m *MemberRemoveResponse) Size() (n int)
- func (m *MemberRemoveResponse) String() string
- func (m *MemberRemoveResponse) Unmarshal(data []byte) error
- type MemberUpdateRequest
- func (m *MemberUpdateRequest) Marshal() (data []byte, err error)
- func (m *MemberUpdateRequest) MarshalTo(data []byte) (int, error)
- func (*MemberUpdateRequest) ProtoMessage()
- func (m *MemberUpdateRequest) Reset()
- func (m *MemberUpdateRequest) Size() (n int)
- func (m *MemberUpdateRequest) String() string
- func (m *MemberUpdateRequest) Unmarshal(data []byte) error
- type MemberUpdateResponse
- func (m *MemberUpdateResponse) GetHeader() *ResponseHeader
- func (m *MemberUpdateResponse) Marshal() (data []byte, err error)
- func (m *MemberUpdateResponse) MarshalTo(data []byte) (int, error)
- func (*MemberUpdateResponse) ProtoMessage()
- func (m *MemberUpdateResponse) Reset()
- func (m *MemberUpdateResponse) Size() (n int)
- func (m *MemberUpdateResponse) String() string
- func (m *MemberUpdateResponse) Unmarshal(data []byte) error
- type Metadata
- type PutRequest
- type PutResponse
- func (m *PutResponse) GetHeader() *ResponseHeader
- func (m *PutResponse) Marshal() (data []byte, err error)
- func (m *PutResponse) MarshalTo(data []byte) (int, error)
- func (*PutResponse) ProtoMessage()
- func (m *PutResponse) Reset()
- func (m *PutResponse) Size() (n int)
- func (m *PutResponse) String() string
- func (m *PutResponse) Unmarshal(data []byte) error
- type RangeRequest
- func (m *RangeRequest) Marshal() (data []byte, err error)
- func (m *RangeRequest) MarshalTo(data []byte) (int, error)
- func (*RangeRequest) ProtoMessage()
- func (m *RangeRequest) Reset()
- func (m *RangeRequest) Size() (n int)
- func (m *RangeRequest) String() string
- func (m *RangeRequest) Unmarshal(data []byte) error
- type RangeRequest_SortOrder
- type RangeRequest_SortTarget
- type RangeResponse
- func (m *RangeResponse) GetHeader() *ResponseHeader
- func (m *RangeResponse) GetKvs() []*storagepb.KeyValue
- func (m *RangeResponse) Marshal() (data []byte, err error)
- func (m *RangeResponse) MarshalTo(data []byte) (int, error)
- func (*RangeResponse) ProtoMessage()
- func (m *RangeResponse) Reset()
- func (m *RangeResponse) Size() (n int)
- func (m *RangeResponse) String() string
- func (m *RangeResponse) Unmarshal(data []byte) error
- type Request
- type RequestUnion
- func (m *RequestUnion) GetRequest() isRequestUnion_Request
- func (m *RequestUnion) GetRequestDeleteRange() *DeleteRangeRequest
- func (m *RequestUnion) GetRequestPut() *PutRequest
- func (m *RequestUnion) GetRequestRange() *RangeRequest
- func (m *RequestUnion) Marshal() (data []byte, err error)
- func (m *RequestUnion) MarshalTo(data []byte) (int, error)
- func (*RequestUnion) ProtoMessage()
- func (m *RequestUnion) Reset()
- func (m *RequestUnion) Size() (n int)
- func (m *RequestUnion) String() string
- func (m *RequestUnion) Unmarshal(data []byte) error
- func (*RequestUnion) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- type RequestUnion_RequestDeleteRange
- type RequestUnion_RequestPut
- type RequestUnion_RequestRange
- type ResponseHeader
- func (m *ResponseHeader) Marshal() (data []byte, err error)
- func (m *ResponseHeader) MarshalTo(data []byte) (int, error)
- func (*ResponseHeader) ProtoMessage()
- func (m *ResponseHeader) Reset()
- func (m *ResponseHeader) Size() (n int)
- func (m *ResponseHeader) String() string
- func (m *ResponseHeader) Unmarshal(data []byte) error
- type ResponseUnion
- func (m *ResponseUnion) GetResponse() isResponseUnion_Response
- func (m *ResponseUnion) GetResponseDeleteRange() *DeleteRangeResponse
- func (m *ResponseUnion) GetResponsePut() *PutResponse
- func (m *ResponseUnion) GetResponseRange() *RangeResponse
- func (m *ResponseUnion) Marshal() (data []byte, err error)
- func (m *ResponseUnion) MarshalTo(data []byte) (int, error)
- func (*ResponseUnion) ProtoMessage()
- func (m *ResponseUnion) Reset()
- func (m *ResponseUnion) Size() (n int)
- func (m *ResponseUnion) String() string
- func (m *ResponseUnion) Unmarshal(data []byte) error
- func (*ResponseUnion) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- type ResponseUnion_ResponseDeleteRange
- type ResponseUnion_ResponsePut
- type ResponseUnion_ResponseRange
- type RoleAddRequest
- func (m *RoleAddRequest) Marshal() (data []byte, err error)
- func (m *RoleAddRequest) MarshalTo(data []byte) (int, error)
- func (*RoleAddRequest) ProtoMessage()
- func (m *RoleAddRequest) Reset()
- func (m *RoleAddRequest) Size() (n int)
- func (m *RoleAddRequest) String() string
- func (m *RoleAddRequest) Unmarshal(data []byte) error
- type RoleAddResponse
- func (m *RoleAddResponse) GetHeader() *ResponseHeader
- func (m *RoleAddResponse) Marshal() (data []byte, err error)
- func (m *RoleAddResponse) MarshalTo(data []byte) (int, error)
- func (*RoleAddResponse) ProtoMessage()
- func (m *RoleAddResponse) Reset()
- func (m *RoleAddResponse) Size() (n int)
- func (m *RoleAddResponse) String() string
- func (m *RoleAddResponse) Unmarshal(data []byte) error
- type RoleDeleteRequest
- func (m *RoleDeleteRequest) Marshal() (data []byte, err error)
- func (m *RoleDeleteRequest) MarshalTo(data []byte) (int, error)
- func (*RoleDeleteRequest) ProtoMessage()
- func (m *RoleDeleteRequest) Reset()
- func (m *RoleDeleteRequest) Size() (n int)
- func (m *RoleDeleteRequest) String() string
- func (m *RoleDeleteRequest) Unmarshal(data []byte) error
- type RoleDeleteResponse
- func (m *RoleDeleteResponse) GetHeader() *ResponseHeader
- func (m *RoleDeleteResponse) Marshal() (data []byte, err error)
- func (m *RoleDeleteResponse) MarshalTo(data []byte) (int, error)
- func (*RoleDeleteResponse) ProtoMessage()
- func (m *RoleDeleteResponse) Reset()
- func (m *RoleDeleteResponse) Size() (n int)
- func (m *RoleDeleteResponse) String() string
- func (m *RoleDeleteResponse) Unmarshal(data []byte) error
- type RoleGetRequest
- func (m *RoleGetRequest) Marshal() (data []byte, err error)
- func (m *RoleGetRequest) MarshalTo(data []byte) (int, error)
- func (*RoleGetRequest) ProtoMessage()
- func (m *RoleGetRequest) Reset()
- func (m *RoleGetRequest) Size() (n int)
- func (m *RoleGetRequest) String() string
- func (m *RoleGetRequest) Unmarshal(data []byte) error
- type RoleGetResponse
- func (m *RoleGetResponse) GetHeader() *ResponseHeader
- func (m *RoleGetResponse) Marshal() (data []byte, err error)
- func (m *RoleGetResponse) MarshalTo(data []byte) (int, error)
- func (*RoleGetResponse) ProtoMessage()
- func (m *RoleGetResponse) Reset()
- func (m *RoleGetResponse) Size() (n int)
- func (m *RoleGetResponse) String() string
- func (m *RoleGetResponse) Unmarshal(data []byte) error
- type RoleGrantRequest
- func (m *RoleGrantRequest) Marshal() (data []byte, err error)
- func (m *RoleGrantRequest) MarshalTo(data []byte) (int, error)
- func (*RoleGrantRequest) ProtoMessage()
- func (m *RoleGrantRequest) Reset()
- func (m *RoleGrantRequest) Size() (n int)
- func (m *RoleGrantRequest) String() string
- func (m *RoleGrantRequest) Unmarshal(data []byte) error
- type RoleGrantResponse
- func (m *RoleGrantResponse) GetHeader() *ResponseHeader
- func (m *RoleGrantResponse) Marshal() (data []byte, err error)
- func (m *RoleGrantResponse) MarshalTo(data []byte) (int, error)
- func (*RoleGrantResponse) ProtoMessage()
- func (m *RoleGrantResponse) Reset()
- func (m *RoleGrantResponse) Size() (n int)
- func (m *RoleGrantResponse) String() string
- func (m *RoleGrantResponse) Unmarshal(data []byte) error
- type RoleRevokeRequest
- func (m *RoleRevokeRequest) Marshal() (data []byte, err error)
- func (m *RoleRevokeRequest) MarshalTo(data []byte) (int, error)
- func (*RoleRevokeRequest) ProtoMessage()
- func (m *RoleRevokeRequest) Reset()
- func (m *RoleRevokeRequest) Size() (n int)
- func (m *RoleRevokeRequest) String() string
- func (m *RoleRevokeRequest) Unmarshal(data []byte) error
- type RoleRevokeResponse
- func (m *RoleRevokeResponse) GetHeader() *ResponseHeader
- func (m *RoleRevokeResponse) Marshal() (data []byte, err error)
- func (m *RoleRevokeResponse) MarshalTo(data []byte) (int, error)
- func (*RoleRevokeResponse) ProtoMessage()
- func (m *RoleRevokeResponse) Reset()
- func (m *RoleRevokeResponse) Size() (n int)
- func (m *RoleRevokeResponse) String() string
- func (m *RoleRevokeResponse) Unmarshal(data []byte) error
- type TxnRequest
- func (m *TxnRequest) GetCompare() []*Compare
- func (m *TxnRequest) GetFailure() []*RequestUnion
- func (m *TxnRequest) GetSuccess() []*RequestUnion
- func (m *TxnRequest) Marshal() (data []byte, err error)
- func (m *TxnRequest) MarshalTo(data []byte) (int, error)
- func (*TxnRequest) ProtoMessage()
- func (m *TxnRequest) Reset()
- func (m *TxnRequest) Size() (n int)
- func (m *TxnRequest) String() string
- func (m *TxnRequest) Unmarshal(data []byte) error
- type TxnResponse
- func (m *TxnResponse) GetHeader() *ResponseHeader
- func (m *TxnResponse) GetResponses() []*ResponseUnion
- func (m *TxnResponse) Marshal() (data []byte, err error)
- func (m *TxnResponse) MarshalTo(data []byte) (int, error)
- func (*TxnResponse) ProtoMessage()
- func (m *TxnResponse) Reset()
- func (m *TxnResponse) Size() (n int)
- func (m *TxnResponse) String() string
- func (m *TxnResponse) Unmarshal(data []byte) error
- type UserAddRequest
- func (m *UserAddRequest) Marshal() (data []byte, err error)
- func (m *UserAddRequest) MarshalTo(data []byte) (int, error)
- func (*UserAddRequest) ProtoMessage()
- func (m *UserAddRequest) Reset()
- func (m *UserAddRequest) Size() (n int)
- func (m *UserAddRequest) String() string
- func (m *UserAddRequest) Unmarshal(data []byte) error
- type UserAddResponse
- func (m *UserAddResponse) GetHeader() *ResponseHeader
- func (m *UserAddResponse) Marshal() (data []byte, err error)
- func (m *UserAddResponse) MarshalTo(data []byte) (int, error)
- func (*UserAddResponse) ProtoMessage()
- func (m *UserAddResponse) Reset()
- func (m *UserAddResponse) Size() (n int)
- func (m *UserAddResponse) String() string
- func (m *UserAddResponse) Unmarshal(data []byte) error
- type UserChangePasswordRequest
- func (m *UserChangePasswordRequest) Marshal() (data []byte, err error)
- func (m *UserChangePasswordRequest) MarshalTo(data []byte) (int, error)
- func (*UserChangePasswordRequest) ProtoMessage()
- func (m *UserChangePasswordRequest) Reset()
- func (m *UserChangePasswordRequest) Size() (n int)
- func (m *UserChangePasswordRequest) String() string
- func (m *UserChangePasswordRequest) Unmarshal(data []byte) error
- type UserChangePasswordResponse
- func (m *UserChangePasswordResponse) GetHeader() *ResponseHeader
- func (m *UserChangePasswordResponse) Marshal() (data []byte, err error)
- func (m *UserChangePasswordResponse) MarshalTo(data []byte) (int, error)
- func (*UserChangePasswordResponse) ProtoMessage()
- func (m *UserChangePasswordResponse) Reset()
- func (m *UserChangePasswordResponse) Size() (n int)
- func (m *UserChangePasswordResponse) String() string
- func (m *UserChangePasswordResponse) Unmarshal(data []byte) error
- type UserDeleteRequest
- func (m *UserDeleteRequest) Marshal() (data []byte, err error)
- func (m *UserDeleteRequest) MarshalTo(data []byte) (int, error)
- func (*UserDeleteRequest) ProtoMessage()
- func (m *UserDeleteRequest) Reset()
- func (m *UserDeleteRequest) Size() (n int)
- func (m *UserDeleteRequest) String() string
- func (m *UserDeleteRequest) Unmarshal(data []byte) error
- type UserDeleteResponse
- func (m *UserDeleteResponse) GetHeader() *ResponseHeader
- func (m *UserDeleteResponse) Marshal() (data []byte, err error)
- func (m *UserDeleteResponse) MarshalTo(data []byte) (int, error)
- func (*UserDeleteResponse) ProtoMessage()
- func (m *UserDeleteResponse) Reset()
- func (m *UserDeleteResponse) Size() (n int)
- func (m *UserDeleteResponse) String() string
- func (m *UserDeleteResponse) Unmarshal(data []byte) error
- type UserGetRequest
- func (m *UserGetRequest) Marshal() (data []byte, err error)
- func (m *UserGetRequest) MarshalTo(data []byte) (int, error)
- func (*UserGetRequest) ProtoMessage()
- func (m *UserGetRequest) Reset()
- func (m *UserGetRequest) Size() (n int)
- func (m *UserGetRequest) String() string
- func (m *UserGetRequest) Unmarshal(data []byte) error
- type UserGetResponse
- func (m *UserGetResponse) GetHeader() *ResponseHeader
- func (m *UserGetResponse) Marshal() (data []byte, err error)
- func (m *UserGetResponse) MarshalTo(data []byte) (int, error)
- func (*UserGetResponse) ProtoMessage()
- func (m *UserGetResponse) Reset()
- func (m *UserGetResponse) Size() (n int)
- func (m *UserGetResponse) String() string
- func (m *UserGetResponse) Unmarshal(data []byte) error
- type UserGrantRequest
- func (m *UserGrantRequest) Marshal() (data []byte, err error)
- func (m *UserGrantRequest) MarshalTo(data []byte) (int, error)
- func (*UserGrantRequest) ProtoMessage()
- func (m *UserGrantRequest) Reset()
- func (m *UserGrantRequest) Size() (n int)
- func (m *UserGrantRequest) String() string
- func (m *UserGrantRequest) Unmarshal(data []byte) error
- type UserGrantResponse
- func (m *UserGrantResponse) GetHeader() *ResponseHeader
- func (m *UserGrantResponse) Marshal() (data []byte, err error)
- func (m *UserGrantResponse) MarshalTo(data []byte) (int, error)
- func (*UserGrantResponse) ProtoMessage()
- func (m *UserGrantResponse) Reset()
- func (m *UserGrantResponse) Size() (n int)
- func (m *UserGrantResponse) String() string
- func (m *UserGrantResponse) Unmarshal(data []byte) error
- type UserRevokeRequest
- func (m *UserRevokeRequest) Marshal() (data []byte, err error)
- func (m *UserRevokeRequest) MarshalTo(data []byte) (int, error)
- func (*UserRevokeRequest) ProtoMessage()
- func (m *UserRevokeRequest) Reset()
- func (m *UserRevokeRequest) Size() (n int)
- func (m *UserRevokeRequest) String() string
- func (m *UserRevokeRequest) Unmarshal(data []byte) error
- type UserRevokeResponse
- func (m *UserRevokeResponse) GetHeader() *ResponseHeader
- func (m *UserRevokeResponse) Marshal() (data []byte, err error)
- func (m *UserRevokeResponse) MarshalTo(data []byte) (int, error)
- func (*UserRevokeResponse) ProtoMessage()
- func (m *UserRevokeResponse) Reset()
- func (m *UserRevokeResponse) Size() (n int)
- func (m *UserRevokeResponse) String() string
- func (m *UserRevokeResponse) Unmarshal(data []byte) error
- type WatchCancelRequest
- func (m *WatchCancelRequest) Marshal() (data []byte, err error)
- func (m *WatchCancelRequest) MarshalTo(data []byte) (int, error)
- func (*WatchCancelRequest) ProtoMessage()
- func (m *WatchCancelRequest) Reset()
- func (m *WatchCancelRequest) Size() (n int)
- func (m *WatchCancelRequest) String() string
- func (m *WatchCancelRequest) Unmarshal(data []byte) error
- type WatchClient
- type WatchCreateRequest
- func (m *WatchCreateRequest) Marshal() (data []byte, err error)
- func (m *WatchCreateRequest) MarshalTo(data []byte) (int, error)
- func (*WatchCreateRequest) ProtoMessage()
- func (m *WatchCreateRequest) Reset()
- func (m *WatchCreateRequest) Size() (n int)
- func (m *WatchCreateRequest) String() string
- func (m *WatchCreateRequest) Unmarshal(data []byte) error
- type WatchRequest
- func (m *WatchRequest) GetCancelRequest() *WatchCancelRequest
- func (m *WatchRequest) GetCreateRequest() *WatchCreateRequest
- func (m *WatchRequest) GetRequestUnion() isWatchRequest_RequestUnion
- func (m *WatchRequest) Marshal() (data []byte, err error)
- func (m *WatchRequest) MarshalTo(data []byte) (int, error)
- func (*WatchRequest) ProtoMessage()
- func (m *WatchRequest) Reset()
- func (m *WatchRequest) Size() (n int)
- func (m *WatchRequest) String() string
- func (m *WatchRequest) Unmarshal(data []byte) error
- func (*WatchRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- type WatchRequest_CancelRequest
- type WatchRequest_CreateRequest
- type WatchResponse
- func (m *WatchResponse) GetEvents() []*storagepb.Event
- func (m *WatchResponse) GetHeader() *ResponseHeader
- func (m *WatchResponse) Marshal() (data []byte, err error)
- func (m *WatchResponse) MarshalTo(data []byte) (int, error)
- func (*WatchResponse) ProtoMessage()
- func (m *WatchResponse) Reset()
- func (m *WatchResponse) Size() (n int)
- func (m *WatchResponse) String() string
- func (m *WatchResponse) Unmarshal(data []byte) error
- type WatchServer
- type Watch_WatchClient
- type Watch_WatchServer
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthEtcdserver = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowEtcdserver = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthRaftInternal = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowRaftInternal = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthRpc = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowRpc = fmt.Errorf("proto: integer overflow") )
var Compare_CompareResult_name = map[int32]string{
0: "EQUAL",
1: "GREATER",
2: "LESS",
}
var Compare_CompareResult_value = map[string]int32{
"EQUAL": 0,
"GREATER": 1,
"LESS": 2,
}
var Compare_CompareTarget_name = map[int32]string{
0: "VERSION",
1: "CREATE",
2: "MOD",
3: "VALUE",
}
var Compare_CompareTarget_value = map[string]int32{
"VERSION": 0,
"CREATE": 1,
"MOD": 2,
"VALUE": 3,
}
var RangeRequest_SortOrder_name = map[int32]string{
0: "NONE",
1: "ASCEND",
2: "DESCEND",
}
var RangeRequest_SortOrder_value = map[string]int32{
"NONE": 0,
"ASCEND": 1,
"DESCEND": 2,
}
var RangeRequest_SortTarget_name = map[int32]string{
0: "KEY",
1: "VERSION",
2: "CREATE",
3: "MOD",
4: "VALUE",
}
var RangeRequest_SortTarget_value = map[string]int32{
"KEY": 0,
"VERSION": 1,
"CREATE": 2,
"MOD": 3,
"VALUE": 4,
}
Functions ¶
func RegisterAuthServer ¶
func RegisterAuthServer(s *grpc.Server, srv AuthServer)
func RegisterClusterServer ¶
func RegisterClusterServer(s *grpc.Server, srv ClusterServer)
func RegisterKVServer ¶
func RegisterLeaseServer ¶
func RegisterLeaseServer(s *grpc.Server, srv LeaseServer)
func RegisterMaintenanceServer ¶
func RegisterMaintenanceServer(s *grpc.Server, srv MaintenanceServer)
func RegisterWatchServer ¶
func RegisterWatchServer(s *grpc.Server, srv WatchServer)
Types ¶
type AuthClient ¶
type AuthClient interface { // AuthEnable enables authentication. AuthEnable(ctx context.Context, in *AuthEnableRequest, opts ...grpc.CallOption) (*AuthEnableResponse, error) // AuthDisable disables authentication. AuthDisable(ctx context.Context, in *AuthDisableRequest, opts ...grpc.CallOption) (*AuthDisableResponse, error) // Authenticate processes authenticate request. Authenticate(ctx context.Context, in *AuthenticateRequest, opts ...grpc.CallOption) (*AuthenticateResponse, error) // UserAdd adds a new user. UserAdd(ctx context.Context, in *UserAddRequest, opts ...grpc.CallOption) (*UserAddResponse, error) // UserGet gets a detailed information of a user or lists entire users. UserGet(ctx context.Context, in *UserGetRequest, opts ...grpc.CallOption) (*UserGetResponse, error) // UserDelete deletes a specified user. UserDelete(ctx context.Context, in *UserDeleteRequest, opts ...grpc.CallOption) (*UserDeleteResponse, error) // UserChangePassword changes password of a specified user. UserChangePassword(ctx context.Context, in *UserChangePasswordRequest, opts ...grpc.CallOption) (*UserChangePasswordResponse, error) // UserGrant grants a role to a specified user. UserGrant(ctx context.Context, in *UserGrantRequest, opts ...grpc.CallOption) (*UserGrantResponse, error) // UserRevoke revokes a role of specified user. UserRevoke(ctx context.Context, in *UserRevokeRequest, opts ...grpc.CallOption) (*UserRevokeResponse, error) // RoleAdd adds a new role. RoleAdd(ctx context.Context, in *RoleAddRequest, opts ...grpc.CallOption) (*RoleAddResponse, error) // RoleGet gets a detailed information of a role or lists entire roles. RoleGet(ctx context.Context, in *RoleGetRequest, opts ...grpc.CallOption) (*RoleGetResponse, error) // RoleDelete deletes a specified role. RoleDelete(ctx context.Context, in *RoleDeleteRequest, opts ...grpc.CallOption) (*RoleDeleteResponse, error) // RoleGrant grants a permission of a specified key or range to a specified role. RoleGrant(ctx context.Context, in *RoleGrantRequest, opts ...grpc.CallOption) (*RoleGrantResponse, error) // RoleRevoke revokes a key or range permission of a specified role. RoleRevoke(ctx context.Context, in *RoleRevokeRequest, opts ...grpc.CallOption) (*RoleRevokeResponse, error) }
func NewAuthClient ¶
func NewAuthClient(cc *grpc.ClientConn) AuthClient
type AuthDisableRequest ¶
type AuthDisableRequest struct { }
func (*AuthDisableRequest) Marshal ¶
func (m *AuthDisableRequest) Marshal() (data []byte, err error)
func (*AuthDisableRequest) MarshalTo ¶
func (m *AuthDisableRequest) MarshalTo(data []byte) (int, error)
func (*AuthDisableRequest) ProtoMessage ¶
func (*AuthDisableRequest) ProtoMessage()
func (*AuthDisableRequest) Reset ¶
func (m *AuthDisableRequest) Reset()
func (*AuthDisableRequest) Size ¶
func (m *AuthDisableRequest) Size() (n int)
func (*AuthDisableRequest) String ¶
func (m *AuthDisableRequest) String() string
func (*AuthDisableRequest) Unmarshal ¶
func (m *AuthDisableRequest) Unmarshal(data []byte) error
type AuthDisableResponse ¶
type AuthDisableResponse struct {
Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}
func (*AuthDisableResponse) GetHeader ¶
func (m *AuthDisableResponse) GetHeader() *ResponseHeader
func (*AuthDisableResponse) Marshal ¶
func (m *AuthDisableResponse) Marshal() (data []byte, err error)
func (*AuthDisableResponse) MarshalTo ¶
func (m *AuthDisableResponse) MarshalTo(data []byte) (int, error)
func (*AuthDisableResponse) ProtoMessage ¶
func (*AuthDisableResponse) ProtoMessage()
func (*AuthDisableResponse) Reset ¶
func (m *AuthDisableResponse) Reset()
func (*AuthDisableResponse) Size ¶
func (m *AuthDisableResponse) Size() (n int)
func (*AuthDisableResponse) String ¶
func (m *AuthDisableResponse) String() string
func (*AuthDisableResponse) Unmarshal ¶
func (m *AuthDisableResponse) Unmarshal(data []byte) error
type AuthEnableRequest ¶
type AuthEnableRequest struct { }
func (*AuthEnableRequest) Marshal ¶
func (m *AuthEnableRequest) Marshal() (data []byte, err error)
func (*AuthEnableRequest) MarshalTo ¶
func (m *AuthEnableRequest) MarshalTo(data []byte) (int, error)
func (*AuthEnableRequest) ProtoMessage ¶
func (*AuthEnableRequest) ProtoMessage()
func (*AuthEnableRequest) Reset ¶
func (m *AuthEnableRequest) Reset()
func (*AuthEnableRequest) Size ¶
func (m *AuthEnableRequest) Size() (n int)
func (*AuthEnableRequest) String ¶
func (m *AuthEnableRequest) String() string
func (*AuthEnableRequest) Unmarshal ¶
func (m *AuthEnableRequest) Unmarshal(data []byte) error
type AuthEnableResponse ¶
type AuthEnableResponse struct {
Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}
func (*AuthEnableResponse) GetHeader ¶
func (m *AuthEnableResponse) GetHeader() *ResponseHeader
func (*AuthEnableResponse) Marshal ¶
func (m *AuthEnableResponse) Marshal() (data []byte, err error)
func (*AuthEnableResponse) MarshalTo ¶
func (m *AuthEnableResponse) MarshalTo(data []byte) (int, error)
func (*AuthEnableResponse) ProtoMessage ¶
func (*AuthEnableResponse) ProtoMessage()
func (*AuthEnableResponse) Reset ¶
func (m *AuthEnableResponse) Reset()
func (*AuthEnableResponse) Size ¶
func (m *AuthEnableResponse) Size() (n int)
func (*AuthEnableResponse) String ¶
func (m *AuthEnableResponse) String() string
func (*AuthEnableResponse) Unmarshal ¶
func (m *AuthEnableResponse) Unmarshal(data []byte) error
type AuthServer ¶
type AuthServer interface { // AuthEnable enables authentication. AuthEnable(context.Context, *AuthEnableRequest) (*AuthEnableResponse, error) // AuthDisable disables authentication. AuthDisable(context.Context, *AuthDisableRequest) (*AuthDisableResponse, error) // Authenticate processes authenticate request. Authenticate(context.Context, *AuthenticateRequest) (*AuthenticateResponse, error) // UserAdd adds a new user. UserAdd(context.Context, *UserAddRequest) (*UserAddResponse, error) // UserGet gets a detailed information of a user or lists entire users. UserGet(context.Context, *UserGetRequest) (*UserGetResponse, error) // UserDelete deletes a specified user. UserDelete(context.Context, *UserDeleteRequest) (*UserDeleteResponse, error) // UserChangePassword changes password of a specified user. UserChangePassword(context.Context, *UserChangePasswordRequest) (*UserChangePasswordResponse, error) // UserGrant grants a role to a specified user. UserGrant(context.Context, *UserGrantRequest) (*UserGrantResponse, error) // UserRevoke revokes a role of specified user. UserRevoke(context.Context, *UserRevokeRequest) (*UserRevokeResponse, error) // RoleAdd adds a new role. RoleAdd(context.Context, *RoleAddRequest) (*RoleAddResponse, error) // RoleGet gets a detailed information of a role or lists entire roles. RoleGet(context.Context, *RoleGetRequest) (*RoleGetResponse, error) // RoleDelete deletes a specified role. RoleDelete(context.Context, *RoleDeleteRequest) (*RoleDeleteResponse, error) // RoleGrant grants a permission of a specified key or range to a specified role. RoleGrant(context.Context, *RoleGrantRequest) (*RoleGrantResponse, error) // RoleRevoke revokes a key or range permission of a specified role. RoleRevoke(context.Context, *RoleRevokeRequest) (*RoleRevokeResponse, error) }
type AuthenticateRequest ¶
type AuthenticateRequest struct { }
func (*AuthenticateRequest) Marshal ¶
func (m *AuthenticateRequest) Marshal() (data []byte, err error)
func (*AuthenticateRequest) MarshalTo ¶
func (m *AuthenticateRequest) MarshalTo(data []byte) (int, error)
func (*AuthenticateRequest) ProtoMessage ¶
func (*AuthenticateRequest) ProtoMessage()
func (*AuthenticateRequest) Reset ¶
func (m *AuthenticateRequest) Reset()
func (*AuthenticateRequest) Size ¶
func (m *AuthenticateRequest) Size() (n int)
func (*AuthenticateRequest) String ¶
func (m *AuthenticateRequest) String() string
func (*AuthenticateRequest) Unmarshal ¶
func (m *AuthenticateRequest) Unmarshal(data []byte) error
type AuthenticateResponse ¶
type AuthenticateResponse struct {
Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}
func (*AuthenticateResponse) GetHeader ¶
func (m *AuthenticateResponse) GetHeader() *ResponseHeader
func (*AuthenticateResponse) Marshal ¶
func (m *AuthenticateResponse) Marshal() (data []byte, err error)
func (*AuthenticateResponse) MarshalTo ¶
func (m *AuthenticateResponse) MarshalTo(data []byte) (int, error)
func (*AuthenticateResponse) ProtoMessage ¶
func (*AuthenticateResponse) ProtoMessage()
func (*AuthenticateResponse) Reset ¶
func (m *AuthenticateResponse) Reset()
func (*AuthenticateResponse) Size ¶
func (m *AuthenticateResponse) Size() (n int)
func (*AuthenticateResponse) String ¶
func (m *AuthenticateResponse) String() string
func (*AuthenticateResponse) Unmarshal ¶
func (m *AuthenticateResponse) Unmarshal(data []byte) error
type ClusterClient ¶
type ClusterClient interface { // MemberAdd adds a member into the cluster. MemberAdd(ctx context.Context, in *MemberAddRequest, opts ...grpc.CallOption) (*MemberAddResponse, error) // MemberRemove removes an existing member from the cluster. MemberRemove(ctx context.Context, in *MemberRemoveRequest, opts ...grpc.CallOption) (*MemberRemoveResponse, error) // MemberUpdate updates the member configuration. MemberUpdate(ctx context.Context, in *MemberUpdateRequest, opts ...grpc.CallOption) (*MemberUpdateResponse, error) // MemberList lists all the members in the cluster. MemberList(ctx context.Context, in *MemberListRequest, opts ...grpc.CallOption) (*MemberListResponse, error) }
func NewClusterClient ¶
func NewClusterClient(cc *grpc.ClientConn) ClusterClient
type ClusterServer ¶
type ClusterServer interface { // MemberAdd adds a member into the cluster. MemberAdd(context.Context, *MemberAddRequest) (*MemberAddResponse, error) // MemberRemove removes an existing member from the cluster. MemberRemove(context.Context, *MemberRemoveRequest) (*MemberRemoveResponse, error) // MemberUpdate updates the member configuration. MemberUpdate(context.Context, *MemberUpdateRequest) (*MemberUpdateResponse, error) // MemberList lists all the members in the cluster. MemberList(context.Context, *MemberListRequest) (*MemberListResponse, error) }
type CompactionRequest ¶ added in v1.0.6
type CompactionRequest struct {
Revision int64 `protobuf:"varint,1,opt,name=revision,proto3" json:"revision,omitempty"`
}
Compaction compacts the kv store upto the given revision (including). It removes the old versions of a key. It keeps the newest version of the key even if its latest modification revision is smaller than the given revision.
func (*CompactionRequest) Marshal ¶ added in v1.0.6
func (m *CompactionRequest) Marshal() (data []byte, err error)
func (*CompactionRequest) MarshalTo ¶ added in v1.0.6
func (m *CompactionRequest) MarshalTo(data []byte) (int, error)
func (*CompactionRequest) ProtoMessage ¶ added in v1.0.6
func (*CompactionRequest) ProtoMessage()
func (*CompactionRequest) Reset ¶ added in v1.0.6
func (m *CompactionRequest) Reset()
func (*CompactionRequest) Size ¶ added in v1.0.6
func (m *CompactionRequest) Size() (n int)
func (*CompactionRequest) String ¶ added in v1.0.6
func (m *CompactionRequest) String() string
func (*CompactionRequest) Unmarshal ¶ added in v1.0.6
func (m *CompactionRequest) Unmarshal(data []byte) error
type CompactionResponse ¶ added in v1.0.6
type CompactionResponse struct {
Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}
func (*CompactionResponse) GetHeader ¶ added in v1.0.6
func (m *CompactionResponse) GetHeader() *ResponseHeader
func (*CompactionResponse) Marshal ¶ added in v1.0.6
func (m *CompactionResponse) Marshal() (data []byte, err error)
func (*CompactionResponse) MarshalTo ¶ added in v1.0.6
func (m *CompactionResponse) MarshalTo(data []byte) (int, error)
func (*CompactionResponse) ProtoMessage ¶ added in v1.0.6
func (*CompactionResponse) ProtoMessage()
func (*CompactionResponse) Reset ¶ added in v1.0.6
func (m *CompactionResponse) Reset()
func (*CompactionResponse) Size ¶ added in v1.0.6
func (m *CompactionResponse) Size() (n int)
func (*CompactionResponse) String ¶ added in v1.0.6
func (m *CompactionResponse) String() string
func (*CompactionResponse) Unmarshal ¶ added in v1.0.6
func (m *CompactionResponse) Unmarshal(data []byte) error
type Compare ¶ added in v1.0.6
type Compare struct { Result Compare_CompareResult `protobuf:"varint,1,opt,name=result,proto3,enum=etcdserverpb.Compare_CompareResult" json:"result,omitempty"` Target Compare_CompareTarget `protobuf:"varint,2,opt,name=target,proto3,enum=etcdserverpb.Compare_CompareTarget" json:"target,omitempty"` // key path Key []byte `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"` // Types that are valid to be assigned to TargetUnion: // *Compare_Version // *Compare_CreateRevision // *Compare_ModRevision // *Compare_Value TargetUnion isCompare_TargetUnion `protobuf_oneof:"target_union"` }
func (*Compare) GetCreateRevision ¶ added in v1.1.4
func (*Compare) GetModRevision ¶ added in v1.1.4
func (*Compare) GetTargetUnion ¶ added in v1.1.4
func (m *Compare) GetTargetUnion() isCompare_TargetUnion
func (*Compare) GetVersion ¶ added in v1.1.4
func (*Compare) ProtoMessage ¶ added in v1.0.6
func (*Compare) ProtoMessage()
type Compare_CompareResult ¶ added in v1.1.2
type Compare_CompareResult int32
const ( Compare_EQUAL Compare_CompareResult = 0 Compare_GREATER Compare_CompareResult = 1 Compare_LESS Compare_CompareResult = 2 )
func (Compare_CompareResult) String ¶ added in v1.1.2
func (x Compare_CompareResult) String() string
type Compare_CompareTarget ¶ added in v1.1.2
type Compare_CompareTarget int32
const ( Compare_VERSION Compare_CompareTarget = 0 Compare_CREATE Compare_CompareTarget = 1 Compare_MOD Compare_CompareTarget = 2 Compare_VALUE Compare_CompareTarget = 3 )
func (Compare_CompareTarget) String ¶ added in v1.1.2
func (x Compare_CompareTarget) String() string
type Compare_CreateRevision ¶ added in v1.1.4
type Compare_CreateRevision struct {
CreateRevision int64 `protobuf:"varint,5,opt,name=create_revision,proto3,oneof"`
}
func (*Compare_CreateRevision) MarshalTo ¶ added in v1.1.4
func (m *Compare_CreateRevision) MarshalTo(data []byte) (int, error)
func (*Compare_CreateRevision) Size ¶ added in v1.1.4
func (m *Compare_CreateRevision) Size() (n int)
type Compare_ModRevision ¶ added in v1.1.4
type Compare_ModRevision struct {
ModRevision int64 `protobuf:"varint,6,opt,name=mod_revision,proto3,oneof"`
}
func (*Compare_ModRevision) MarshalTo ¶ added in v1.1.4
func (m *Compare_ModRevision) MarshalTo(data []byte) (int, error)
func (*Compare_ModRevision) Size ¶ added in v1.1.4
func (m *Compare_ModRevision) Size() (n int)
type Compare_Value ¶ added in v1.1.4
type Compare_Value struct {
Value []byte `protobuf:"bytes,7,opt,name=value,proto3,oneof"`
}
func (*Compare_Value) MarshalTo ¶ added in v1.1.4
func (m *Compare_Value) MarshalTo(data []byte) (int, error)
func (*Compare_Value) Size ¶ added in v1.1.4
func (m *Compare_Value) Size() (n int)
type Compare_Version ¶ added in v1.1.4
type Compare_Version struct {
Version int64 `protobuf:"varint,4,opt,name=version,proto3,oneof"`
}
func (*Compare_Version) MarshalTo ¶ added in v1.1.4
func (m *Compare_Version) MarshalTo(data []byte) (int, error)
func (*Compare_Version) Size ¶ added in v1.1.4
func (m *Compare_Version) Size() (n int)
type DefragmentRequest ¶
type DefragmentRequest struct { }
func (*DefragmentRequest) Marshal ¶
func (m *DefragmentRequest) Marshal() (data []byte, err error)
func (*DefragmentRequest) MarshalTo ¶
func (m *DefragmentRequest) MarshalTo(data []byte) (int, error)
func (*DefragmentRequest) ProtoMessage ¶
func (*DefragmentRequest) ProtoMessage()
func (*DefragmentRequest) Reset ¶
func (m *DefragmentRequest) Reset()
func (*DefragmentRequest) Size ¶
func (m *DefragmentRequest) Size() (n int)
func (*DefragmentRequest) String ¶
func (m *DefragmentRequest) String() string
func (*DefragmentRequest) Unmarshal ¶
func (m *DefragmentRequest) Unmarshal(data []byte) error
type DefragmentResponse ¶
type DefragmentResponse struct {
Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}
func (*DefragmentResponse) GetHeader ¶
func (m *DefragmentResponse) GetHeader() *ResponseHeader
func (*DefragmentResponse) Marshal ¶
func (m *DefragmentResponse) Marshal() (data []byte, err error)
func (*DefragmentResponse) MarshalTo ¶
func (m *DefragmentResponse) MarshalTo(data []byte) (int, error)
func (*DefragmentResponse) ProtoMessage ¶
func (*DefragmentResponse) ProtoMessage()
func (*DefragmentResponse) Reset ¶
func (m *DefragmentResponse) Reset()
func (*DefragmentResponse) Size ¶
func (m *DefragmentResponse) Size() (n int)
func (*DefragmentResponse) String ¶
func (m *DefragmentResponse) String() string
func (*DefragmentResponse) Unmarshal ¶
func (m *DefragmentResponse) Unmarshal(data []byte) error
type DeleteRangeRequest ¶ added in v1.0.6
type DeleteRangeRequest struct { // if the range_end is not given, the request deletes the key. Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // if the range_end is given, it deletes the keys in range [key, range_end). RangeEnd []byte `protobuf:"bytes,2,opt,name=range_end,proto3" json:"range_end,omitempty"` }
func (*DeleteRangeRequest) Marshal ¶ added in v1.0.6
func (m *DeleteRangeRequest) Marshal() (data []byte, err error)
func (*DeleteRangeRequest) MarshalTo ¶ added in v1.0.6
func (m *DeleteRangeRequest) MarshalTo(data []byte) (int, error)
func (*DeleteRangeRequest) ProtoMessage ¶ added in v1.0.6
func (*DeleteRangeRequest) ProtoMessage()
func (*DeleteRangeRequest) Reset ¶ added in v1.0.6
func (m *DeleteRangeRequest) Reset()
func (*DeleteRangeRequest) Size ¶ added in v1.0.6
func (m *DeleteRangeRequest) Size() (n int)
func (*DeleteRangeRequest) String ¶ added in v1.0.6
func (m *DeleteRangeRequest) String() string
func (*DeleteRangeRequest) Unmarshal ¶ added in v1.0.6
func (m *DeleteRangeRequest) Unmarshal(data []byte) error
type DeleteRangeResponse ¶ added in v1.0.6
type DeleteRangeResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"` // Deleted is the number of keys that got deleted. Deleted int64 `protobuf:"varint,2,opt,name=deleted,proto3" json:"deleted,omitempty"` }
func (*DeleteRangeResponse) GetHeader ¶ added in v1.0.6
func (m *DeleteRangeResponse) GetHeader() *ResponseHeader
func (*DeleteRangeResponse) Marshal ¶ added in v1.0.6
func (m *DeleteRangeResponse) Marshal() (data []byte, err error)
func (*DeleteRangeResponse) MarshalTo ¶ added in v1.0.6
func (m *DeleteRangeResponse) MarshalTo(data []byte) (int, error)
func (*DeleteRangeResponse) ProtoMessage ¶ added in v1.0.6
func (*DeleteRangeResponse) ProtoMessage()
func (*DeleteRangeResponse) Reset ¶ added in v1.0.6
func (m *DeleteRangeResponse) Reset()
func (*DeleteRangeResponse) Size ¶ added in v1.0.6
func (m *DeleteRangeResponse) Size() (n int)
func (*DeleteRangeResponse) String ¶ added in v1.0.6
func (m *DeleteRangeResponse) String() string
func (*DeleteRangeResponse) Unmarshal ¶ added in v1.0.6
func (m *DeleteRangeResponse) Unmarshal(data []byte) error
type EmptyResponse ¶
type EmptyResponse struct { }
func (*EmptyResponse) Marshal ¶
func (m *EmptyResponse) Marshal() (data []byte, err error)
func (*EmptyResponse) ProtoMessage ¶
func (*EmptyResponse) ProtoMessage()
func (*EmptyResponse) Reset ¶
func (m *EmptyResponse) Reset()
func (*EmptyResponse) Size ¶
func (m *EmptyResponse) Size() (n int)
func (*EmptyResponse) String ¶
func (m *EmptyResponse) String() string
func (*EmptyResponse) Unmarshal ¶
func (m *EmptyResponse) Unmarshal(data []byte) error
type HashRequest ¶
type HashRequest struct { }
func (*HashRequest) Marshal ¶
func (m *HashRequest) Marshal() (data []byte, err error)
func (*HashRequest) ProtoMessage ¶
func (*HashRequest) ProtoMessage()
func (*HashRequest) Reset ¶
func (m *HashRequest) Reset()
func (*HashRequest) Size ¶
func (m *HashRequest) Size() (n int)
func (*HashRequest) String ¶
func (m *HashRequest) String() string
func (*HashRequest) Unmarshal ¶
func (m *HashRequest) Unmarshal(data []byte) error
type HashResponse ¶
type HashResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"` Hash uint32 `protobuf:"varint,2,opt,name=hash,proto3" json:"hash,omitempty"` }
func (*HashResponse) GetHeader ¶
func (m *HashResponse) GetHeader() *ResponseHeader
func (*HashResponse) Marshal ¶
func (m *HashResponse) Marshal() (data []byte, err error)
func (*HashResponse) ProtoMessage ¶
func (*HashResponse) ProtoMessage()
func (*HashResponse) Reset ¶
func (m *HashResponse) Reset()
func (*HashResponse) Size ¶
func (m *HashResponse) Size() (n int)
func (*HashResponse) String ¶
func (m *HashResponse) String() string
func (*HashResponse) Unmarshal ¶
func (m *HashResponse) Unmarshal(data []byte) error
type InternalRaftRequest ¶ added in v1.1.2
type InternalRaftRequest struct { ID uint64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"` V2 *Request `protobuf:"bytes,2,opt,name=v2" json:"v2,omitempty"` Range *RangeRequest `protobuf:"bytes,3,opt,name=range" json:"range,omitempty"` Put *PutRequest `protobuf:"bytes,4,opt,name=put" json:"put,omitempty"` DeleteRange *DeleteRangeRequest `protobuf:"bytes,5,opt,name=delete_range" json:"delete_range,omitempty"` Txn *TxnRequest `protobuf:"bytes,6,opt,name=txn" json:"txn,omitempty"` Compaction *CompactionRequest `protobuf:"bytes,7,opt,name=compaction" json:"compaction,omitempty"` LeaseCreate *LeaseCreateRequest `protobuf:"bytes,8,opt,name=lease_create" json:"lease_create,omitempty"` LeaseRevoke *LeaseRevokeRequest `protobuf:"bytes,9,opt,name=lease_revoke" json:"lease_revoke,omitempty"` AuthEnable *AuthEnableRequest `protobuf:"bytes,10,opt,name=auth_enable" json:"auth_enable,omitempty"` }
An InternalRaftRequest is the union of all requests which can be sent via raft.
func (*InternalRaftRequest) Marshal ¶ added in v1.1.2
func (m *InternalRaftRequest) Marshal() (data []byte, err error)
func (*InternalRaftRequest) MarshalTo ¶ added in v1.1.2
func (m *InternalRaftRequest) MarshalTo(data []byte) (int, error)
func (*InternalRaftRequest) ProtoMessage ¶ added in v1.1.2
func (*InternalRaftRequest) ProtoMessage()
func (*InternalRaftRequest) Reset ¶ added in v1.1.2
func (m *InternalRaftRequest) Reset()
func (*InternalRaftRequest) Size ¶ added in v1.1.2
func (m *InternalRaftRequest) Size() (n int)
func (*InternalRaftRequest) String ¶ added in v1.1.2
func (m *InternalRaftRequest) String() string
func (*InternalRaftRequest) Unmarshal ¶ added in v1.1.2
func (m *InternalRaftRequest) Unmarshal(data []byte) error
type KVClient ¶
type KVClient interface { // Range gets the keys in the range from the store. Range(ctx context.Context, in *RangeRequest, opts ...grpc.CallOption) (*RangeResponse, error) // Put puts the given key into the store. // A put request increases the revision of the store, // and generates one event in the event history. Put(ctx context.Context, in *PutRequest, opts ...grpc.CallOption) (*PutResponse, error) // Delete deletes the given range from the store. // A delete request increase the revision of the store, // and generates one event in the event history. DeleteRange(ctx context.Context, in *DeleteRangeRequest, opts ...grpc.CallOption) (*DeleteRangeResponse, error) // Txn processes all the requests in one transaction. // A txn request increases the revision of the store, // and generates events with the same revision in the event history. // It is not allowed to modify the same key several times within one txn. Txn(ctx context.Context, in *TxnRequest, opts ...grpc.CallOption) (*TxnResponse, error) // Compact compacts the event history in etcd. User should compact the // event history periodically, or it will grow infinitely. Compact(ctx context.Context, in *CompactionRequest, opts ...grpc.CallOption) (*CompactionResponse, error) // Hash returns the hash of local KV state for consistency checking purpose. // This is designed for testing purpose. Do not use this in production when there // are ongoing transactions. Hash(ctx context.Context, in *HashRequest, opts ...grpc.CallOption) (*HashResponse, error) }
func NewKVClient ¶
func NewKVClient(cc *grpc.ClientConn) KVClient
type KVServer ¶
type KVServer interface { // Range gets the keys in the range from the store. Range(context.Context, *RangeRequest) (*RangeResponse, error) // Put puts the given key into the store. // A put request increases the revision of the store, // and generates one event in the event history. Put(context.Context, *PutRequest) (*PutResponse, error) // Delete deletes the given range from the store. // A delete request increase the revision of the store, // and generates one event in the event history. DeleteRange(context.Context, *DeleteRangeRequest) (*DeleteRangeResponse, error) // Txn processes all the requests in one transaction. // A txn request increases the revision of the store, // and generates events with the same revision in the event history. // It is not allowed to modify the same key several times within one txn. Txn(context.Context, *TxnRequest) (*TxnResponse, error) // Compact compacts the event history in etcd. User should compact the // event history periodically, or it will grow infinitely. Compact(context.Context, *CompactionRequest) (*CompactionResponse, error) // Hash returns the hash of local KV state for consistency checking purpose. // This is designed for testing purpose. Do not use this in production when there // are ongoing transactions. Hash(context.Context, *HashRequest) (*HashResponse, error) }
type LeaseClient ¶
type LeaseClient interface { // LeaseCreate creates a lease. A lease has a TTL. The lease will expire if the // server does not receive a keepAlive within TTL from the lease holder. // All keys attached to the lease will be expired and deleted if the lease expires. // The key expiration generates an event in event history. LeaseCreate(ctx context.Context, in *LeaseCreateRequest, opts ...grpc.CallOption) (*LeaseCreateResponse, error) // LeaseRevoke revokes a lease. All the key attached to the lease will be expired and deleted. LeaseRevoke(ctx context.Context, in *LeaseRevokeRequest, opts ...grpc.CallOption) (*LeaseRevokeResponse, error) // KeepAlive keeps the lease alive. LeaseKeepAlive(ctx context.Context, opts ...grpc.CallOption) (Lease_LeaseKeepAliveClient, error) }
func NewLeaseClient ¶
func NewLeaseClient(cc *grpc.ClientConn) LeaseClient
type LeaseCreateRequest ¶
type LeaseCreateRequest struct { // advisory ttl in seconds TTL int64 `protobuf:"varint,1,opt,name=TTL,proto3" json:"TTL,omitempty"` // requested ID to create; 0 lets lessor choose ID int64 `protobuf:"varint,2,opt,name=ID,proto3" json:"ID,omitempty"` }
func (*LeaseCreateRequest) Marshal ¶
func (m *LeaseCreateRequest) Marshal() (data []byte, err error)
func (*LeaseCreateRequest) MarshalTo ¶
func (m *LeaseCreateRequest) MarshalTo(data []byte) (int, error)
func (*LeaseCreateRequest) ProtoMessage ¶
func (*LeaseCreateRequest) ProtoMessage()
func (*LeaseCreateRequest) Reset ¶
func (m *LeaseCreateRequest) Reset()
func (*LeaseCreateRequest) Size ¶
func (m *LeaseCreateRequest) Size() (n int)
func (*LeaseCreateRequest) String ¶
func (m *LeaseCreateRequest) String() string
func (*LeaseCreateRequest) Unmarshal ¶
func (m *LeaseCreateRequest) Unmarshal(data []byte) error
type LeaseCreateResponse ¶
type LeaseCreateResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"` ID int64 `protobuf:"varint,2,opt,name=ID,proto3" json:"ID,omitempty"` // server decided ttl in second TTL int64 `protobuf:"varint,3,opt,name=TTL,proto3" json:"TTL,omitempty"` Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"` }
func (*LeaseCreateResponse) GetHeader ¶
func (m *LeaseCreateResponse) GetHeader() *ResponseHeader
func (*LeaseCreateResponse) Marshal ¶
func (m *LeaseCreateResponse) Marshal() (data []byte, err error)
func (*LeaseCreateResponse) MarshalTo ¶
func (m *LeaseCreateResponse) MarshalTo(data []byte) (int, error)
func (*LeaseCreateResponse) ProtoMessage ¶
func (*LeaseCreateResponse) ProtoMessage()
func (*LeaseCreateResponse) Reset ¶
func (m *LeaseCreateResponse) Reset()
func (*LeaseCreateResponse) Size ¶
func (m *LeaseCreateResponse) Size() (n int)
func (*LeaseCreateResponse) String ¶
func (m *LeaseCreateResponse) String() string
func (*LeaseCreateResponse) Unmarshal ¶
func (m *LeaseCreateResponse) Unmarshal(data []byte) error
type LeaseKeepAliveRequest ¶
type LeaseKeepAliveRequest struct {
ID int64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
}
func (*LeaseKeepAliveRequest) Marshal ¶
func (m *LeaseKeepAliveRequest) Marshal() (data []byte, err error)
func (*LeaseKeepAliveRequest) MarshalTo ¶
func (m *LeaseKeepAliveRequest) MarshalTo(data []byte) (int, error)
func (*LeaseKeepAliveRequest) ProtoMessage ¶
func (*LeaseKeepAliveRequest) ProtoMessage()
func (*LeaseKeepAliveRequest) Reset ¶
func (m *LeaseKeepAliveRequest) Reset()
func (*LeaseKeepAliveRequest) Size ¶
func (m *LeaseKeepAliveRequest) Size() (n int)
func (*LeaseKeepAliveRequest) String ¶
func (m *LeaseKeepAliveRequest) String() string
func (*LeaseKeepAliveRequest) Unmarshal ¶
func (m *LeaseKeepAliveRequest) Unmarshal(data []byte) error
type LeaseKeepAliveResponse ¶
type LeaseKeepAliveResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"` ID int64 `protobuf:"varint,2,opt,name=ID,proto3" json:"ID,omitempty"` TTL int64 `protobuf:"varint,3,opt,name=TTL,proto3" json:"TTL,omitempty"` }
func (*LeaseKeepAliveResponse) GetHeader ¶
func (m *LeaseKeepAliveResponse) GetHeader() *ResponseHeader
func (*LeaseKeepAliveResponse) Marshal ¶
func (m *LeaseKeepAliveResponse) Marshal() (data []byte, err error)
func (*LeaseKeepAliveResponse) MarshalTo ¶
func (m *LeaseKeepAliveResponse) MarshalTo(data []byte) (int, error)
func (*LeaseKeepAliveResponse) ProtoMessage ¶
func (*LeaseKeepAliveResponse) ProtoMessage()
func (*LeaseKeepAliveResponse) Reset ¶
func (m *LeaseKeepAliveResponse) Reset()
func (*LeaseKeepAliveResponse) Size ¶
func (m *LeaseKeepAliveResponse) Size() (n int)
func (*LeaseKeepAliveResponse) String ¶
func (m *LeaseKeepAliveResponse) String() string
func (*LeaseKeepAliveResponse) Unmarshal ¶
func (m *LeaseKeepAliveResponse) Unmarshal(data []byte) error
type LeaseRevokeRequest ¶
type LeaseRevokeRequest struct {
ID int64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
}
func (*LeaseRevokeRequest) Marshal ¶
func (m *LeaseRevokeRequest) Marshal() (data []byte, err error)
func (*LeaseRevokeRequest) MarshalTo ¶
func (m *LeaseRevokeRequest) MarshalTo(data []byte) (int, error)
func (*LeaseRevokeRequest) ProtoMessage ¶
func (*LeaseRevokeRequest) ProtoMessage()
func (*LeaseRevokeRequest) Reset ¶
func (m *LeaseRevokeRequest) Reset()
func (*LeaseRevokeRequest) Size ¶
func (m *LeaseRevokeRequest) Size() (n int)
func (*LeaseRevokeRequest) String ¶
func (m *LeaseRevokeRequest) String() string
func (*LeaseRevokeRequest) Unmarshal ¶
func (m *LeaseRevokeRequest) Unmarshal(data []byte) error
type LeaseRevokeResponse ¶
type LeaseRevokeResponse struct {
Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}
func (*LeaseRevokeResponse) GetHeader ¶
func (m *LeaseRevokeResponse) GetHeader() *ResponseHeader
func (*LeaseRevokeResponse) Marshal ¶
func (m *LeaseRevokeResponse) Marshal() (data []byte, err error)
func (*LeaseRevokeResponse) MarshalTo ¶
func (m *LeaseRevokeResponse) MarshalTo(data []byte) (int, error)
func (*LeaseRevokeResponse) ProtoMessage ¶
func (*LeaseRevokeResponse) ProtoMessage()
func (*LeaseRevokeResponse) Reset ¶
func (m *LeaseRevokeResponse) Reset()
func (*LeaseRevokeResponse) Size ¶
func (m *LeaseRevokeResponse) Size() (n int)
func (*LeaseRevokeResponse) String ¶
func (m *LeaseRevokeResponse) String() string
func (*LeaseRevokeResponse) Unmarshal ¶
func (m *LeaseRevokeResponse) Unmarshal(data []byte) error
type LeaseServer ¶
type LeaseServer interface { // LeaseCreate creates a lease. A lease has a TTL. The lease will expire if the // server does not receive a keepAlive within TTL from the lease holder. // All keys attached to the lease will be expired and deleted if the lease expires. // The key expiration generates an event in event history. LeaseCreate(context.Context, *LeaseCreateRequest) (*LeaseCreateResponse, error) // LeaseRevoke revokes a lease. All the key attached to the lease will be expired and deleted. LeaseRevoke(context.Context, *LeaseRevokeRequest) (*LeaseRevokeResponse, error) // KeepAlive keeps the lease alive. LeaseKeepAlive(Lease_LeaseKeepAliveServer) error }
type Lease_LeaseKeepAliveClient ¶
type Lease_LeaseKeepAliveClient interface { Send(*LeaseKeepAliveRequest) error Recv() (*LeaseKeepAliveResponse, error) grpc.ClientStream }
type Lease_LeaseKeepAliveServer ¶
type Lease_LeaseKeepAliveServer interface { Send(*LeaseKeepAliveResponse) error Recv() (*LeaseKeepAliveRequest, error) grpc.ServerStream }
type MaintenanceClient ¶
type MaintenanceClient interface { // TODO: move Hash from kv to Maintenance Defragment(ctx context.Context, in *DefragmentRequest, opts ...grpc.CallOption) (*DefragmentResponse, error) }
func NewMaintenanceClient ¶
func NewMaintenanceClient(cc *grpc.ClientConn) MaintenanceClient
type MaintenanceServer ¶
type MaintenanceServer interface { // TODO: move Hash from kv to Maintenance Defragment(context.Context, *DefragmentRequest) (*DefragmentResponse, error) }
type Member ¶
type Member struct { ID uint64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"` // If the member is not started, name will be an empty string. Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` IsLeader bool `protobuf:"varint,3,opt,name=IsLeader,proto3" json:"IsLeader,omitempty"` PeerURLs []string `protobuf:"bytes,4,rep,name=peerURLs" json:"peerURLs,omitempty"` // If the member is not started, client_URLs will be an zero length // string array. ClientURLs []string `protobuf:"bytes,5,rep,name=clientURLs" json:"clientURLs,omitempty"` }
func (*Member) ProtoMessage ¶
func (*Member) ProtoMessage()
type MemberAddRequest ¶
type MemberAddRequest struct {
PeerURLs []string `protobuf:"bytes,1,rep,name=peerURLs" json:"peerURLs,omitempty"`
}
func (*MemberAddRequest) Marshal ¶
func (m *MemberAddRequest) Marshal() (data []byte, err error)
func (*MemberAddRequest) ProtoMessage ¶
func (*MemberAddRequest) ProtoMessage()
func (*MemberAddRequest) Reset ¶
func (m *MemberAddRequest) Reset()
func (*MemberAddRequest) Size ¶
func (m *MemberAddRequest) Size() (n int)
func (*MemberAddRequest) String ¶
func (m *MemberAddRequest) String() string
func (*MemberAddRequest) Unmarshal ¶
func (m *MemberAddRequest) Unmarshal(data []byte) error
type MemberAddResponse ¶
type MemberAddResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"` Member *Member `protobuf:"bytes,2,opt,name=member" json:"member,omitempty"` }
func (*MemberAddResponse) GetHeader ¶
func (m *MemberAddResponse) GetHeader() *ResponseHeader
func (*MemberAddResponse) GetMember ¶
func (m *MemberAddResponse) GetMember() *Member
func (*MemberAddResponse) Marshal ¶
func (m *MemberAddResponse) Marshal() (data []byte, err error)
func (*MemberAddResponse) MarshalTo ¶
func (m *MemberAddResponse) MarshalTo(data []byte) (int, error)
func (*MemberAddResponse) ProtoMessage ¶
func (*MemberAddResponse) ProtoMessage()
func (*MemberAddResponse) Reset ¶
func (m *MemberAddResponse) Reset()
func (*MemberAddResponse) Size ¶
func (m *MemberAddResponse) Size() (n int)
func (*MemberAddResponse) String ¶
func (m *MemberAddResponse) String() string
func (*MemberAddResponse) Unmarshal ¶
func (m *MemberAddResponse) Unmarshal(data []byte) error
type MemberListRequest ¶
type MemberListRequest struct { }
func (*MemberListRequest) Marshal ¶
func (m *MemberListRequest) Marshal() (data []byte, err error)
func (*MemberListRequest) MarshalTo ¶
func (m *MemberListRequest) MarshalTo(data []byte) (int, error)
func (*MemberListRequest) ProtoMessage ¶
func (*MemberListRequest) ProtoMessage()
func (*MemberListRequest) Reset ¶
func (m *MemberListRequest) Reset()
func (*MemberListRequest) Size ¶
func (m *MemberListRequest) Size() (n int)
func (*MemberListRequest) String ¶
func (m *MemberListRequest) String() string
func (*MemberListRequest) Unmarshal ¶
func (m *MemberListRequest) Unmarshal(data []byte) error
type MemberListResponse ¶
type MemberListResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"` Members []*Member `protobuf:"bytes,2,rep,name=members" json:"members,omitempty"` }
func (*MemberListResponse) GetHeader ¶
func (m *MemberListResponse) GetHeader() *ResponseHeader
func (*MemberListResponse) GetMembers ¶
func (m *MemberListResponse) GetMembers() []*Member
func (*MemberListResponse) Marshal ¶
func (m *MemberListResponse) Marshal() (data []byte, err error)
func (*MemberListResponse) MarshalTo ¶
func (m *MemberListResponse) MarshalTo(data []byte) (int, error)
func (*MemberListResponse) ProtoMessage ¶
func (*MemberListResponse) ProtoMessage()
func (*MemberListResponse) Reset ¶
func (m *MemberListResponse) Reset()
func (*MemberListResponse) Size ¶
func (m *MemberListResponse) Size() (n int)
func (*MemberListResponse) String ¶
func (m *MemberListResponse) String() string
func (*MemberListResponse) Unmarshal ¶
func (m *MemberListResponse) Unmarshal(data []byte) error
type MemberRemoveRequest ¶
type MemberRemoveRequest struct {
ID uint64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
}
func (*MemberRemoveRequest) Marshal ¶
func (m *MemberRemoveRequest) Marshal() (data []byte, err error)
func (*MemberRemoveRequest) MarshalTo ¶
func (m *MemberRemoveRequest) MarshalTo(data []byte) (int, error)
func (*MemberRemoveRequest) ProtoMessage ¶
func (*MemberRemoveRequest) ProtoMessage()
func (*MemberRemoveRequest) Reset ¶
func (m *MemberRemoveRequest) Reset()
func (*MemberRemoveRequest) Size ¶
func (m *MemberRemoveRequest) Size() (n int)
func (*MemberRemoveRequest) String ¶
func (m *MemberRemoveRequest) String() string
func (*MemberRemoveRequest) Unmarshal ¶
func (m *MemberRemoveRequest) Unmarshal(data []byte) error
type MemberRemoveResponse ¶
type MemberRemoveResponse struct {
Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}
func (*MemberRemoveResponse) GetHeader ¶
func (m *MemberRemoveResponse) GetHeader() *ResponseHeader
func (*MemberRemoveResponse) Marshal ¶
func (m *MemberRemoveResponse) Marshal() (data []byte, err error)
func (*MemberRemoveResponse) MarshalTo ¶
func (m *MemberRemoveResponse) MarshalTo(data []byte) (int, error)
func (*MemberRemoveResponse) ProtoMessage ¶
func (*MemberRemoveResponse) ProtoMessage()
func (*MemberRemoveResponse) Reset ¶
func (m *MemberRemoveResponse) Reset()
func (*MemberRemoveResponse) Size ¶
func (m *MemberRemoveResponse) Size() (n int)
func (*MemberRemoveResponse) String ¶
func (m *MemberRemoveResponse) String() string
func (*MemberRemoveResponse) Unmarshal ¶
func (m *MemberRemoveResponse) Unmarshal(data []byte) error
type MemberUpdateRequest ¶
type MemberUpdateRequest struct { ID uint64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"` PeerURLs []string `protobuf:"bytes,2,rep,name=peerURLs" json:"peerURLs,omitempty"` }
func (*MemberUpdateRequest) Marshal ¶
func (m *MemberUpdateRequest) Marshal() (data []byte, err error)
func (*MemberUpdateRequest) MarshalTo ¶
func (m *MemberUpdateRequest) MarshalTo(data []byte) (int, error)
func (*MemberUpdateRequest) ProtoMessage ¶
func (*MemberUpdateRequest) ProtoMessage()
func (*MemberUpdateRequest) Reset ¶
func (m *MemberUpdateRequest) Reset()
func (*MemberUpdateRequest) Size ¶
func (m *MemberUpdateRequest) Size() (n int)
func (*MemberUpdateRequest) String ¶
func (m *MemberUpdateRequest) String() string
func (*MemberUpdateRequest) Unmarshal ¶
func (m *MemberUpdateRequest) Unmarshal(data []byte) error
type MemberUpdateResponse ¶
type MemberUpdateResponse struct {
Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}
func (*MemberUpdateResponse) GetHeader ¶
func (m *MemberUpdateResponse) GetHeader() *ResponseHeader
func (*MemberUpdateResponse) Marshal ¶
func (m *MemberUpdateResponse) Marshal() (data []byte, err error)
func (*MemberUpdateResponse) MarshalTo ¶
func (m *MemberUpdateResponse) MarshalTo(data []byte) (int, error)
func (*MemberUpdateResponse) ProtoMessage ¶
func (*MemberUpdateResponse) ProtoMessage()
func (*MemberUpdateResponse) Reset ¶
func (m *MemberUpdateResponse) Reset()
func (*MemberUpdateResponse) Size ¶
func (m *MemberUpdateResponse) Size() (n int)
func (*MemberUpdateResponse) String ¶
func (m *MemberUpdateResponse) String() string
func (*MemberUpdateResponse) Unmarshal ¶
func (m *MemberUpdateResponse) Unmarshal(data []byte) error
type Metadata ¶
type Metadata struct { NodeID uint64 `protobuf:"varint,1,opt,name=NodeID" json:"NodeID"` ClusterID uint64 `protobuf:"varint,2,opt,name=ClusterID" json:"ClusterID"` XXX_unrecognized []byte `json:"-"` }
func (*Metadata) ProtoMessage ¶
func (*Metadata) ProtoMessage()
type PutRequest ¶ added in v1.0.6
type PutRequest struct { Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` Lease int64 `protobuf:"varint,3,opt,name=lease,proto3" json:"lease,omitempty"` }
func (*PutRequest) Marshal ¶ added in v1.0.6
func (m *PutRequest) Marshal() (data []byte, err error)
func (*PutRequest) MarshalTo ¶ added in v1.0.6
func (m *PutRequest) MarshalTo(data []byte) (int, error)
func (*PutRequest) ProtoMessage ¶ added in v1.0.6
func (*PutRequest) ProtoMessage()
func (*PutRequest) Reset ¶ added in v1.0.6
func (m *PutRequest) Reset()
func (*PutRequest) Size ¶ added in v1.0.6
func (m *PutRequest) Size() (n int)
func (*PutRequest) String ¶ added in v1.0.6
func (m *PutRequest) String() string
func (*PutRequest) Unmarshal ¶ added in v1.0.6
func (m *PutRequest) Unmarshal(data []byte) error
type PutResponse ¶ added in v1.0.6
type PutResponse struct {
Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}
func (*PutResponse) GetHeader ¶ added in v1.0.6
func (m *PutResponse) GetHeader() *ResponseHeader
func (*PutResponse) Marshal ¶ added in v1.0.6
func (m *PutResponse) Marshal() (data []byte, err error)
func (*PutResponse) MarshalTo ¶ added in v1.0.6
func (m *PutResponse) MarshalTo(data []byte) (int, error)
func (*PutResponse) ProtoMessage ¶ added in v1.0.6
func (*PutResponse) ProtoMessage()
func (*PutResponse) Reset ¶ added in v1.0.6
func (m *PutResponse) Reset()
func (*PutResponse) Size ¶ added in v1.0.6
func (m *PutResponse) Size() (n int)
func (*PutResponse) String ¶ added in v1.0.6
func (m *PutResponse) String() string
func (*PutResponse) Unmarshal ¶ added in v1.0.6
func (m *PutResponse) Unmarshal(data []byte) error
type RangeRequest ¶ added in v1.0.6
type RangeRequest struct { // if the range_end is not given, the request returns the key. Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // if the range_end is given, it gets the keys in range [key, range_end) // if range_end is nonempty, otherwise it returns all keys >= key. RangeEnd []byte `protobuf:"bytes,2,opt,name=range_end,proto3" json:"range_end,omitempty"` // limit the number of keys returned. Limit int64 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"` // range over the store at the given revision. // if revision is less or equal to zero, range over the newest store. // if the revision has been compacted, ErrCompaction will be returned in // response. Revision int64 `protobuf:"varint,4,opt,name=revision,proto3" json:"revision,omitempty"` // sort_order is the requested order for returned the results SortOrder RangeRequest_SortOrder `protobuf:"varint,5,opt,name=sort_order,proto3,enum=etcdserverpb.RangeRequest_SortOrder" json:"sort_order,omitempty"` // sort_target is the kv field to use for sorting SortTarget RangeRequest_SortTarget `protobuf:"varint,6,opt,name=sort_target,proto3,enum=etcdserverpb.RangeRequest_SortTarget" json:"sort_target,omitempty"` // range request is linearizable by default. Linearizable requests has a higher // latency and lower throughput than serializable request. // To reduce latency, serializable can be set. If serializable is set, range request // will be serializable, but not linearizable with other requests. // Serializable range can be served locally without waiting for other nodes in the cluster. Serializable bool `protobuf:"varint,7,opt,name=serializable,proto3" json:"serializable,omitempty"` }
func (*RangeRequest) Marshal ¶ added in v1.0.6
func (m *RangeRequest) Marshal() (data []byte, err error)
func (*RangeRequest) MarshalTo ¶ added in v1.0.6
func (m *RangeRequest) MarshalTo(data []byte) (int, error)
func (*RangeRequest) ProtoMessage ¶ added in v1.0.6
func (*RangeRequest) ProtoMessage()
func (*RangeRequest) Reset ¶ added in v1.0.6
func (m *RangeRequest) Reset()
func (*RangeRequest) Size ¶ added in v1.0.6
func (m *RangeRequest) Size() (n int)
func (*RangeRequest) String ¶ added in v1.0.6
func (m *RangeRequest) String() string
func (*RangeRequest) Unmarshal ¶ added in v1.0.6
func (m *RangeRequest) Unmarshal(data []byte) error
type RangeRequest_SortOrder ¶
type RangeRequest_SortOrder int32
const ( RangeRequest_NONE RangeRequest_SortOrder = 0 RangeRequest_ASCEND RangeRequest_SortOrder = 1 RangeRequest_DESCEND RangeRequest_SortOrder = 2 )
func (RangeRequest_SortOrder) String ¶
func (x RangeRequest_SortOrder) String() string
type RangeRequest_SortTarget ¶
type RangeRequest_SortTarget int32
const ( RangeRequest_KEY RangeRequest_SortTarget = 0 RangeRequest_VERSION RangeRequest_SortTarget = 1 RangeRequest_CREATE RangeRequest_SortTarget = 2 RangeRequest_MOD RangeRequest_SortTarget = 3 RangeRequest_VALUE RangeRequest_SortTarget = 4 )
func (RangeRequest_SortTarget) String ¶
func (x RangeRequest_SortTarget) String() string
type RangeResponse ¶ added in v1.0.6
type RangeResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"` Kvs []*storagepb.KeyValue `protobuf:"bytes,2,rep,name=kvs" json:"kvs,omitempty"` // more indicates if there are more keys to return in the requested range. More bool `protobuf:"varint,3,opt,name=more,proto3" json:"more,omitempty"` }
func (*RangeResponse) GetHeader ¶ added in v1.0.6
func (m *RangeResponse) GetHeader() *ResponseHeader
func (*RangeResponse) GetKvs ¶ added in v1.0.6
func (m *RangeResponse) GetKvs() []*storagepb.KeyValue
func (*RangeResponse) Marshal ¶ added in v1.0.6
func (m *RangeResponse) Marshal() (data []byte, err error)
func (*RangeResponse) MarshalTo ¶ added in v1.0.6
func (m *RangeResponse) MarshalTo(data []byte) (int, error)
func (*RangeResponse) ProtoMessage ¶ added in v1.0.6
func (*RangeResponse) ProtoMessage()
func (*RangeResponse) Reset ¶ added in v1.0.6
func (m *RangeResponse) Reset()
func (*RangeResponse) Size ¶ added in v1.0.6
func (m *RangeResponse) Size() (n int)
func (*RangeResponse) String ¶ added in v1.0.6
func (m *RangeResponse) String() string
func (*RangeResponse) Unmarshal ¶ added in v1.0.6
func (m *RangeResponse) Unmarshal(data []byte) error
type Request ¶
type Request struct { ID uint64 `protobuf:"varint,1,opt,name=ID" json:"ID"` Method string `protobuf:"bytes,2,opt,name=Method" json:"Method"` Path string `protobuf:"bytes,3,opt,name=Path" json:"Path"` Val string `protobuf:"bytes,4,opt,name=Val" json:"Val"` Dir bool `protobuf:"varint,5,opt,name=Dir" json:"Dir"` PrevValue string `protobuf:"bytes,6,opt,name=PrevValue" json:"PrevValue"` PrevIndex uint64 `protobuf:"varint,7,opt,name=PrevIndex" json:"PrevIndex"` PrevExist *bool `protobuf:"varint,8,opt,name=PrevExist" json:"PrevExist,omitempty"` Expiration int64 `protobuf:"varint,9,opt,name=Expiration" json:"Expiration"` Wait bool `protobuf:"varint,10,opt,name=Wait" json:"Wait"` Since uint64 `protobuf:"varint,11,opt,name=Since" json:"Since"` Recursive bool `protobuf:"varint,12,opt,name=Recursive" json:"Recursive"` Sorted bool `protobuf:"varint,13,opt,name=Sorted" json:"Sorted"` Quorum bool `protobuf:"varint,14,opt,name=Quorum" json:"Quorum"` Time int64 `protobuf:"varint,15,opt,name=Time" json:"Time"` Stream bool `protobuf:"varint,16,opt,name=Stream" json:"Stream"` Refresh *bool `protobuf:"varint,17,opt,name=Refresh" json:"Refresh,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*Request) ProtoMessage ¶
func (*Request) ProtoMessage()
type RequestUnion ¶ added in v1.0.6
type RequestUnion struct { // Types that are valid to be assigned to Request: // *RequestUnion_RequestRange // *RequestUnion_RequestPut // *RequestUnion_RequestDeleteRange Request isRequestUnion_Request `protobuf_oneof:"request"` }
func (*RequestUnion) GetRequest ¶ added in v1.1.4
func (m *RequestUnion) GetRequest() isRequestUnion_Request
func (*RequestUnion) GetRequestDeleteRange ¶ added in v1.0.6
func (m *RequestUnion) GetRequestDeleteRange() *DeleteRangeRequest
func (*RequestUnion) GetRequestPut ¶ added in v1.0.6
func (m *RequestUnion) GetRequestPut() *PutRequest
func (*RequestUnion) GetRequestRange ¶ added in v1.0.6
func (m *RequestUnion) GetRequestRange() *RangeRequest
func (*RequestUnion) Marshal ¶ added in v1.0.6
func (m *RequestUnion) Marshal() (data []byte, err error)
func (*RequestUnion) MarshalTo ¶ added in v1.0.6
func (m *RequestUnion) MarshalTo(data []byte) (int, error)
func (*RequestUnion) ProtoMessage ¶ added in v1.0.6
func (*RequestUnion) ProtoMessage()
func (*RequestUnion) Reset ¶ added in v1.0.6
func (m *RequestUnion) Reset()
func (*RequestUnion) Size ¶ added in v1.0.6
func (m *RequestUnion) Size() (n int)
func (*RequestUnion) String ¶ added in v1.0.6
func (m *RequestUnion) String() string
func (*RequestUnion) Unmarshal ¶ added in v1.0.6
func (m *RequestUnion) Unmarshal(data []byte) error
type RequestUnion_RequestDeleteRange ¶ added in v1.1.4
type RequestUnion_RequestDeleteRange struct {
RequestDeleteRange *DeleteRangeRequest `protobuf:"bytes,3,opt,name=request_delete_range,oneof"`
}
func (*RequestUnion_RequestDeleteRange) MarshalTo ¶ added in v1.1.4
func (m *RequestUnion_RequestDeleteRange) MarshalTo(data []byte) (int, error)
func (*RequestUnion_RequestDeleteRange) Size ¶ added in v1.1.4
func (m *RequestUnion_RequestDeleteRange) Size() (n int)
type RequestUnion_RequestPut ¶ added in v1.1.4
type RequestUnion_RequestPut struct {
RequestPut *PutRequest `protobuf:"bytes,2,opt,name=request_put,oneof"`
}
func (*RequestUnion_RequestPut) MarshalTo ¶ added in v1.1.4
func (m *RequestUnion_RequestPut) MarshalTo(data []byte) (int, error)
func (*RequestUnion_RequestPut) Size ¶ added in v1.1.4
func (m *RequestUnion_RequestPut) Size() (n int)
type RequestUnion_RequestRange ¶ added in v1.1.4
type RequestUnion_RequestRange struct {
RequestRange *RangeRequest `protobuf:"bytes,1,opt,name=request_range,oneof"`
}
func (*RequestUnion_RequestRange) MarshalTo ¶ added in v1.1.4
func (m *RequestUnion_RequestRange) MarshalTo(data []byte) (int, error)
func (*RequestUnion_RequestRange) Size ¶ added in v1.1.4
func (m *RequestUnion_RequestRange) Size() (n int)
type ResponseHeader ¶ added in v1.0.6
type ResponseHeader struct { ClusterId uint64 `protobuf:"varint,1,opt,name=cluster_id,proto3" json:"cluster_id,omitempty"` MemberId uint64 `protobuf:"varint,2,opt,name=member_id,proto3" json:"member_id,omitempty"` // revision of the store when the request was applied. Revision int64 `protobuf:"varint,3,opt,name=revision,proto3" json:"revision,omitempty"` // term of raft when the request was applied. RaftTerm uint64 `protobuf:"varint,4,opt,name=raft_term,proto3" json:"raft_term,omitempty"` }
func (*ResponseHeader) Marshal ¶ added in v1.0.6
func (m *ResponseHeader) Marshal() (data []byte, err error)
func (*ResponseHeader) MarshalTo ¶ added in v1.0.6
func (m *ResponseHeader) MarshalTo(data []byte) (int, error)
func (*ResponseHeader) ProtoMessage ¶ added in v1.0.6
func (*ResponseHeader) ProtoMessage()
func (*ResponseHeader) Reset ¶ added in v1.0.6
func (m *ResponseHeader) Reset()
func (*ResponseHeader) Size ¶ added in v1.0.6
func (m *ResponseHeader) Size() (n int)
func (*ResponseHeader) String ¶ added in v1.0.6
func (m *ResponseHeader) String() string
func (*ResponseHeader) Unmarshal ¶ added in v1.0.6
func (m *ResponseHeader) Unmarshal(data []byte) error
type ResponseUnion ¶ added in v1.0.6
type ResponseUnion struct { // Types that are valid to be assigned to Response: // *ResponseUnion_ResponseRange // *ResponseUnion_ResponsePut // *ResponseUnion_ResponseDeleteRange Response isResponseUnion_Response `protobuf_oneof:"response"` }
func (*ResponseUnion) GetResponse ¶ added in v1.1.4
func (m *ResponseUnion) GetResponse() isResponseUnion_Response
func (*ResponseUnion) GetResponseDeleteRange ¶ added in v1.0.6
func (m *ResponseUnion) GetResponseDeleteRange() *DeleteRangeResponse
func (*ResponseUnion) GetResponsePut ¶ added in v1.0.6
func (m *ResponseUnion) GetResponsePut() *PutResponse
func (*ResponseUnion) GetResponseRange ¶ added in v1.1.2
func (m *ResponseUnion) GetResponseRange() *RangeResponse
func (*ResponseUnion) Marshal ¶ added in v1.0.6
func (m *ResponseUnion) Marshal() (data []byte, err error)
func (*ResponseUnion) MarshalTo ¶ added in v1.0.6
func (m *ResponseUnion) MarshalTo(data []byte) (int, error)
func (*ResponseUnion) ProtoMessage ¶ added in v1.0.6
func (*ResponseUnion) ProtoMessage()
func (*ResponseUnion) Reset ¶ added in v1.0.6
func (m *ResponseUnion) Reset()
func (*ResponseUnion) Size ¶ added in v1.0.6
func (m *ResponseUnion) Size() (n int)
func (*ResponseUnion) String ¶ added in v1.0.6
func (m *ResponseUnion) String() string
func (*ResponseUnion) Unmarshal ¶ added in v1.0.6
func (m *ResponseUnion) Unmarshal(data []byte) error
type ResponseUnion_ResponseDeleteRange ¶ added in v1.1.4
type ResponseUnion_ResponseDeleteRange struct {
ResponseDeleteRange *DeleteRangeResponse `protobuf:"bytes,3,opt,name=response_delete_range,oneof"`
}
func (*ResponseUnion_ResponseDeleteRange) MarshalTo ¶ added in v1.1.4
func (m *ResponseUnion_ResponseDeleteRange) MarshalTo(data []byte) (int, error)
func (*ResponseUnion_ResponseDeleteRange) Size ¶ added in v1.1.4
func (m *ResponseUnion_ResponseDeleteRange) Size() (n int)
type ResponseUnion_ResponsePut ¶ added in v1.1.4
type ResponseUnion_ResponsePut struct {
ResponsePut *PutResponse `protobuf:"bytes,2,opt,name=response_put,oneof"`
}
func (*ResponseUnion_ResponsePut) MarshalTo ¶ added in v1.1.4
func (m *ResponseUnion_ResponsePut) MarshalTo(data []byte) (int, error)
func (*ResponseUnion_ResponsePut) Size ¶ added in v1.1.4
func (m *ResponseUnion_ResponsePut) Size() (n int)
type ResponseUnion_ResponseRange ¶ added in v1.1.4
type ResponseUnion_ResponseRange struct {
ResponseRange *RangeResponse `protobuf:"bytes,1,opt,name=response_range,oneof"`
}
func (*ResponseUnion_ResponseRange) MarshalTo ¶ added in v1.1.4
func (m *ResponseUnion_ResponseRange) MarshalTo(data []byte) (int, error)
func (*ResponseUnion_ResponseRange) Size ¶ added in v1.1.4
func (m *ResponseUnion_ResponseRange) Size() (n int)
type RoleAddRequest ¶
type RoleAddRequest struct { }
func (*RoleAddRequest) Marshal ¶
func (m *RoleAddRequest) Marshal() (data []byte, err error)
func (*RoleAddRequest) ProtoMessage ¶
func (*RoleAddRequest) ProtoMessage()
func (*RoleAddRequest) Reset ¶
func (m *RoleAddRequest) Reset()
func (*RoleAddRequest) Size ¶
func (m *RoleAddRequest) Size() (n int)
func (*RoleAddRequest) String ¶
func (m *RoleAddRequest) String() string
func (*RoleAddRequest) Unmarshal ¶
func (m *RoleAddRequest) Unmarshal(data []byte) error
type RoleAddResponse ¶
type RoleAddResponse struct {
Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}
func (*RoleAddResponse) GetHeader ¶
func (m *RoleAddResponse) GetHeader() *ResponseHeader
func (*RoleAddResponse) Marshal ¶
func (m *RoleAddResponse) Marshal() (data []byte, err error)
func (*RoleAddResponse) ProtoMessage ¶
func (*RoleAddResponse) ProtoMessage()
func (*RoleAddResponse) Reset ¶
func (m *RoleAddResponse) Reset()
func (*RoleAddResponse) Size ¶
func (m *RoleAddResponse) Size() (n int)
func (*RoleAddResponse) String ¶
func (m *RoleAddResponse) String() string
func (*RoleAddResponse) Unmarshal ¶
func (m *RoleAddResponse) Unmarshal(data []byte) error
type RoleDeleteRequest ¶
type RoleDeleteRequest struct { }
func (*RoleDeleteRequest) Marshal ¶
func (m *RoleDeleteRequest) Marshal() (data []byte, err error)
func (*RoleDeleteRequest) MarshalTo ¶
func (m *RoleDeleteRequest) MarshalTo(data []byte) (int, error)
func (*RoleDeleteRequest) ProtoMessage ¶
func (*RoleDeleteRequest) ProtoMessage()
func (*RoleDeleteRequest) Reset ¶
func (m *RoleDeleteRequest) Reset()
func (*RoleDeleteRequest) Size ¶
func (m *RoleDeleteRequest) Size() (n int)
func (*RoleDeleteRequest) String ¶
func (m *RoleDeleteRequest) String() string
func (*RoleDeleteRequest) Unmarshal ¶
func (m *RoleDeleteRequest) Unmarshal(data []byte) error
type RoleDeleteResponse ¶
type RoleDeleteResponse struct {
Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}
func (*RoleDeleteResponse) GetHeader ¶
func (m *RoleDeleteResponse) GetHeader() *ResponseHeader
func (*RoleDeleteResponse) Marshal ¶
func (m *RoleDeleteResponse) Marshal() (data []byte, err error)
func (*RoleDeleteResponse) MarshalTo ¶
func (m *RoleDeleteResponse) MarshalTo(data []byte) (int, error)
func (*RoleDeleteResponse) ProtoMessage ¶
func (*RoleDeleteResponse) ProtoMessage()
func (*RoleDeleteResponse) Reset ¶
func (m *RoleDeleteResponse) Reset()
func (*RoleDeleteResponse) Size ¶
func (m *RoleDeleteResponse) Size() (n int)
func (*RoleDeleteResponse) String ¶
func (m *RoleDeleteResponse) String() string
func (*RoleDeleteResponse) Unmarshal ¶
func (m *RoleDeleteResponse) Unmarshal(data []byte) error
type RoleGetRequest ¶
type RoleGetRequest struct { }
func (*RoleGetRequest) Marshal ¶
func (m *RoleGetRequest) Marshal() (data []byte, err error)
func (*RoleGetRequest) ProtoMessage ¶
func (*RoleGetRequest) ProtoMessage()
func (*RoleGetRequest) Reset ¶
func (m *RoleGetRequest) Reset()
func (*RoleGetRequest) Size ¶
func (m *RoleGetRequest) Size() (n int)
func (*RoleGetRequest) String ¶
func (m *RoleGetRequest) String() string
func (*RoleGetRequest) Unmarshal ¶
func (m *RoleGetRequest) Unmarshal(data []byte) error
type RoleGetResponse ¶
type RoleGetResponse struct {
Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}
func (*RoleGetResponse) GetHeader ¶
func (m *RoleGetResponse) GetHeader() *ResponseHeader
func (*RoleGetResponse) Marshal ¶
func (m *RoleGetResponse) Marshal() (data []byte, err error)
func (*RoleGetResponse) ProtoMessage ¶
func (*RoleGetResponse) ProtoMessage()
func (*RoleGetResponse) Reset ¶
func (m *RoleGetResponse) Reset()
func (*RoleGetResponse) Size ¶
func (m *RoleGetResponse) Size() (n int)
func (*RoleGetResponse) String ¶
func (m *RoleGetResponse) String() string
func (*RoleGetResponse) Unmarshal ¶
func (m *RoleGetResponse) Unmarshal(data []byte) error
type RoleGrantRequest ¶
type RoleGrantRequest struct { }
func (*RoleGrantRequest) Marshal ¶
func (m *RoleGrantRequest) Marshal() (data []byte, err error)
func (*RoleGrantRequest) ProtoMessage ¶
func (*RoleGrantRequest) ProtoMessage()
func (*RoleGrantRequest) Reset ¶
func (m *RoleGrantRequest) Reset()
func (*RoleGrantRequest) Size ¶
func (m *RoleGrantRequest) Size() (n int)
func (*RoleGrantRequest) String ¶
func (m *RoleGrantRequest) String() string
func (*RoleGrantRequest) Unmarshal ¶
func (m *RoleGrantRequest) Unmarshal(data []byte) error
type RoleGrantResponse ¶
type RoleGrantResponse struct {
Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}
func (*RoleGrantResponse) GetHeader ¶
func (m *RoleGrantResponse) GetHeader() *ResponseHeader
func (*RoleGrantResponse) Marshal ¶
func (m *RoleGrantResponse) Marshal() (data []byte, err error)
func (*RoleGrantResponse) MarshalTo ¶
func (m *RoleGrantResponse) MarshalTo(data []byte) (int, error)
func (*RoleGrantResponse) ProtoMessage ¶
func (*RoleGrantResponse) ProtoMessage()
func (*RoleGrantResponse) Reset ¶
func (m *RoleGrantResponse) Reset()
func (*RoleGrantResponse) Size ¶
func (m *RoleGrantResponse) Size() (n int)
func (*RoleGrantResponse) String ¶
func (m *RoleGrantResponse) String() string
func (*RoleGrantResponse) Unmarshal ¶
func (m *RoleGrantResponse) Unmarshal(data []byte) error
type RoleRevokeRequest ¶
type RoleRevokeRequest struct { }
func (*RoleRevokeRequest) Marshal ¶
func (m *RoleRevokeRequest) Marshal() (data []byte, err error)
func (*RoleRevokeRequest) MarshalTo ¶
func (m *RoleRevokeRequest) MarshalTo(data []byte) (int, error)
func (*RoleRevokeRequest) ProtoMessage ¶
func (*RoleRevokeRequest) ProtoMessage()
func (*RoleRevokeRequest) Reset ¶
func (m *RoleRevokeRequest) Reset()
func (*RoleRevokeRequest) Size ¶
func (m *RoleRevokeRequest) Size() (n int)
func (*RoleRevokeRequest) String ¶
func (m *RoleRevokeRequest) String() string
func (*RoleRevokeRequest) Unmarshal ¶
func (m *RoleRevokeRequest) Unmarshal(data []byte) error
type RoleRevokeResponse ¶
type RoleRevokeResponse struct {
Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}
func (*RoleRevokeResponse) GetHeader ¶
func (m *RoleRevokeResponse) GetHeader() *ResponseHeader
func (*RoleRevokeResponse) Marshal ¶
func (m *RoleRevokeResponse) Marshal() (data []byte, err error)
func (*RoleRevokeResponse) MarshalTo ¶
func (m *RoleRevokeResponse) MarshalTo(data []byte) (int, error)
func (*RoleRevokeResponse) ProtoMessage ¶
func (*RoleRevokeResponse) ProtoMessage()
func (*RoleRevokeResponse) Reset ¶
func (m *RoleRevokeResponse) Reset()
func (*RoleRevokeResponse) Size ¶
func (m *RoleRevokeResponse) Size() (n int)
func (*RoleRevokeResponse) String ¶
func (m *RoleRevokeResponse) String() string
func (*RoleRevokeResponse) Unmarshal ¶
func (m *RoleRevokeResponse) Unmarshal(data []byte) error
type TxnRequest ¶ added in v1.1.2
type TxnRequest struct { Compare []*Compare `protobuf:"bytes,1,rep,name=compare" json:"compare,omitempty"` Success []*RequestUnion `protobuf:"bytes,2,rep,name=success" json:"success,omitempty"` Failure []*RequestUnion `protobuf:"bytes,3,rep,name=failure" json:"failure,omitempty"` }
From google paxosdb paper: Our implementation hinges around a powerful primitive which we call MultiOp. All other database operations except for iteration are implemented as a single call to MultiOp. A MultiOp is applied atomically and consists of three components: 1. A list of tests called guard. Each test in guard checks a single entry in the database. It may check for the absence or presence of a value, or compare with a given value. Two different tests in the guard may apply to the same or different entries in the database. All tests in the guard are applied and MultiOp returns the results. If all tests are true, MultiOp executes t op (see item 2 below), otherwise it executes f op (see item 3 below). 2. A list of database operations called t op. Each operation in the list is either an insert, delete, or lookup operation, and applies to a single database entry. Two different operations in the list may apply to the same or different entries in the database. These operations are executed if guard evaluates to true. 3. A list of database operations called f op. Like t op, but executed if guard evaluates to false.
func (*TxnRequest) GetCompare ¶ added in v1.1.2
func (m *TxnRequest) GetCompare() []*Compare
func (*TxnRequest) GetFailure ¶ added in v1.1.2
func (m *TxnRequest) GetFailure() []*RequestUnion
func (*TxnRequest) GetSuccess ¶ added in v1.1.2
func (m *TxnRequest) GetSuccess() []*RequestUnion
func (*TxnRequest) Marshal ¶ added in v1.1.2
func (m *TxnRequest) Marshal() (data []byte, err error)
func (*TxnRequest) MarshalTo ¶ added in v1.1.2
func (m *TxnRequest) MarshalTo(data []byte) (int, error)
func (*TxnRequest) ProtoMessage ¶ added in v1.1.2
func (*TxnRequest) ProtoMessage()
func (*TxnRequest) Reset ¶ added in v1.1.2
func (m *TxnRequest) Reset()
func (*TxnRequest) Size ¶ added in v1.1.2
func (m *TxnRequest) Size() (n int)
func (*TxnRequest) String ¶ added in v1.1.2
func (m *TxnRequest) String() string
func (*TxnRequest) Unmarshal ¶ added in v1.1.2
func (m *TxnRequest) Unmarshal(data []byte) error
type TxnResponse ¶ added in v1.1.2
type TxnResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"` Succeeded bool `protobuf:"varint,2,opt,name=succeeded,proto3" json:"succeeded,omitempty"` Responses []*ResponseUnion `protobuf:"bytes,3,rep,name=responses" json:"responses,omitempty"` }
func (*TxnResponse) GetHeader ¶ added in v1.1.2
func (m *TxnResponse) GetHeader() *ResponseHeader
func (*TxnResponse) GetResponses ¶ added in v1.1.2
func (m *TxnResponse) GetResponses() []*ResponseUnion
func (*TxnResponse) Marshal ¶ added in v1.1.2
func (m *TxnResponse) Marshal() (data []byte, err error)
func (*TxnResponse) MarshalTo ¶ added in v1.1.2
func (m *TxnResponse) MarshalTo(data []byte) (int, error)
func (*TxnResponse) ProtoMessage ¶ added in v1.1.2
func (*TxnResponse) ProtoMessage()
func (*TxnResponse) Reset ¶ added in v1.1.2
func (m *TxnResponse) Reset()
func (*TxnResponse) Size ¶ added in v1.1.2
func (m *TxnResponse) Size() (n int)
func (*TxnResponse) String ¶ added in v1.1.2
func (m *TxnResponse) String() string
func (*TxnResponse) Unmarshal ¶ added in v1.1.2
func (m *TxnResponse) Unmarshal(data []byte) error
type UserAddRequest ¶
type UserAddRequest struct { }
func (*UserAddRequest) Marshal ¶
func (m *UserAddRequest) Marshal() (data []byte, err error)
func (*UserAddRequest) ProtoMessage ¶
func (*UserAddRequest) ProtoMessage()
func (*UserAddRequest) Reset ¶
func (m *UserAddRequest) Reset()
func (*UserAddRequest) Size ¶
func (m *UserAddRequest) Size() (n int)
func (*UserAddRequest) String ¶
func (m *UserAddRequest) String() string
func (*UserAddRequest) Unmarshal ¶
func (m *UserAddRequest) Unmarshal(data []byte) error
type UserAddResponse ¶
type UserAddResponse struct {
Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}
func (*UserAddResponse) GetHeader ¶
func (m *UserAddResponse) GetHeader() *ResponseHeader
func (*UserAddResponse) Marshal ¶
func (m *UserAddResponse) Marshal() (data []byte, err error)
func (*UserAddResponse) ProtoMessage ¶
func (*UserAddResponse) ProtoMessage()
func (*UserAddResponse) Reset ¶
func (m *UserAddResponse) Reset()
func (*UserAddResponse) Size ¶
func (m *UserAddResponse) Size() (n int)
func (*UserAddResponse) String ¶
func (m *UserAddResponse) String() string
func (*UserAddResponse) Unmarshal ¶
func (m *UserAddResponse) Unmarshal(data []byte) error
type UserChangePasswordRequest ¶
type UserChangePasswordRequest struct { }
func (*UserChangePasswordRequest) Marshal ¶
func (m *UserChangePasswordRequest) Marshal() (data []byte, err error)
func (*UserChangePasswordRequest) MarshalTo ¶
func (m *UserChangePasswordRequest) MarshalTo(data []byte) (int, error)
func (*UserChangePasswordRequest) ProtoMessage ¶
func (*UserChangePasswordRequest) ProtoMessage()
func (*UserChangePasswordRequest) Reset ¶
func (m *UserChangePasswordRequest) Reset()
func (*UserChangePasswordRequest) Size ¶
func (m *UserChangePasswordRequest) Size() (n int)
func (*UserChangePasswordRequest) String ¶
func (m *UserChangePasswordRequest) String() string
func (*UserChangePasswordRequest) Unmarshal ¶
func (m *UserChangePasswordRequest) Unmarshal(data []byte) error
type UserChangePasswordResponse ¶
type UserChangePasswordResponse struct {
Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}
func (*UserChangePasswordResponse) GetHeader ¶
func (m *UserChangePasswordResponse) GetHeader() *ResponseHeader
func (*UserChangePasswordResponse) Marshal ¶
func (m *UserChangePasswordResponse) Marshal() (data []byte, err error)
func (*UserChangePasswordResponse) MarshalTo ¶
func (m *UserChangePasswordResponse) MarshalTo(data []byte) (int, error)
func (*UserChangePasswordResponse) ProtoMessage ¶
func (*UserChangePasswordResponse) ProtoMessage()
func (*UserChangePasswordResponse) Reset ¶
func (m *UserChangePasswordResponse) Reset()
func (*UserChangePasswordResponse) Size ¶
func (m *UserChangePasswordResponse) Size() (n int)
func (*UserChangePasswordResponse) String ¶
func (m *UserChangePasswordResponse) String() string
func (*UserChangePasswordResponse) Unmarshal ¶
func (m *UserChangePasswordResponse) Unmarshal(data []byte) error
type UserDeleteRequest ¶
type UserDeleteRequest struct { }
func (*UserDeleteRequest) Marshal ¶
func (m *UserDeleteRequest) Marshal() (data []byte, err error)
func (*UserDeleteRequest) MarshalTo ¶
func (m *UserDeleteRequest) MarshalTo(data []byte) (int, error)
func (*UserDeleteRequest) ProtoMessage ¶
func (*UserDeleteRequest) ProtoMessage()
func (*UserDeleteRequest) Reset ¶
func (m *UserDeleteRequest) Reset()
func (*UserDeleteRequest) Size ¶
func (m *UserDeleteRequest) Size() (n int)
func (*UserDeleteRequest) String ¶
func (m *UserDeleteRequest) String() string
func (*UserDeleteRequest) Unmarshal ¶
func (m *UserDeleteRequest) Unmarshal(data []byte) error
type UserDeleteResponse ¶
type UserDeleteResponse struct {
Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}
func (*UserDeleteResponse) GetHeader ¶
func (m *UserDeleteResponse) GetHeader() *ResponseHeader
func (*UserDeleteResponse) Marshal ¶
func (m *UserDeleteResponse) Marshal() (data []byte, err error)
func (*UserDeleteResponse) MarshalTo ¶
func (m *UserDeleteResponse) MarshalTo(data []byte) (int, error)
func (*UserDeleteResponse) ProtoMessage ¶
func (*UserDeleteResponse) ProtoMessage()
func (*UserDeleteResponse) Reset ¶
func (m *UserDeleteResponse) Reset()
func (*UserDeleteResponse) Size ¶
func (m *UserDeleteResponse) Size() (n int)
func (*UserDeleteResponse) String ¶
func (m *UserDeleteResponse) String() string
func (*UserDeleteResponse) Unmarshal ¶
func (m *UserDeleteResponse) Unmarshal(data []byte) error
type UserGetRequest ¶
type UserGetRequest struct { }
func (*UserGetRequest) Marshal ¶
func (m *UserGetRequest) Marshal() (data []byte, err error)
func (*UserGetRequest) ProtoMessage ¶
func (*UserGetRequest) ProtoMessage()
func (*UserGetRequest) Reset ¶
func (m *UserGetRequest) Reset()
func (*UserGetRequest) Size ¶
func (m *UserGetRequest) Size() (n int)
func (*UserGetRequest) String ¶
func (m *UserGetRequest) String() string
func (*UserGetRequest) Unmarshal ¶
func (m *UserGetRequest) Unmarshal(data []byte) error
type UserGetResponse ¶
type UserGetResponse struct {
Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}
func (*UserGetResponse) GetHeader ¶
func (m *UserGetResponse) GetHeader() *ResponseHeader
func (*UserGetResponse) Marshal ¶
func (m *UserGetResponse) Marshal() (data []byte, err error)
func (*UserGetResponse) ProtoMessage ¶
func (*UserGetResponse) ProtoMessage()
func (*UserGetResponse) Reset ¶
func (m *UserGetResponse) Reset()
func (*UserGetResponse) Size ¶
func (m *UserGetResponse) Size() (n int)
func (*UserGetResponse) String ¶
func (m *UserGetResponse) String() string
func (*UserGetResponse) Unmarshal ¶
func (m *UserGetResponse) Unmarshal(data []byte) error
type UserGrantRequest ¶
type UserGrantRequest struct { }
func (*UserGrantRequest) Marshal ¶
func (m *UserGrantRequest) Marshal() (data []byte, err error)
func (*UserGrantRequest) ProtoMessage ¶
func (*UserGrantRequest) ProtoMessage()
func (*UserGrantRequest) Reset ¶
func (m *UserGrantRequest) Reset()
func (*UserGrantRequest) Size ¶
func (m *UserGrantRequest) Size() (n int)
func (*UserGrantRequest) String ¶
func (m *UserGrantRequest) String() string
func (*UserGrantRequest) Unmarshal ¶
func (m *UserGrantRequest) Unmarshal(data []byte) error
type UserGrantResponse ¶
type UserGrantResponse struct {
Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}
func (*UserGrantResponse) GetHeader ¶
func (m *UserGrantResponse) GetHeader() *ResponseHeader
func (*UserGrantResponse) Marshal ¶
func (m *UserGrantResponse) Marshal() (data []byte, err error)
func (*UserGrantResponse) MarshalTo ¶
func (m *UserGrantResponse) MarshalTo(data []byte) (int, error)
func (*UserGrantResponse) ProtoMessage ¶
func (*UserGrantResponse) ProtoMessage()
func (*UserGrantResponse) Reset ¶
func (m *UserGrantResponse) Reset()
func (*UserGrantResponse) Size ¶
func (m *UserGrantResponse) Size() (n int)
func (*UserGrantResponse) String ¶
func (m *UserGrantResponse) String() string
func (*UserGrantResponse) Unmarshal ¶
func (m *UserGrantResponse) Unmarshal(data []byte) error
type UserRevokeRequest ¶
type UserRevokeRequest struct { }
func (*UserRevokeRequest) Marshal ¶
func (m *UserRevokeRequest) Marshal() (data []byte, err error)
func (*UserRevokeRequest) MarshalTo ¶
func (m *UserRevokeRequest) MarshalTo(data []byte) (int, error)
func (*UserRevokeRequest) ProtoMessage ¶
func (*UserRevokeRequest) ProtoMessage()
func (*UserRevokeRequest) Reset ¶
func (m *UserRevokeRequest) Reset()
func (*UserRevokeRequest) Size ¶
func (m *UserRevokeRequest) Size() (n int)
func (*UserRevokeRequest) String ¶
func (m *UserRevokeRequest) String() string
func (*UserRevokeRequest) Unmarshal ¶
func (m *UserRevokeRequest) Unmarshal(data []byte) error
type UserRevokeResponse ¶
type UserRevokeResponse struct {
Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"`
}
func (*UserRevokeResponse) GetHeader ¶
func (m *UserRevokeResponse) GetHeader() *ResponseHeader
func (*UserRevokeResponse) Marshal ¶
func (m *UserRevokeResponse) Marshal() (data []byte, err error)
func (*UserRevokeResponse) MarshalTo ¶
func (m *UserRevokeResponse) MarshalTo(data []byte) (int, error)
func (*UserRevokeResponse) ProtoMessage ¶
func (*UserRevokeResponse) ProtoMessage()
func (*UserRevokeResponse) Reset ¶
func (m *UserRevokeResponse) Reset()
func (*UserRevokeResponse) Size ¶
func (m *UserRevokeResponse) Size() (n int)
func (*UserRevokeResponse) String ¶
func (m *UserRevokeResponse) String() string
func (*UserRevokeResponse) Unmarshal ¶
func (m *UserRevokeResponse) Unmarshal(data []byte) error
type WatchCancelRequest ¶
type WatchCancelRequest struct {
WatchId int64 `protobuf:"varint,1,opt,name=watch_id,proto3" json:"watch_id,omitempty"`
}
func (*WatchCancelRequest) Marshal ¶
func (m *WatchCancelRequest) Marshal() (data []byte, err error)
func (*WatchCancelRequest) MarshalTo ¶
func (m *WatchCancelRequest) MarshalTo(data []byte) (int, error)
func (*WatchCancelRequest) ProtoMessage ¶
func (*WatchCancelRequest) ProtoMessage()
func (*WatchCancelRequest) Reset ¶
func (m *WatchCancelRequest) Reset()
func (*WatchCancelRequest) Size ¶
func (m *WatchCancelRequest) Size() (n int)
func (*WatchCancelRequest) String ¶
func (m *WatchCancelRequest) String() string
func (*WatchCancelRequest) Unmarshal ¶
func (m *WatchCancelRequest) Unmarshal(data []byte) error
type WatchClient ¶
type WatchClient interface { // Watch watches the events happening or happened. Both input and output // are stream. One watch rpc can watch for multiple keys or prefixs and // get a stream of events. The whole events history can be watched unless // compacted. Watch(ctx context.Context, opts ...grpc.CallOption) (Watch_WatchClient, error) }
func NewWatchClient ¶
func NewWatchClient(cc *grpc.ClientConn) WatchClient
type WatchCreateRequest ¶
type WatchCreateRequest struct { // the key to be watched Key []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // if the range_end is given, keys in [key, range_end) are watched // NOTE: only range_end == prefixEnd(key) is accepted now RangeEnd []byte `protobuf:"bytes,2,opt,name=range_end,proto3" json:"range_end,omitempty"` // start_revision is an optional revision (including) to watch from. No start_revision is "now". StartRevision int64 `protobuf:"varint,3,opt,name=start_revision,proto3" json:"start_revision,omitempty"` // if progress_notify is set, etcd server sends WatchResponse with empty events to the // created watcher when there are no recent events. It is useful when clients want always to be // able to recover a disconnected watcher from a recent known revision. // etcdsever can decide how long it should send a notification based on current load. ProgressNotify bool `protobuf:"varint,4,opt,name=progress_notify,proto3" json:"progress_notify,omitempty"` }
func (*WatchCreateRequest) Marshal ¶
func (m *WatchCreateRequest) Marshal() (data []byte, err error)
func (*WatchCreateRequest) MarshalTo ¶
func (m *WatchCreateRequest) MarshalTo(data []byte) (int, error)
func (*WatchCreateRequest) ProtoMessage ¶
func (*WatchCreateRequest) ProtoMessage()
func (*WatchCreateRequest) Reset ¶
func (m *WatchCreateRequest) Reset()
func (*WatchCreateRequest) Size ¶
func (m *WatchCreateRequest) Size() (n int)
func (*WatchCreateRequest) String ¶
func (m *WatchCreateRequest) String() string
func (*WatchCreateRequest) Unmarshal ¶
func (m *WatchCreateRequest) Unmarshal(data []byte) error
type WatchRequest ¶
type WatchRequest struct { // Types that are valid to be assigned to RequestUnion: // *WatchRequest_CreateRequest // *WatchRequest_CancelRequest RequestUnion isWatchRequest_RequestUnion `protobuf_oneof:"request_union"` }
func (*WatchRequest) GetCancelRequest ¶
func (m *WatchRequest) GetCancelRequest() *WatchCancelRequest
func (*WatchRequest) GetCreateRequest ¶
func (m *WatchRequest) GetCreateRequest() *WatchCreateRequest
func (*WatchRequest) GetRequestUnion ¶
func (m *WatchRequest) GetRequestUnion() isWatchRequest_RequestUnion
func (*WatchRequest) Marshal ¶
func (m *WatchRequest) Marshal() (data []byte, err error)
func (*WatchRequest) ProtoMessage ¶
func (*WatchRequest) ProtoMessage()
func (*WatchRequest) Reset ¶
func (m *WatchRequest) Reset()
func (*WatchRequest) Size ¶
func (m *WatchRequest) Size() (n int)
func (*WatchRequest) String ¶
func (m *WatchRequest) String() string
func (*WatchRequest) Unmarshal ¶
func (m *WatchRequest) Unmarshal(data []byte) error
type WatchRequest_CancelRequest ¶
type WatchRequest_CancelRequest struct {
CancelRequest *WatchCancelRequest `protobuf:"bytes,2,opt,name=cancel_request,oneof"`
}
func (*WatchRequest_CancelRequest) MarshalTo ¶
func (m *WatchRequest_CancelRequest) MarshalTo(data []byte) (int, error)
func (*WatchRequest_CancelRequest) Size ¶
func (m *WatchRequest_CancelRequest) Size() (n int)
type WatchRequest_CreateRequest ¶
type WatchRequest_CreateRequest struct {
CreateRequest *WatchCreateRequest `protobuf:"bytes,1,opt,name=create_request,oneof"`
}
func (*WatchRequest_CreateRequest) MarshalTo ¶
func (m *WatchRequest_CreateRequest) MarshalTo(data []byte) (int, error)
func (*WatchRequest_CreateRequest) Size ¶
func (m *WatchRequest_CreateRequest) Size() (n int)
type WatchResponse ¶
type WatchResponse struct { Header *ResponseHeader `protobuf:"bytes,1,opt,name=header" json:"header,omitempty"` // watch_id is the ID of the watching the response sent to. WatchId int64 `protobuf:"varint,2,opt,name=watch_id,proto3" json:"watch_id,omitempty"` // If the response is for a create watch request, created is set to true. // Client should record the watch_id and prepare for receiving events for // that watching from the same stream. // All events sent to the created watching will attach with the same watch_id. Created bool `protobuf:"varint,3,opt,name=created,proto3" json:"created,omitempty"` // If the response is for a cancel watch request, cancel is set to true. // No further events will be sent to the canceled watching. Canceled bool `protobuf:"varint,4,opt,name=canceled,proto3" json:"canceled,omitempty"` // CompactRevision is set to the minimum index if a watching tries to watch // at a compacted index. // // This happens when creating a watching at a compacted revision or the watching cannot // catch up with the progress of the KV. // // Client should treat the watching as canceled and should not try to create any // watching with same start_revision again. CompactRevision int64 `protobuf:"varint,5,opt,name=compact_revision,proto3" json:"compact_revision,omitempty"` Events []*storagepb.Event `protobuf:"bytes,11,rep,name=events" json:"events,omitempty"` }
func (*WatchResponse) GetEvents ¶
func (m *WatchResponse) GetEvents() []*storagepb.Event
func (*WatchResponse) GetHeader ¶
func (m *WatchResponse) GetHeader() *ResponseHeader
func (*WatchResponse) Marshal ¶
func (m *WatchResponse) Marshal() (data []byte, err error)
func (*WatchResponse) ProtoMessage ¶
func (*WatchResponse) ProtoMessage()
func (*WatchResponse) Reset ¶
func (m *WatchResponse) Reset()
func (*WatchResponse) Size ¶
func (m *WatchResponse) Size() (n int)
func (*WatchResponse) String ¶
func (m *WatchResponse) String() string
func (*WatchResponse) Unmarshal ¶
func (m *WatchResponse) Unmarshal(data []byte) error
type WatchServer ¶
type WatchServer interface { // Watch watches the events happening or happened. Both input and output // are stream. One watch rpc can watch for multiple keys or prefixs and // get a stream of events. The whole events history can be watched unless // compacted. Watch(Watch_WatchServer) error }
type Watch_WatchClient ¶
type Watch_WatchClient interface { Send(*WatchRequest) error Recv() (*WatchResponse, error) grpc.ClientStream }
type Watch_WatchServer ¶
type Watch_WatchServer interface { Send(*WatchResponse) error Recv() (*WatchRequest, error) grpc.ServerStream }