Documentation ¶
Index ¶
- Variables
- func RegisterClientServer(s grpc.ServiceRegistrar, srv ClientServer)
- type AddReplicaRequest
- func (*AddReplicaRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AddReplicaRequest) GetExpiry() int64
- func (x *AddReplicaRequest) GetKeygroup() string
- func (x *AddReplicaRequest) GetNodeId() string
- func (*AddReplicaRequest) ProtoMessage()
- func (x *AddReplicaRequest) ProtoReflect() protoreflect.Message
- func (x *AddReplicaRequest) Reset()
- func (x *AddReplicaRequest) String() string
- type AddTriggerRequest
- func (*AddTriggerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AddTriggerRequest) GetKeygroup() string
- func (x *AddTriggerRequest) GetTriggerHost() string
- func (x *AddTriggerRequest) GetTriggerId() string
- func (*AddTriggerRequest) ProtoMessage()
- func (x *AddTriggerRequest) ProtoReflect() protoreflect.Message
- func (x *AddTriggerRequest) Reset()
- func (x *AddTriggerRequest) String() string
- type AddUserRequest
- func (*AddUserRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AddUserRequest) GetKeygroup() string
- func (x *AddUserRequest) GetRole() UserRole
- func (x *AddUserRequest) GetUser() string
- func (*AddUserRequest) ProtoMessage()
- func (x *AddUserRequest) ProtoReflect() protoreflect.Message
- func (x *AddUserRequest) Reset()
- func (x *AddUserRequest) String() string
- type AppendRequest
- func (*AppendRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AppendRequest) GetData() string
- func (x *AppendRequest) GetId() uint64
- func (x *AppendRequest) GetKeygroup() string
- func (*AppendRequest) ProtoMessage()
- func (x *AppendRequest) ProtoReflect() protoreflect.Message
- func (x *AppendRequest) Reset()
- func (x *AppendRequest) String() string
- type AppendResponse
- type ClientClient
- type ClientServer
- type CreateKeygroupRequest
- func (*CreateKeygroupRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateKeygroupRequest) GetExpiry() int64
- func (x *CreateKeygroupRequest) GetKeygroup() string
- func (x *CreateKeygroupRequest) GetMutable() bool
- func (*CreateKeygroupRequest) ProtoMessage()
- func (x *CreateKeygroupRequest) ProtoReflect() protoreflect.Message
- func (x *CreateKeygroupRequest) Reset()
- func (x *CreateKeygroupRequest) String() string
- type DeleteKeygroupRequest
- func (*DeleteKeygroupRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteKeygroupRequest) GetKeygroup() string
- func (*DeleteKeygroupRequest) ProtoMessage()
- func (x *DeleteKeygroupRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteKeygroupRequest) Reset()
- func (x *DeleteKeygroupRequest) String() string
- type DeleteRequest
- func (*DeleteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteRequest) GetId() string
- func (x *DeleteRequest) GetKeygroup() string
- func (x *DeleteRequest) GetVersions() []*Version
- func (*DeleteRequest) ProtoMessage()
- func (x *DeleteRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteRequest) Reset()
- func (x *DeleteRequest) String() string
- type DeleteResponse
- type Empty
- type GetAllReplicaResponse
- func (*GetAllReplicaResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetAllReplicaResponse) GetReplicas() []*Replica
- func (*GetAllReplicaResponse) ProtoMessage()
- func (x *GetAllReplicaResponse) ProtoReflect() protoreflect.Message
- func (x *GetAllReplicaResponse) Reset()
- func (x *GetAllReplicaResponse) String() string
- type GetKeygroupInfoRequest
- func (*GetKeygroupInfoRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetKeygroupInfoRequest) GetKeygroup() string
- func (*GetKeygroupInfoRequest) ProtoMessage()
- func (x *GetKeygroupInfoRequest) ProtoReflect() protoreflect.Message
- func (x *GetKeygroupInfoRequest) Reset()
- func (x *GetKeygroupInfoRequest) String() string
- type GetKeygroupInfoResponse
- func (*GetKeygroupInfoResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetKeygroupInfoResponse) GetMutable() bool
- func (x *GetKeygroupInfoResponse) GetReplica() []*KeygroupReplica
- func (*GetKeygroupInfoResponse) ProtoMessage()
- func (x *GetKeygroupInfoResponse) ProtoReflect() protoreflect.Message
- func (x *GetKeygroupInfoResponse) Reset()
- func (x *GetKeygroupInfoResponse) String() string
- type GetKeygroupTriggerRequest
- func (*GetKeygroupTriggerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetKeygroupTriggerRequest) GetKeygroup() string
- func (*GetKeygroupTriggerRequest) ProtoMessage()
- func (x *GetKeygroupTriggerRequest) ProtoReflect() protoreflect.Message
- func (x *GetKeygroupTriggerRequest) Reset()
- func (x *GetKeygroupTriggerRequest) String() string
- type GetKeygroupTriggerResponse
- func (*GetKeygroupTriggerResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetKeygroupTriggerResponse) GetTriggers() []*Trigger
- func (*GetKeygroupTriggerResponse) ProtoMessage()
- func (x *GetKeygroupTriggerResponse) ProtoReflect() protoreflect.Message
- func (x *GetKeygroupTriggerResponse) Reset()
- func (x *GetKeygroupTriggerResponse) String() string
- type GetReplicaRequest
- type GetReplicaResponse
- func (*GetReplicaResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetReplicaResponse) GetHost() string
- func (x *GetReplicaResponse) GetNodeId() string
- func (*GetReplicaResponse) ProtoMessage()
- func (x *GetReplicaResponse) ProtoReflect() protoreflect.Message
- func (x *GetReplicaResponse) Reset()
- func (x *GetReplicaResponse) String() string
- type Item
- type Key
- type KeygroupReplica
- func (*KeygroupReplica) Descriptor() ([]byte, []int)deprecated
- func (x *KeygroupReplica) GetExpiry() int64
- func (x *KeygroupReplica) GetHost() string
- func (x *KeygroupReplica) GetNodeId() string
- func (*KeygroupReplica) ProtoMessage()
- func (x *KeygroupReplica) ProtoReflect() protoreflect.Message
- func (x *KeygroupReplica) Reset()
- func (x *KeygroupReplica) String() string
- type KeysRequest
- func (*KeysRequest) Descriptor() ([]byte, []int)deprecated
- func (x *KeysRequest) GetCount() uint64
- func (x *KeysRequest) GetId() string
- func (x *KeysRequest) GetKeygroup() string
- func (*KeysRequest) ProtoMessage()
- func (x *KeysRequest) ProtoReflect() protoreflect.Message
- func (x *KeysRequest) Reset()
- func (x *KeysRequest) String() string
- type KeysResponse
- type ReadRequest
- func (*ReadRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReadRequest) GetId() string
- func (x *ReadRequest) GetKeygroup() string
- func (x *ReadRequest) GetVersions() []*Version
- func (*ReadRequest) ProtoMessage()
- func (x *ReadRequest) ProtoReflect() protoreflect.Message
- func (x *ReadRequest) Reset()
- func (x *ReadRequest) String() string
- type ReadResponse
- type RemoveReplicaRequest
- func (*RemoveReplicaRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveReplicaRequest) GetKeygroup() string
- func (x *RemoveReplicaRequest) GetNodeId() string
- func (*RemoveReplicaRequest) ProtoMessage()
- func (x *RemoveReplicaRequest) ProtoReflect() protoreflect.Message
- func (x *RemoveReplicaRequest) Reset()
- func (x *RemoveReplicaRequest) String() string
- type RemoveTriggerRequest
- func (*RemoveTriggerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveTriggerRequest) GetKeygroup() string
- func (x *RemoveTriggerRequest) GetTriggerId() string
- func (*RemoveTriggerRequest) ProtoMessage()
- func (x *RemoveTriggerRequest) ProtoReflect() protoreflect.Message
- func (x *RemoveTriggerRequest) Reset()
- func (x *RemoveTriggerRequest) String() string
- type RemoveUserRequest
- func (*RemoveUserRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveUserRequest) GetKeygroup() string
- func (x *RemoveUserRequest) GetRole() UserRole
- func (x *RemoveUserRequest) GetUser() string
- func (*RemoveUserRequest) ProtoMessage()
- func (x *RemoveUserRequest) ProtoReflect() protoreflect.Message
- func (x *RemoveUserRequest) Reset()
- func (x *RemoveUserRequest) String() string
- type Replica
- type ScanRequest
- func (*ScanRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ScanRequest) GetCount() uint64
- func (x *ScanRequest) GetId() string
- func (x *ScanRequest) GetKeygroup() string
- func (*ScanRequest) ProtoMessage()
- func (x *ScanRequest) ProtoReflect() protoreflect.Message
- func (x *ScanRequest) Reset()
- func (x *ScanRequest) String() string
- type ScanResponse
- type Trigger
- type UnimplementedClientServer
- func (UnimplementedClientServer) AddReplica(context.Context, *AddReplicaRequest) (*Empty, error)
- func (UnimplementedClientServer) AddTrigger(context.Context, *AddTriggerRequest) (*Empty, error)
- func (UnimplementedClientServer) AddUser(context.Context, *AddUserRequest) (*Empty, error)
- func (UnimplementedClientServer) Append(context.Context, *AppendRequest) (*AppendResponse, error)
- func (UnimplementedClientServer) CreateKeygroup(context.Context, *CreateKeygroupRequest) (*Empty, error)
- func (UnimplementedClientServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
- func (UnimplementedClientServer) DeleteKeygroup(context.Context, *DeleteKeygroupRequest) (*Empty, error)
- func (UnimplementedClientServer) GetAllReplica(context.Context, *Empty) (*GetAllReplicaResponse, error)
- func (UnimplementedClientServer) GetKeygroupInfo(context.Context, *GetKeygroupInfoRequest) (*GetKeygroupInfoResponse, error)
- func (UnimplementedClientServer) GetKeygroupTriggers(context.Context, *GetKeygroupTriggerRequest) (*GetKeygroupTriggerResponse, error)
- func (UnimplementedClientServer) GetReplica(context.Context, *GetReplicaRequest) (*GetReplicaResponse, error)
- func (UnimplementedClientServer) Keys(context.Context, *KeysRequest) (*KeysResponse, error)
- func (UnimplementedClientServer) Read(context.Context, *ReadRequest) (*ReadResponse, error)
- func (UnimplementedClientServer) RemoveReplica(context.Context, *RemoveReplicaRequest) (*Empty, error)
- func (UnimplementedClientServer) RemoveTrigger(context.Context, *RemoveTriggerRequest) (*Empty, error)
- func (UnimplementedClientServer) RemoveUser(context.Context, *RemoveUserRequest) (*Empty, error)
- func (UnimplementedClientServer) Scan(context.Context, *ScanRequest) (*ScanResponse, error)
- func (UnimplementedClientServer) Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
- type UnsafeClientServer
- type UpdateRequest
- func (*UpdateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateRequest) GetData() string
- func (x *UpdateRequest) GetId() string
- func (x *UpdateRequest) GetKeygroup() string
- func (x *UpdateRequest) GetVersions() []*Version
- func (*UpdateRequest) ProtoMessage()
- func (x *UpdateRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateRequest) Reset()
- func (x *UpdateRequest) String() string
- type UpdateResponse
- type UserRole
- type Version
Constants ¶
This section is empty.
Variables ¶
var ( UserRole_name = map[int32]string{ 0: "ReadKeygroup", 1: "WriteKeygroup", 2: "ConfigureReplica", 3: "ConfigureTrigger", 4: "ConfigureKeygroups", } UserRole_value = map[string]int32{ "ReadKeygroup": 0, "WriteKeygroup": 1, "ConfigureReplica": 2, "ConfigureTrigger": 3, "ConfigureKeygroups": 4, } )
Enum value maps for UserRole.
var Client_ServiceDesc = grpc.ServiceDesc{ ServiceName: "mcc.fred.client.Client", HandlerType: (*ClientServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateKeygroup", Handler: _Client_CreateKeygroup_Handler, }, { MethodName: "DeleteKeygroup", Handler: _Client_DeleteKeygroup_Handler, }, { MethodName: "Read", Handler: _Client_Read_Handler, }, { MethodName: "Scan", Handler: _Client_Scan_Handler, }, { MethodName: "Keys", Handler: _Client_Keys_Handler, }, { MethodName: "Update", Handler: _Client_Update_Handler, }, { MethodName: "Delete", Handler: _Client_Delete_Handler, }, { MethodName: "Append", Handler: _Client_Append_Handler, }, { MethodName: "AddReplica", Handler: _Client_AddReplica_Handler, }, { MethodName: "GetKeygroupInfo", Handler: _Client_GetKeygroupInfo_Handler, }, { MethodName: "RemoveReplica", Handler: _Client_RemoveReplica_Handler, }, { MethodName: "GetReplica", Handler: _Client_GetReplica_Handler, }, { MethodName: "GetAllReplica", Handler: _Client_GetAllReplica_Handler, }, { MethodName: "GetKeygroupTriggers", Handler: _Client_GetKeygroupTriggers_Handler, }, { MethodName: "AddTrigger", Handler: _Client_AddTrigger_Handler, }, { MethodName: "RemoveTrigger", Handler: _Client_RemoveTrigger_Handler, }, { MethodName: "AddUser", Handler: _Client_AddUser_Handler, }, { MethodName: "RemoveUser", Handler: _Client_RemoveUser_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "client.proto", }
Client_ServiceDesc is the grpc.ServiceDesc for Client service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_client_proto protoreflect.FileDescriptor
Functions ¶
func RegisterClientServer ¶
func RegisterClientServer(s grpc.ServiceRegistrar, srv ClientServer)
Types ¶
type AddReplicaRequest ¶
type AddReplicaRequest struct { Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"` NodeId string `protobuf:"bytes,2,opt,name=nodeId,proto3" json:"nodeId,omitempty"` Expiry int64 `protobuf:"varint,3,opt,name=expiry,proto3" json:"expiry,omitempty"` // contains filtered or unexported fields }
func (*AddReplicaRequest) Descriptor
deprecated
func (*AddReplicaRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddReplicaRequest.ProtoReflect.Descriptor instead.
func (*AddReplicaRequest) GetExpiry ¶
func (x *AddReplicaRequest) GetExpiry() int64
func (*AddReplicaRequest) GetKeygroup ¶
func (x *AddReplicaRequest) GetKeygroup() string
func (*AddReplicaRequest) GetNodeId ¶
func (x *AddReplicaRequest) GetNodeId() string
func (*AddReplicaRequest) ProtoMessage ¶
func (*AddReplicaRequest) ProtoMessage()
func (*AddReplicaRequest) ProtoReflect ¶
func (x *AddReplicaRequest) ProtoReflect() protoreflect.Message
func (*AddReplicaRequest) Reset ¶
func (x *AddReplicaRequest) Reset()
func (*AddReplicaRequest) String ¶
func (x *AddReplicaRequest) String() string
type AddTriggerRequest ¶
type AddTriggerRequest struct { Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"` TriggerId string `protobuf:"bytes,2,opt,name=triggerId,proto3" json:"triggerId,omitempty"` TriggerHost string `protobuf:"bytes,3,opt,name=triggerHost,proto3" json:"triggerHost,omitempty"` // contains filtered or unexported fields }
func (*AddTriggerRequest) Descriptor
deprecated
func (*AddTriggerRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddTriggerRequest.ProtoReflect.Descriptor instead.
func (*AddTriggerRequest) GetKeygroup ¶
func (x *AddTriggerRequest) GetKeygroup() string
func (*AddTriggerRequest) GetTriggerHost ¶
func (x *AddTriggerRequest) GetTriggerHost() string
func (*AddTriggerRequest) GetTriggerId ¶
func (x *AddTriggerRequest) GetTriggerId() string
func (*AddTriggerRequest) ProtoMessage ¶
func (*AddTriggerRequest) ProtoMessage()
func (*AddTriggerRequest) ProtoReflect ¶
func (x *AddTriggerRequest) ProtoReflect() protoreflect.Message
func (*AddTriggerRequest) Reset ¶
func (x *AddTriggerRequest) Reset()
func (*AddTriggerRequest) String ¶
func (x *AddTriggerRequest) String() string
type AddUserRequest ¶ added in v0.2.1
type AddUserRequest struct { User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` Keygroup string `protobuf:"bytes,2,opt,name=keygroup,proto3" json:"keygroup,omitempty"` Role UserRole `protobuf:"varint,3,opt,name=role,proto3,enum=mcc.fred.client.UserRole" json:"role,omitempty"` // contains filtered or unexported fields }
func (*AddUserRequest) Descriptor
deprecated
added in
v0.2.1
func (*AddUserRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddUserRequest.ProtoReflect.Descriptor instead.
func (*AddUserRequest) GetKeygroup ¶ added in v0.2.1
func (x *AddUserRequest) GetKeygroup() string
func (*AddUserRequest) GetRole ¶ added in v0.2.1
func (x *AddUserRequest) GetRole() UserRole
func (*AddUserRequest) GetUser ¶ added in v0.2.1
func (x *AddUserRequest) GetUser() string
func (*AddUserRequest) ProtoMessage ¶ added in v0.2.1
func (*AddUserRequest) ProtoMessage()
func (*AddUserRequest) ProtoReflect ¶ added in v0.2.1
func (x *AddUserRequest) ProtoReflect() protoreflect.Message
func (*AddUserRequest) Reset ¶ added in v0.2.1
func (x *AddUserRequest) Reset()
func (*AddUserRequest) String ¶ added in v0.2.1
func (x *AddUserRequest) String() string
type AppendRequest ¶
type AppendRequest struct { Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"` Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"` Data string `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*AppendRequest) Descriptor
deprecated
func (*AppendRequest) Descriptor() ([]byte, []int)
Deprecated: Use AppendRequest.ProtoReflect.Descriptor instead.
func (*AppendRequest) GetData ¶
func (x *AppendRequest) GetData() string
func (*AppendRequest) GetId ¶ added in v0.2.1
func (x *AppendRequest) GetId() uint64
func (*AppendRequest) GetKeygroup ¶
func (x *AppendRequest) GetKeygroup() string
func (*AppendRequest) ProtoMessage ¶
func (*AppendRequest) ProtoMessage()
func (*AppendRequest) ProtoReflect ¶
func (x *AppendRequest) ProtoReflect() protoreflect.Message
func (*AppendRequest) Reset ¶
func (x *AppendRequest) Reset()
func (*AppendRequest) String ¶
func (x *AppendRequest) String() string
type AppendResponse ¶
type AppendResponse struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*AppendResponse) Descriptor
deprecated
func (*AppendResponse) Descriptor() ([]byte, []int)
Deprecated: Use AppendResponse.ProtoReflect.Descriptor instead.
func (*AppendResponse) GetId ¶
func (x *AppendResponse) GetId() string
func (*AppendResponse) ProtoMessage ¶
func (*AppendResponse) ProtoMessage()
func (*AppendResponse) ProtoReflect ¶
func (x *AppendResponse) ProtoReflect() protoreflect.Message
func (*AppendResponse) Reset ¶
func (x *AppendResponse) Reset()
func (*AppendResponse) String ¶
func (x *AppendResponse) String() string
type ClientClient ¶
type ClientClient interface { CreateKeygroup(ctx context.Context, in *CreateKeygroupRequest, opts ...grpc.CallOption) (*Empty, error) DeleteKeygroup(ctx context.Context, in *DeleteKeygroupRequest, opts ...grpc.CallOption) (*Empty, error) Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error) Scan(ctx context.Context, in *ScanRequest, opts ...grpc.CallOption) (*ScanResponse, error) Keys(ctx context.Context, in *KeysRequest, opts ...grpc.CallOption) (*KeysResponse, error) Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error) Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error) Append(ctx context.Context, in *AppendRequest, opts ...grpc.CallOption) (*AppendResponse, error) AddReplica(ctx context.Context, in *AddReplicaRequest, opts ...grpc.CallOption) (*Empty, error) GetKeygroupInfo(ctx context.Context, in *GetKeygroupInfoRequest, opts ...grpc.CallOption) (*GetKeygroupInfoResponse, error) RemoveReplica(ctx context.Context, in *RemoveReplicaRequest, opts ...grpc.CallOption) (*Empty, error) GetReplica(ctx context.Context, in *GetReplicaRequest, opts ...grpc.CallOption) (*GetReplicaResponse, error) GetAllReplica(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*GetAllReplicaResponse, error) GetKeygroupTriggers(ctx context.Context, in *GetKeygroupTriggerRequest, opts ...grpc.CallOption) (*GetKeygroupTriggerResponse, error) AddTrigger(ctx context.Context, in *AddTriggerRequest, opts ...grpc.CallOption) (*Empty, error) RemoveTrigger(ctx context.Context, in *RemoveTriggerRequest, opts ...grpc.CallOption) (*Empty, error) AddUser(ctx context.Context, in *AddUserRequest, opts ...grpc.CallOption) (*Empty, error) RemoveUser(ctx context.Context, in *RemoveUserRequest, opts ...grpc.CallOption) (*Empty, error) }
ClientClient is the client API for Client service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewClientClient ¶
func NewClientClient(cc grpc.ClientConnInterface) ClientClient
type ClientServer ¶
type ClientServer interface { CreateKeygroup(context.Context, *CreateKeygroupRequest) (*Empty, error) DeleteKeygroup(context.Context, *DeleteKeygroupRequest) (*Empty, error) Read(context.Context, *ReadRequest) (*ReadResponse, error) Scan(context.Context, *ScanRequest) (*ScanResponse, error) Keys(context.Context, *KeysRequest) (*KeysResponse, error) Update(context.Context, *UpdateRequest) (*UpdateResponse, error) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error) Append(context.Context, *AppendRequest) (*AppendResponse, error) AddReplica(context.Context, *AddReplicaRequest) (*Empty, error) GetKeygroupInfo(context.Context, *GetKeygroupInfoRequest) (*GetKeygroupInfoResponse, error) RemoveReplica(context.Context, *RemoveReplicaRequest) (*Empty, error) GetReplica(context.Context, *GetReplicaRequest) (*GetReplicaResponse, error) GetAllReplica(context.Context, *Empty) (*GetAllReplicaResponse, error) GetKeygroupTriggers(context.Context, *GetKeygroupTriggerRequest) (*GetKeygroupTriggerResponse, error) AddTrigger(context.Context, *AddTriggerRequest) (*Empty, error) RemoveTrigger(context.Context, *RemoveTriggerRequest) (*Empty, error) AddUser(context.Context, *AddUserRequest) (*Empty, error) RemoveUser(context.Context, *RemoveUserRequest) (*Empty, error) }
ClientServer is the server API for Client service. All implementations should embed UnimplementedClientServer for forward compatibility
type CreateKeygroupRequest ¶
type CreateKeygroupRequest struct { Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"` Mutable bool `protobuf:"varint,2,opt,name=mutable,proto3" json:"mutable,omitempty"` Expiry int64 `protobuf:"varint,3,opt,name=expiry,proto3" json:"expiry,omitempty"` // contains filtered or unexported fields }
func (*CreateKeygroupRequest) Descriptor
deprecated
func (*CreateKeygroupRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateKeygroupRequest.ProtoReflect.Descriptor instead.
func (*CreateKeygroupRequest) GetExpiry ¶
func (x *CreateKeygroupRequest) GetExpiry() int64
func (*CreateKeygroupRequest) GetKeygroup ¶
func (x *CreateKeygroupRequest) GetKeygroup() string
func (*CreateKeygroupRequest) GetMutable ¶
func (x *CreateKeygroupRequest) GetMutable() bool
func (*CreateKeygroupRequest) ProtoMessage ¶
func (*CreateKeygroupRequest) ProtoMessage()
func (*CreateKeygroupRequest) ProtoReflect ¶
func (x *CreateKeygroupRequest) ProtoReflect() protoreflect.Message
func (*CreateKeygroupRequest) Reset ¶
func (x *CreateKeygroupRequest) Reset()
func (*CreateKeygroupRequest) String ¶
func (x *CreateKeygroupRequest) String() string
type DeleteKeygroupRequest ¶
type DeleteKeygroupRequest struct { Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"` // contains filtered or unexported fields }
func (*DeleteKeygroupRequest) Descriptor
deprecated
func (*DeleteKeygroupRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteKeygroupRequest.ProtoReflect.Descriptor instead.
func (*DeleteKeygroupRequest) GetKeygroup ¶
func (x *DeleteKeygroupRequest) GetKeygroup() string
func (*DeleteKeygroupRequest) ProtoMessage ¶
func (*DeleteKeygroupRequest) ProtoMessage()
func (*DeleteKeygroupRequest) ProtoReflect ¶
func (x *DeleteKeygroupRequest) ProtoReflect() protoreflect.Message
func (*DeleteKeygroupRequest) Reset ¶
func (x *DeleteKeygroupRequest) Reset()
func (*DeleteKeygroupRequest) String ¶
func (x *DeleteKeygroupRequest) String() string
type DeleteRequest ¶
type DeleteRequest struct { Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` Versions []*Version `protobuf:"bytes,3,rep,name=versions,proto3" json:"versions,omitempty"` // contains filtered or unexported fields }
func (*DeleteRequest) Descriptor
deprecated
func (*DeleteRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.
func (*DeleteRequest) GetId ¶
func (x *DeleteRequest) GetId() string
func (*DeleteRequest) GetKeygroup ¶
func (x *DeleteRequest) GetKeygroup() string
func (*DeleteRequest) GetVersions ¶ added in v0.2.1
func (x *DeleteRequest) GetVersions() []*Version
func (*DeleteRequest) ProtoMessage ¶
func (*DeleteRequest) ProtoMessage()
func (*DeleteRequest) ProtoReflect ¶
func (x *DeleteRequest) ProtoReflect() protoreflect.Message
func (*DeleteRequest) Reset ¶
func (x *DeleteRequest) Reset()
func (*DeleteRequest) String ¶
func (x *DeleteRequest) String() string
type DeleteResponse ¶ added in v0.2.1
type DeleteResponse struct { Version *Version `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
func (*DeleteResponse) Descriptor
deprecated
added in
v0.2.1
func (*DeleteResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.
func (*DeleteResponse) GetVersion ¶ added in v0.2.1
func (x *DeleteResponse) GetVersion() *Version
func (*DeleteResponse) ProtoMessage ¶ added in v0.2.1
func (*DeleteResponse) ProtoMessage()
func (*DeleteResponse) ProtoReflect ¶ added in v0.2.1
func (x *DeleteResponse) ProtoReflect() protoreflect.Message
func (*DeleteResponse) Reset ¶ added in v0.2.1
func (x *DeleteResponse) Reset()
func (*DeleteResponse) String ¶ added in v0.2.1
func (x *DeleteResponse) String() string
type Empty ¶ added in v0.2.1
type Empty struct {
// contains filtered or unexported fields
}
func (*Empty) Descriptor
deprecated
added in
v0.2.1
func (*Empty) ProtoMessage ¶ added in v0.2.1
func (*Empty) ProtoMessage()
func (*Empty) ProtoReflect ¶ added in v0.2.1
func (x *Empty) ProtoReflect() protoreflect.Message
type GetAllReplicaResponse ¶
type GetAllReplicaResponse struct { Replicas []*Replica `protobuf:"bytes,1,rep,name=replicas,proto3" json:"replicas,omitempty"` // contains filtered or unexported fields }
func (*GetAllReplicaResponse) Descriptor
deprecated
func (*GetAllReplicaResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetAllReplicaResponse.ProtoReflect.Descriptor instead.
func (*GetAllReplicaResponse) GetReplicas ¶
func (x *GetAllReplicaResponse) GetReplicas() []*Replica
func (*GetAllReplicaResponse) ProtoMessage ¶
func (*GetAllReplicaResponse) ProtoMessage()
func (*GetAllReplicaResponse) ProtoReflect ¶
func (x *GetAllReplicaResponse) ProtoReflect() protoreflect.Message
func (*GetAllReplicaResponse) Reset ¶
func (x *GetAllReplicaResponse) Reset()
func (*GetAllReplicaResponse) String ¶
func (x *GetAllReplicaResponse) String() string
type GetKeygroupInfoRequest ¶ added in v0.2.2
type GetKeygroupInfoRequest struct { Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"` // contains filtered or unexported fields }
func (*GetKeygroupInfoRequest) Descriptor
deprecated
added in
v0.2.2
func (*GetKeygroupInfoRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetKeygroupInfoRequest.ProtoReflect.Descriptor instead.
func (*GetKeygroupInfoRequest) GetKeygroup ¶ added in v0.2.2
func (x *GetKeygroupInfoRequest) GetKeygroup() string
func (*GetKeygroupInfoRequest) ProtoMessage ¶ added in v0.2.2
func (*GetKeygroupInfoRequest) ProtoMessage()
func (*GetKeygroupInfoRequest) ProtoReflect ¶ added in v0.2.2
func (x *GetKeygroupInfoRequest) ProtoReflect() protoreflect.Message
func (*GetKeygroupInfoRequest) Reset ¶ added in v0.2.2
func (x *GetKeygroupInfoRequest) Reset()
func (*GetKeygroupInfoRequest) String ¶ added in v0.2.2
func (x *GetKeygroupInfoRequest) String() string
type GetKeygroupInfoResponse ¶ added in v0.2.2
type GetKeygroupInfoResponse struct { Mutable bool `protobuf:"varint,1,opt,name=mutable,proto3" json:"mutable,omitempty"` Replica []*KeygroupReplica `protobuf:"bytes,2,rep,name=replica,proto3" json:"replica,omitempty"` // contains filtered or unexported fields }
func (*GetKeygroupInfoResponse) Descriptor
deprecated
added in
v0.2.2
func (*GetKeygroupInfoResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetKeygroupInfoResponse.ProtoReflect.Descriptor instead.
func (*GetKeygroupInfoResponse) GetMutable ¶ added in v0.2.2
func (x *GetKeygroupInfoResponse) GetMutable() bool
func (*GetKeygroupInfoResponse) GetReplica ¶ added in v0.2.2
func (x *GetKeygroupInfoResponse) GetReplica() []*KeygroupReplica
func (*GetKeygroupInfoResponse) ProtoMessage ¶ added in v0.2.2
func (*GetKeygroupInfoResponse) ProtoMessage()
func (*GetKeygroupInfoResponse) ProtoReflect ¶ added in v0.2.2
func (x *GetKeygroupInfoResponse) ProtoReflect() protoreflect.Message
func (*GetKeygroupInfoResponse) Reset ¶ added in v0.2.2
func (x *GetKeygroupInfoResponse) Reset()
func (*GetKeygroupInfoResponse) String ¶ added in v0.2.2
func (x *GetKeygroupInfoResponse) String() string
type GetKeygroupTriggerRequest ¶
type GetKeygroupTriggerRequest struct { Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"` // contains filtered or unexported fields }
func (*GetKeygroupTriggerRequest) Descriptor
deprecated
func (*GetKeygroupTriggerRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetKeygroupTriggerRequest.ProtoReflect.Descriptor instead.
func (*GetKeygroupTriggerRequest) GetKeygroup ¶
func (x *GetKeygroupTriggerRequest) GetKeygroup() string
func (*GetKeygroupTriggerRequest) ProtoMessage ¶
func (*GetKeygroupTriggerRequest) ProtoMessage()
func (*GetKeygroupTriggerRequest) ProtoReflect ¶
func (x *GetKeygroupTriggerRequest) ProtoReflect() protoreflect.Message
func (*GetKeygroupTriggerRequest) Reset ¶
func (x *GetKeygroupTriggerRequest) Reset()
func (*GetKeygroupTriggerRequest) String ¶
func (x *GetKeygroupTriggerRequest) String() string
type GetKeygroupTriggerResponse ¶
type GetKeygroupTriggerResponse struct { Triggers []*Trigger `protobuf:"bytes,1,rep,name=triggers,proto3" json:"triggers,omitempty"` // contains filtered or unexported fields }
func (*GetKeygroupTriggerResponse) Descriptor
deprecated
func (*GetKeygroupTriggerResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetKeygroupTriggerResponse.ProtoReflect.Descriptor instead.
func (*GetKeygroupTriggerResponse) GetTriggers ¶
func (x *GetKeygroupTriggerResponse) GetTriggers() []*Trigger
func (*GetKeygroupTriggerResponse) ProtoMessage ¶
func (*GetKeygroupTriggerResponse) ProtoMessage()
func (*GetKeygroupTriggerResponse) ProtoReflect ¶
func (x *GetKeygroupTriggerResponse) ProtoReflect() protoreflect.Message
func (*GetKeygroupTriggerResponse) Reset ¶
func (x *GetKeygroupTriggerResponse) Reset()
func (*GetKeygroupTriggerResponse) String ¶
func (x *GetKeygroupTriggerResponse) String() string
type GetReplicaRequest ¶
type GetReplicaRequest struct { NodeId string `protobuf:"bytes,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"` // contains filtered or unexported fields }
func (*GetReplicaRequest) Descriptor
deprecated
func (*GetReplicaRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetReplicaRequest.ProtoReflect.Descriptor instead.
func (*GetReplicaRequest) GetNodeId ¶
func (x *GetReplicaRequest) GetNodeId() string
func (*GetReplicaRequest) ProtoMessage ¶
func (*GetReplicaRequest) ProtoMessage()
func (*GetReplicaRequest) ProtoReflect ¶
func (x *GetReplicaRequest) ProtoReflect() protoreflect.Message
func (*GetReplicaRequest) Reset ¶
func (x *GetReplicaRequest) Reset()
func (*GetReplicaRequest) String ¶
func (x *GetReplicaRequest) String() string
type GetReplicaResponse ¶
type GetReplicaResponse struct { NodeId string `protobuf:"bytes,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"` Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"` // contains filtered or unexported fields }
func (*GetReplicaResponse) Descriptor
deprecated
func (*GetReplicaResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetReplicaResponse.ProtoReflect.Descriptor instead.
func (*GetReplicaResponse) GetHost ¶
func (x *GetReplicaResponse) GetHost() string
func (*GetReplicaResponse) GetNodeId ¶
func (x *GetReplicaResponse) GetNodeId() string
func (*GetReplicaResponse) ProtoMessage ¶
func (*GetReplicaResponse) ProtoMessage()
func (*GetReplicaResponse) ProtoReflect ¶
func (x *GetReplicaResponse) ProtoReflect() protoreflect.Message
func (*GetReplicaResponse) Reset ¶
func (x *GetReplicaResponse) Reset()
func (*GetReplicaResponse) String ¶
func (x *GetReplicaResponse) String() string
type Item ¶ added in v0.2.1
type Item struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Val string `protobuf:"bytes,2,opt,name=val,proto3" json:"val,omitempty"` Version *Version `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
func (*Item) Descriptor
deprecated
added in
v0.2.1
func (*Item) GetVersion ¶ added in v0.2.1
func (*Item) ProtoMessage ¶ added in v0.2.1
func (*Item) ProtoMessage()
func (*Item) ProtoReflect ¶ added in v0.2.1
func (x *Item) ProtoReflect() protoreflect.Message
type Key ¶ added in v0.2.19
type Key struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Version *Version `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
func (*Key) Descriptor
deprecated
added in
v0.2.19
func (*Key) GetVersion ¶ added in v0.2.19
func (*Key) ProtoMessage ¶ added in v0.2.19
func (*Key) ProtoMessage()
func (*Key) ProtoReflect ¶ added in v0.2.19
func (x *Key) ProtoReflect() protoreflect.Message
type KeygroupReplica ¶
type KeygroupReplica struct { NodeId string `protobuf:"bytes,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"` Expiry int64 `protobuf:"varint,2,opt,name=expiry,proto3" json:"expiry,omitempty"` Host string `protobuf:"bytes,3,opt,name=host,proto3" json:"host,omitempty"` // contains filtered or unexported fields }
func (*KeygroupReplica) Descriptor
deprecated
func (*KeygroupReplica) Descriptor() ([]byte, []int)
Deprecated: Use KeygroupReplica.ProtoReflect.Descriptor instead.
func (*KeygroupReplica) GetExpiry ¶
func (x *KeygroupReplica) GetExpiry() int64
func (*KeygroupReplica) GetHost ¶
func (x *KeygroupReplica) GetHost() string
func (*KeygroupReplica) GetNodeId ¶
func (x *KeygroupReplica) GetNodeId() string
func (*KeygroupReplica) ProtoMessage ¶
func (*KeygroupReplica) ProtoMessage()
func (*KeygroupReplica) ProtoReflect ¶
func (x *KeygroupReplica) ProtoReflect() protoreflect.Message
func (*KeygroupReplica) Reset ¶
func (x *KeygroupReplica) Reset()
func (*KeygroupReplica) String ¶
func (x *KeygroupReplica) String() string
type KeysRequest ¶ added in v0.2.19
type KeysRequest struct { Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` Count uint64 `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"` // contains filtered or unexported fields }
func (*KeysRequest) Descriptor
deprecated
added in
v0.2.19
func (*KeysRequest) Descriptor() ([]byte, []int)
Deprecated: Use KeysRequest.ProtoReflect.Descriptor instead.
func (*KeysRequest) GetCount ¶ added in v0.2.19
func (x *KeysRequest) GetCount() uint64
func (*KeysRequest) GetId ¶ added in v0.2.19
func (x *KeysRequest) GetId() string
func (*KeysRequest) GetKeygroup ¶ added in v0.2.19
func (x *KeysRequest) GetKeygroup() string
func (*KeysRequest) ProtoMessage ¶ added in v0.2.19
func (*KeysRequest) ProtoMessage()
func (*KeysRequest) ProtoReflect ¶ added in v0.2.19
func (x *KeysRequest) ProtoReflect() protoreflect.Message
func (*KeysRequest) Reset ¶ added in v0.2.19
func (x *KeysRequest) Reset()
func (*KeysRequest) String ¶ added in v0.2.19
func (x *KeysRequest) String() string
type KeysResponse ¶ added in v0.2.19
type KeysResponse struct { Keys []*Key `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"` // contains filtered or unexported fields }
func (*KeysResponse) Descriptor
deprecated
added in
v0.2.19
func (*KeysResponse) Descriptor() ([]byte, []int)
Deprecated: Use KeysResponse.ProtoReflect.Descriptor instead.
func (*KeysResponse) GetKeys ¶ added in v0.2.19
func (x *KeysResponse) GetKeys() []*Key
func (*KeysResponse) ProtoMessage ¶ added in v0.2.19
func (*KeysResponse) ProtoMessage()
func (*KeysResponse) ProtoReflect ¶ added in v0.2.19
func (x *KeysResponse) ProtoReflect() protoreflect.Message
func (*KeysResponse) Reset ¶ added in v0.2.19
func (x *KeysResponse) Reset()
func (*KeysResponse) String ¶ added in v0.2.19
func (x *KeysResponse) String() string
type ReadRequest ¶
type ReadRequest struct { Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` Versions []*Version `protobuf:"bytes,3,rep,name=versions,proto3" json:"versions,omitempty"` // contains filtered or unexported fields }
func (*ReadRequest) Descriptor
deprecated
func (*ReadRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadRequest.ProtoReflect.Descriptor instead.
func (*ReadRequest) GetId ¶
func (x *ReadRequest) GetId() string
func (*ReadRequest) GetKeygroup ¶
func (x *ReadRequest) GetKeygroup() string
func (*ReadRequest) GetVersions ¶ added in v0.2.1
func (x *ReadRequest) GetVersions() []*Version
func (*ReadRequest) ProtoMessage ¶
func (*ReadRequest) ProtoMessage()
func (*ReadRequest) ProtoReflect ¶
func (x *ReadRequest) ProtoReflect() protoreflect.Message
func (*ReadRequest) Reset ¶
func (x *ReadRequest) Reset()
func (*ReadRequest) String ¶
func (x *ReadRequest) String() string
type ReadResponse ¶
type ReadResponse struct { Data []*Item `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*ReadResponse) Descriptor
deprecated
func (*ReadResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReadResponse.ProtoReflect.Descriptor instead.
func (*ReadResponse) GetData ¶
func (x *ReadResponse) GetData() []*Item
func (*ReadResponse) ProtoMessage ¶
func (*ReadResponse) ProtoMessage()
func (*ReadResponse) ProtoReflect ¶
func (x *ReadResponse) ProtoReflect() protoreflect.Message
func (*ReadResponse) Reset ¶
func (x *ReadResponse) Reset()
func (*ReadResponse) String ¶
func (x *ReadResponse) String() string
type RemoveReplicaRequest ¶
type RemoveReplicaRequest struct { Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"` NodeId string `protobuf:"bytes,2,opt,name=nodeId,proto3" json:"nodeId,omitempty"` // contains filtered or unexported fields }
func (*RemoveReplicaRequest) Descriptor
deprecated
func (*RemoveReplicaRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemoveReplicaRequest.ProtoReflect.Descriptor instead.
func (*RemoveReplicaRequest) GetKeygroup ¶
func (x *RemoveReplicaRequest) GetKeygroup() string
func (*RemoveReplicaRequest) GetNodeId ¶
func (x *RemoveReplicaRequest) GetNodeId() string
func (*RemoveReplicaRequest) ProtoMessage ¶
func (*RemoveReplicaRequest) ProtoMessage()
func (*RemoveReplicaRequest) ProtoReflect ¶
func (x *RemoveReplicaRequest) ProtoReflect() protoreflect.Message
func (*RemoveReplicaRequest) Reset ¶
func (x *RemoveReplicaRequest) Reset()
func (*RemoveReplicaRequest) String ¶
func (x *RemoveReplicaRequest) String() string
type RemoveTriggerRequest ¶
type RemoveTriggerRequest struct { Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"` TriggerId string `protobuf:"bytes,2,opt,name=triggerId,proto3" json:"triggerId,omitempty"` // contains filtered or unexported fields }
func (*RemoveTriggerRequest) Descriptor
deprecated
func (*RemoveTriggerRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemoveTriggerRequest.ProtoReflect.Descriptor instead.
func (*RemoveTriggerRequest) GetKeygroup ¶
func (x *RemoveTriggerRequest) GetKeygroup() string
func (*RemoveTriggerRequest) GetTriggerId ¶
func (x *RemoveTriggerRequest) GetTriggerId() string
func (*RemoveTriggerRequest) ProtoMessage ¶
func (*RemoveTriggerRequest) ProtoMessage()
func (*RemoveTriggerRequest) ProtoReflect ¶
func (x *RemoveTriggerRequest) ProtoReflect() protoreflect.Message
func (*RemoveTriggerRequest) Reset ¶
func (x *RemoveTriggerRequest) Reset()
func (*RemoveTriggerRequest) String ¶
func (x *RemoveTriggerRequest) String() string
type RemoveUserRequest ¶ added in v0.2.1
type RemoveUserRequest struct { User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` Keygroup string `protobuf:"bytes,2,opt,name=keygroup,proto3" json:"keygroup,omitempty"` Role UserRole `protobuf:"varint,3,opt,name=role,proto3,enum=mcc.fred.client.UserRole" json:"role,omitempty"` // contains filtered or unexported fields }
func (*RemoveUserRequest) Descriptor
deprecated
added in
v0.2.1
func (*RemoveUserRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemoveUserRequest.ProtoReflect.Descriptor instead.
func (*RemoveUserRequest) GetKeygroup ¶ added in v0.2.1
func (x *RemoveUserRequest) GetKeygroup() string
func (*RemoveUserRequest) GetRole ¶ added in v0.2.1
func (x *RemoveUserRequest) GetRole() UserRole
func (*RemoveUserRequest) GetUser ¶ added in v0.2.1
func (x *RemoveUserRequest) GetUser() string
func (*RemoveUserRequest) ProtoMessage ¶ added in v0.2.1
func (*RemoveUserRequest) ProtoMessage()
func (*RemoveUserRequest) ProtoReflect ¶ added in v0.2.1
func (x *RemoveUserRequest) ProtoReflect() protoreflect.Message
func (*RemoveUserRequest) Reset ¶ added in v0.2.1
func (x *RemoveUserRequest) Reset()
func (*RemoveUserRequest) String ¶ added in v0.2.1
func (x *RemoveUserRequest) String() string
type Replica ¶ added in v0.2.1
type Replica struct { NodeId string `protobuf:"bytes,1,opt,name=nodeId,proto3" json:"nodeId,omitempty"` Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"` // contains filtered or unexported fields }
func (*Replica) Descriptor
deprecated
added in
v0.2.1
func (*Replica) ProtoMessage ¶ added in v0.2.1
func (*Replica) ProtoMessage()
func (*Replica) ProtoReflect ¶ added in v0.2.1
func (x *Replica) ProtoReflect() protoreflect.Message
type ScanRequest ¶
type ScanRequest struct { Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` Count uint64 `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"` // contains filtered or unexported fields }
func (*ScanRequest) Descriptor
deprecated
func (*ScanRequest) Descriptor() ([]byte, []int)
Deprecated: Use ScanRequest.ProtoReflect.Descriptor instead.
func (*ScanRequest) GetCount ¶
func (x *ScanRequest) GetCount() uint64
func (*ScanRequest) GetId ¶
func (x *ScanRequest) GetId() string
func (*ScanRequest) GetKeygroup ¶
func (x *ScanRequest) GetKeygroup() string
func (*ScanRequest) ProtoMessage ¶
func (*ScanRequest) ProtoMessage()
func (*ScanRequest) ProtoReflect ¶
func (x *ScanRequest) ProtoReflect() protoreflect.Message
func (*ScanRequest) Reset ¶
func (x *ScanRequest) Reset()
func (*ScanRequest) String ¶
func (x *ScanRequest) String() string
type ScanResponse ¶
type ScanResponse struct { Data []*Item `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*ScanResponse) Descriptor
deprecated
func (*ScanResponse) Descriptor() ([]byte, []int)
Deprecated: Use ScanResponse.ProtoReflect.Descriptor instead.
func (*ScanResponse) GetData ¶
func (x *ScanResponse) GetData() []*Item
func (*ScanResponse) ProtoMessage ¶
func (*ScanResponse) ProtoMessage()
func (*ScanResponse) ProtoReflect ¶
func (x *ScanResponse) ProtoReflect() protoreflect.Message
func (*ScanResponse) Reset ¶
func (x *ScanResponse) Reset()
func (*ScanResponse) String ¶
func (x *ScanResponse) String() string
type Trigger ¶
type Trigger struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"` // contains filtered or unexported fields }
func (*Trigger) Descriptor
deprecated
func (*Trigger) ProtoMessage ¶
func (*Trigger) ProtoMessage()
func (*Trigger) ProtoReflect ¶
func (x *Trigger) ProtoReflect() protoreflect.Message
type UnimplementedClientServer ¶
type UnimplementedClientServer struct { }
UnimplementedClientServer should be embedded to have forward compatible implementations.
func (UnimplementedClientServer) AddReplica ¶
func (UnimplementedClientServer) AddReplica(context.Context, *AddReplicaRequest) (*Empty, error)
func (UnimplementedClientServer) AddTrigger ¶
func (UnimplementedClientServer) AddTrigger(context.Context, *AddTriggerRequest) (*Empty, error)
func (UnimplementedClientServer) AddUser ¶
func (UnimplementedClientServer) AddUser(context.Context, *AddUserRequest) (*Empty, error)
func (UnimplementedClientServer) Append ¶
func (UnimplementedClientServer) Append(context.Context, *AppendRequest) (*AppendResponse, error)
func (UnimplementedClientServer) CreateKeygroup ¶
func (UnimplementedClientServer) CreateKeygroup(context.Context, *CreateKeygroupRequest) (*Empty, error)
func (UnimplementedClientServer) Delete ¶
func (UnimplementedClientServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
func (UnimplementedClientServer) DeleteKeygroup ¶
func (UnimplementedClientServer) DeleteKeygroup(context.Context, *DeleteKeygroupRequest) (*Empty, error)
func (UnimplementedClientServer) GetAllReplica ¶
func (UnimplementedClientServer) GetAllReplica(context.Context, *Empty) (*GetAllReplicaResponse, error)
func (UnimplementedClientServer) GetKeygroupInfo ¶ added in v0.2.2
func (UnimplementedClientServer) GetKeygroupInfo(context.Context, *GetKeygroupInfoRequest) (*GetKeygroupInfoResponse, error)
func (UnimplementedClientServer) GetKeygroupTriggers ¶
func (UnimplementedClientServer) GetKeygroupTriggers(context.Context, *GetKeygroupTriggerRequest) (*GetKeygroupTriggerResponse, error)
func (UnimplementedClientServer) GetReplica ¶
func (UnimplementedClientServer) GetReplica(context.Context, *GetReplicaRequest) (*GetReplicaResponse, error)
func (UnimplementedClientServer) Keys ¶ added in v0.2.19
func (UnimplementedClientServer) Keys(context.Context, *KeysRequest) (*KeysResponse, error)
func (UnimplementedClientServer) Read ¶
func (UnimplementedClientServer) Read(context.Context, *ReadRequest) (*ReadResponse, error)
func (UnimplementedClientServer) RemoveReplica ¶
func (UnimplementedClientServer) RemoveReplica(context.Context, *RemoveReplicaRequest) (*Empty, error)
func (UnimplementedClientServer) RemoveTrigger ¶
func (UnimplementedClientServer) RemoveTrigger(context.Context, *RemoveTriggerRequest) (*Empty, error)
func (UnimplementedClientServer) RemoveUser ¶
func (UnimplementedClientServer) RemoveUser(context.Context, *RemoveUserRequest) (*Empty, error)
func (UnimplementedClientServer) Scan ¶
func (UnimplementedClientServer) Scan(context.Context, *ScanRequest) (*ScanResponse, error)
func (UnimplementedClientServer) Update ¶
func (UnimplementedClientServer) Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
type UnsafeClientServer ¶
type UnsafeClientServer interface {
// contains filtered or unexported methods
}
UnsafeClientServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ClientServer will result in compilation errors.
type UpdateRequest ¶
type UpdateRequest struct { Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` Data string `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"` Versions []*Version `protobuf:"bytes,4,rep,name=versions,proto3" json:"versions,omitempty"` // contains filtered or unexported fields }
func (*UpdateRequest) Descriptor
deprecated
func (*UpdateRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateRequest.ProtoReflect.Descriptor instead.
func (*UpdateRequest) GetData ¶
func (x *UpdateRequest) GetData() string
func (*UpdateRequest) GetId ¶
func (x *UpdateRequest) GetId() string
func (*UpdateRequest) GetKeygroup ¶
func (x *UpdateRequest) GetKeygroup() string
func (*UpdateRequest) GetVersions ¶ added in v0.2.1
func (x *UpdateRequest) GetVersions() []*Version
func (*UpdateRequest) ProtoMessage ¶
func (*UpdateRequest) ProtoMessage()
func (*UpdateRequest) ProtoReflect ¶
func (x *UpdateRequest) ProtoReflect() protoreflect.Message
func (*UpdateRequest) Reset ¶
func (x *UpdateRequest) Reset()
func (*UpdateRequest) String ¶
func (x *UpdateRequest) String() string
type UpdateResponse ¶ added in v0.2.1
type UpdateResponse struct { Version *Version `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
func (*UpdateResponse) Descriptor
deprecated
added in
v0.2.1
func (*UpdateResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateResponse.ProtoReflect.Descriptor instead.
func (*UpdateResponse) GetVersion ¶ added in v0.2.1
func (x *UpdateResponse) GetVersion() *Version
func (*UpdateResponse) ProtoMessage ¶ added in v0.2.1
func (*UpdateResponse) ProtoMessage()
func (*UpdateResponse) ProtoReflect ¶ added in v0.2.1
func (x *UpdateResponse) ProtoReflect() protoreflect.Message
func (*UpdateResponse) Reset ¶ added in v0.2.1
func (x *UpdateResponse) Reset()
func (*UpdateResponse) String ¶ added in v0.2.1
func (x *UpdateResponse) String() string
type UserRole ¶
type UserRole int32
func (UserRole) Descriptor ¶
func (UserRole) Descriptor() protoreflect.EnumDescriptor
func (UserRole) EnumDescriptor
deprecated
func (UserRole) Number ¶
func (x UserRole) Number() protoreflect.EnumNumber
func (UserRole) Type ¶
func (UserRole) Type() protoreflect.EnumType
type Version ¶ added in v0.2.1
type Version struct { Version map[string]uint64 `` /* 156-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Version) Descriptor
deprecated
added in
v0.2.1
func (*Version) GetVersion ¶ added in v0.2.1
func (*Version) ProtoMessage ¶ added in v0.2.1
func (*Version) ProtoMessage()
func (*Version) ProtoReflect ¶ added in v0.2.1
func (x *Version) ProtoReflect() protoreflect.Message