Documentation ¶
Index ¶
- Variables
- func RegisterDatabaseServer(s grpc.ServiceRegistrar, srv DatabaseServer)
- type AddKeygroupTriggerRequest
- func (*AddKeygroupTriggerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AddKeygroupTriggerRequest) GetHost() string
- func (x *AddKeygroupTriggerRequest) GetId() string
- func (x *AddKeygroupTriggerRequest) GetKeygroup() string
- func (*AddKeygroupTriggerRequest) ProtoMessage()
- func (x *AddKeygroupTriggerRequest) ProtoReflect() protoreflect.Message
- func (x *AddKeygroupTriggerRequest) Reset()
- func (x *AddKeygroupTriggerRequest) String() string
- type AddKeygroupTriggerResponse
- type AppendRequest
- func (*AppendRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AppendRequest) GetExpiry() int64
- func (x *AppendRequest) GetId() string
- func (x *AppendRequest) GetKeygroup() string
- func (x *AppendRequest) GetVal() string
- func (*AppendRequest) ProtoMessage()
- func (x *AppendRequest) ProtoReflect() protoreflect.Message
- func (x *AppendRequest) Reset()
- func (x *AppendRequest) String() string
- type AppendResponse
- type CreateKeygroupRequest
- func (*CreateKeygroupRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateKeygroupRequest) GetKeygroup() string
- func (*CreateKeygroupRequest) ProtoMessage()
- func (x *CreateKeygroupRequest) ProtoReflect() protoreflect.Message
- func (x *CreateKeygroupRequest) Reset()
- func (x *CreateKeygroupRequest) String() string
- type CreateKeygroupResponse
- type DatabaseClient
- type DatabaseServer
- 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 DeleteKeygroupResponse
- type DeleteKeygroupTriggerRequest
- func (*DeleteKeygroupTriggerRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteKeygroupTriggerRequest) GetId() string
- func (x *DeleteKeygroupTriggerRequest) GetKeygroup() string
- func (*DeleteKeygroupTriggerRequest) ProtoMessage()
- func (x *DeleteKeygroupTriggerRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteKeygroupTriggerRequest) Reset()
- func (x *DeleteKeygroupTriggerRequest) String() string
- type DeleteKeygroupTriggerResponse
- func (*DeleteKeygroupTriggerResponse) Descriptor() ([]byte, []int)deprecated
- func (*DeleteKeygroupTriggerResponse) ProtoMessage()
- func (x *DeleteKeygroupTriggerResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteKeygroupTriggerResponse) Reset()
- func (x *DeleteKeygroupTriggerResponse) String() string
- type DeleteRequest
- func (*DeleteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteRequest) GetId() string
- func (x *DeleteRequest) GetKeygroup() string
- func (x *DeleteRequest) GetVersion() map[string]uint64
- func (*DeleteRequest) ProtoMessage()
- func (x *DeleteRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteRequest) Reset()
- func (x *DeleteRequest) String() string
- type DeleteResponse
- type ExistsKeygroupRequest
- func (*ExistsKeygroupRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExistsKeygroupRequest) GetKeygroup() string
- func (*ExistsKeygroupRequest) ProtoMessage()
- func (x *ExistsKeygroupRequest) ProtoReflect() protoreflect.Message
- func (x *ExistsKeygroupRequest) Reset()
- func (x *ExistsKeygroupRequest) String() string
- type ExistsKeygroupResponse
- func (*ExistsKeygroupResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ExistsKeygroupResponse) GetExists() bool
- func (*ExistsKeygroupResponse) ProtoMessage()
- func (x *ExistsKeygroupResponse) ProtoReflect() protoreflect.Message
- func (x *ExistsKeygroupResponse) Reset()
- func (x *ExistsKeygroupResponse) String() string
- type ExistsRequest
- func (*ExistsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExistsRequest) GetId() string
- func (x *ExistsRequest) GetKeygroup() string
- func (*ExistsRequest) ProtoMessage()
- func (x *ExistsRequest) ProtoReflect() protoreflect.Message
- func (x *ExistsRequest) Reset()
- func (x *ExistsRequest) String() string
- type ExistsResponse
- 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 IDsRequest
- type IDsResponse
- type Item
- func (*Item) Descriptor() ([]byte, []int)deprecated
- func (x *Item) GetId() string
- func (x *Item) GetKeygroup() string
- func (x *Item) GetVal() string
- func (x *Item) GetVersion() map[string]uint64
- func (*Item) ProtoMessage()
- func (x *Item) ProtoReflect() protoreflect.Message
- func (x *Item) Reset()
- func (x *Item) String() string
- type ReadAllRequest
- type ReadAllResponse
- type ReadRequest
- type ReadResponse
- type ScanRequest
- func (*ScanRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ScanRequest) GetCount() uint64
- func (x *ScanRequest) GetKeygroup() string
- func (x *ScanRequest) GetStart() string
- func (*ScanRequest) ProtoMessage()
- func (x *ScanRequest) ProtoReflect() protoreflect.Message
- func (x *ScanRequest) Reset()
- func (x *ScanRequest) String() string
- type ScanResponse
- type Trigger
- type UnimplementedDatabaseServer
- func (UnimplementedDatabaseServer) AddKeygroupTrigger(context.Context, *AddKeygroupTriggerRequest) (*AddKeygroupTriggerResponse, error)
- func (UnimplementedDatabaseServer) Append(context.Context, *AppendRequest) (*AppendResponse, error)
- func (UnimplementedDatabaseServer) CreateKeygroup(context.Context, *CreateKeygroupRequest) (*CreateKeygroupResponse, error)
- func (UnimplementedDatabaseServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
- func (UnimplementedDatabaseServer) DeleteKeygroup(context.Context, *DeleteKeygroupRequest) (*DeleteKeygroupResponse, error)
- func (UnimplementedDatabaseServer) DeleteKeygroupTrigger(context.Context, *DeleteKeygroupTriggerRequest) (*DeleteKeygroupTriggerResponse, error)
- func (UnimplementedDatabaseServer) Exists(context.Context, *ExistsRequest) (*ExistsResponse, error)
- func (UnimplementedDatabaseServer) ExistsKeygroup(context.Context, *ExistsKeygroupRequest) (*ExistsKeygroupResponse, error)
- func (UnimplementedDatabaseServer) GetKeygroupTrigger(context.Context, *GetKeygroupTriggerRequest) (*GetKeygroupTriggerResponse, error)
- func (UnimplementedDatabaseServer) IDs(context.Context, *IDsRequest) (*IDsResponse, error)
- func (UnimplementedDatabaseServer) Read(context.Context, *ReadRequest) (*ReadResponse, error)
- func (UnimplementedDatabaseServer) ReadAll(context.Context, *ReadAllRequest) (*ReadAllResponse, error)
- func (UnimplementedDatabaseServer) Scan(context.Context, *ScanRequest) (*ScanResponse, error)
- func (UnimplementedDatabaseServer) Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
- type UnsafeDatabaseServer
- type UpdateRequest
- func (*UpdateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateRequest) GetExpiry() int64
- func (x *UpdateRequest) GetId() string
- func (x *UpdateRequest) GetKeygroup() string
- func (x *UpdateRequest) GetVal() string
- func (x *UpdateRequest) GetVersion() map[string]uint64
- func (*UpdateRequest) ProtoMessage()
- func (x *UpdateRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateRequest) Reset()
- func (x *UpdateRequest) String() string
- type UpdateResponse
Constants ¶
This section is empty.
Variables ¶
var Database_ServiceDesc = grpc.ServiceDesc{ ServiceName: "mcc.fred.storage.Database", HandlerType: (*DatabaseServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Update", Handler: _Database_Update_Handler, }, { MethodName: "Delete", Handler: _Database_Delete_Handler, }, { MethodName: "Append", Handler: _Database_Append_Handler, }, { MethodName: "Read", Handler: _Database_Read_Handler, }, { MethodName: "Scan", Handler: _Database_Scan_Handler, }, { MethodName: "ReadAll", Handler: _Database_ReadAll_Handler, }, { MethodName: "IDs", Handler: _Database_IDs_Handler, }, { MethodName: "Exists", Handler: _Database_Exists_Handler, }, { MethodName: "CreateKeygroup", Handler: _Database_CreateKeygroup_Handler, }, { MethodName: "DeleteKeygroup", Handler: _Database_DeleteKeygroup_Handler, }, { MethodName: "ExistsKeygroup", Handler: _Database_ExistsKeygroup_Handler, }, { MethodName: "AddKeygroupTrigger", Handler: _Database_AddKeygroupTrigger_Handler, }, { MethodName: "DeleteKeygroupTrigger", Handler: _Database_DeleteKeygroupTrigger_Handler, }, { MethodName: "GetKeygroupTrigger", Handler: _Database_GetKeygroupTrigger_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "storage.proto", }
Database_ServiceDesc is the grpc.ServiceDesc for Database service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_storage_proto protoreflect.FileDescriptor
Functions ¶
func RegisterDatabaseServer ¶
func RegisterDatabaseServer(s grpc.ServiceRegistrar, srv DatabaseServer)
Types ¶
type AddKeygroupTriggerRequest ¶ added in v0.2.1
type AddKeygroupTriggerRequest 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"` Host string `protobuf:"bytes,3,opt,name=host,proto3" json:"host,omitempty"` // contains filtered or unexported fields }
func (*AddKeygroupTriggerRequest) Descriptor
deprecated
added in
v0.2.1
func (*AddKeygroupTriggerRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddKeygroupTriggerRequest.ProtoReflect.Descriptor instead.
func (*AddKeygroupTriggerRequest) GetHost ¶ added in v0.2.1
func (x *AddKeygroupTriggerRequest) GetHost() string
func (*AddKeygroupTriggerRequest) GetId ¶ added in v0.2.1
func (x *AddKeygroupTriggerRequest) GetId() string
func (*AddKeygroupTriggerRequest) GetKeygroup ¶ added in v0.2.1
func (x *AddKeygroupTriggerRequest) GetKeygroup() string
func (*AddKeygroupTriggerRequest) ProtoMessage ¶ added in v0.2.1
func (*AddKeygroupTriggerRequest) ProtoMessage()
func (*AddKeygroupTriggerRequest) ProtoReflect ¶ added in v0.2.1
func (x *AddKeygroupTriggerRequest) ProtoReflect() protoreflect.Message
func (*AddKeygroupTriggerRequest) Reset ¶ added in v0.2.1
func (x *AddKeygroupTriggerRequest) Reset()
func (*AddKeygroupTriggerRequest) String ¶ added in v0.2.1
func (x *AddKeygroupTriggerRequest) String() string
type AddKeygroupTriggerResponse ¶ added in v0.2.1
type AddKeygroupTriggerResponse struct {
// contains filtered or unexported fields
}
func (*AddKeygroupTriggerResponse) Descriptor
deprecated
added in
v0.2.1
func (*AddKeygroupTriggerResponse) Descriptor() ([]byte, []int)
Deprecated: Use AddKeygroupTriggerResponse.ProtoReflect.Descriptor instead.
func (*AddKeygroupTriggerResponse) ProtoMessage ¶ added in v0.2.1
func (*AddKeygroupTriggerResponse) ProtoMessage()
func (*AddKeygroupTriggerResponse) ProtoReflect ¶ added in v0.2.1
func (x *AddKeygroupTriggerResponse) ProtoReflect() protoreflect.Message
func (*AddKeygroupTriggerResponse) Reset ¶ added in v0.2.1
func (x *AddKeygroupTriggerResponse) Reset()
func (*AddKeygroupTriggerResponse) String ¶ added in v0.2.1
func (x *AddKeygroupTriggerResponse) String() string
type AppendRequest ¶ added in v0.2.1
type AppendRequest 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"` Val string `protobuf:"bytes,3,opt,name=val,proto3" json:"val,omitempty"` Expiry int64 `protobuf:"varint,4,opt,name=expiry,proto3" json:"expiry,omitempty"` // contains filtered or unexported fields }
func (*AppendRequest) Descriptor
deprecated
added in
v0.2.1
func (*AppendRequest) Descriptor() ([]byte, []int)
Deprecated: Use AppendRequest.ProtoReflect.Descriptor instead.
func (*AppendRequest) GetExpiry ¶ added in v0.2.1
func (x *AppendRequest) GetExpiry() int64
func (*AppendRequest) GetId ¶ added in v0.2.1
func (x *AppendRequest) GetId() string
func (*AppendRequest) GetKeygroup ¶ added in v0.2.1
func (x *AppendRequest) GetKeygroup() string
func (*AppendRequest) GetVal ¶ added in v0.2.1
func (x *AppendRequest) GetVal() string
func (*AppendRequest) ProtoMessage ¶ added in v0.2.1
func (*AppendRequest) ProtoMessage()
func (*AppendRequest) ProtoReflect ¶ added in v0.2.1
func (x *AppendRequest) ProtoReflect() protoreflect.Message
func (*AppendRequest) Reset ¶ added in v0.2.1
func (x *AppendRequest) Reset()
func (*AppendRequest) String ¶ added in v0.2.1
func (x *AppendRequest) String() string
type AppendResponse ¶ added in v0.2.1
type AppendResponse struct {
// contains filtered or unexported fields
}
func (*AppendResponse) Descriptor
deprecated
added in
v0.2.1
func (*AppendResponse) Descriptor() ([]byte, []int)
Deprecated: Use AppendResponse.ProtoReflect.Descriptor instead.
func (*AppendResponse) ProtoMessage ¶ added in v0.2.1
func (*AppendResponse) ProtoMessage()
func (*AppendResponse) ProtoReflect ¶ added in v0.2.1
func (x *AppendResponse) ProtoReflect() protoreflect.Message
func (*AppendResponse) Reset ¶ added in v0.2.1
func (x *AppendResponse) Reset()
func (*AppendResponse) String ¶ added in v0.2.1
func (x *AppendResponse) String() string
type CreateKeygroupRequest ¶ added in v0.2.1
type CreateKeygroupRequest struct { Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"` // contains filtered or unexported fields }
func (*CreateKeygroupRequest) Descriptor
deprecated
added in
v0.2.1
func (*CreateKeygroupRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateKeygroupRequest.ProtoReflect.Descriptor instead.
func (*CreateKeygroupRequest) GetKeygroup ¶ added in v0.2.1
func (x *CreateKeygroupRequest) GetKeygroup() string
func (*CreateKeygroupRequest) ProtoMessage ¶ added in v0.2.1
func (*CreateKeygroupRequest) ProtoMessage()
func (*CreateKeygroupRequest) ProtoReflect ¶ added in v0.2.1
func (x *CreateKeygroupRequest) ProtoReflect() protoreflect.Message
func (*CreateKeygroupRequest) Reset ¶ added in v0.2.1
func (x *CreateKeygroupRequest) Reset()
func (*CreateKeygroupRequest) String ¶ added in v0.2.1
func (x *CreateKeygroupRequest) String() string
type CreateKeygroupResponse ¶ added in v0.2.1
type CreateKeygroupResponse struct {
// contains filtered or unexported fields
}
func (*CreateKeygroupResponse) Descriptor
deprecated
added in
v0.2.1
func (*CreateKeygroupResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateKeygroupResponse.ProtoReflect.Descriptor instead.
func (*CreateKeygroupResponse) ProtoMessage ¶ added in v0.2.1
func (*CreateKeygroupResponse) ProtoMessage()
func (*CreateKeygroupResponse) ProtoReflect ¶ added in v0.2.1
func (x *CreateKeygroupResponse) ProtoReflect() protoreflect.Message
func (*CreateKeygroupResponse) Reset ¶ added in v0.2.1
func (x *CreateKeygroupResponse) Reset()
func (*CreateKeygroupResponse) String ¶ added in v0.2.1
func (x *CreateKeygroupResponse) String() string
type DatabaseClient ¶
type DatabaseClient interface { 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) Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error) Scan(ctx context.Context, in *ScanRequest, opts ...grpc.CallOption) (*ScanResponse, error) ReadAll(ctx context.Context, in *ReadAllRequest, opts ...grpc.CallOption) (*ReadAllResponse, error) IDs(ctx context.Context, in *IDsRequest, opts ...grpc.CallOption) (*IDsResponse, error) Exists(ctx context.Context, in *ExistsRequest, opts ...grpc.CallOption) (*ExistsResponse, error) CreateKeygroup(ctx context.Context, in *CreateKeygroupRequest, opts ...grpc.CallOption) (*CreateKeygroupResponse, error) DeleteKeygroup(ctx context.Context, in *DeleteKeygroupRequest, opts ...grpc.CallOption) (*DeleteKeygroupResponse, error) ExistsKeygroup(ctx context.Context, in *ExistsKeygroupRequest, opts ...grpc.CallOption) (*ExistsKeygroupResponse, error) AddKeygroupTrigger(ctx context.Context, in *AddKeygroupTriggerRequest, opts ...grpc.CallOption) (*AddKeygroupTriggerResponse, error) DeleteKeygroupTrigger(ctx context.Context, in *DeleteKeygroupTriggerRequest, opts ...grpc.CallOption) (*DeleteKeygroupTriggerResponse, error) GetKeygroupTrigger(ctx context.Context, in *GetKeygroupTriggerRequest, opts ...grpc.CallOption) (*GetKeygroupTriggerResponse, error) }
DatabaseClient is the client API for Database 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 NewDatabaseClient ¶
func NewDatabaseClient(cc grpc.ClientConnInterface) DatabaseClient
type DatabaseServer ¶
type DatabaseServer interface { Update(context.Context, *UpdateRequest) (*UpdateResponse, error) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error) Append(context.Context, *AppendRequest) (*AppendResponse, error) Read(context.Context, *ReadRequest) (*ReadResponse, error) Scan(context.Context, *ScanRequest) (*ScanResponse, error) ReadAll(context.Context, *ReadAllRequest) (*ReadAllResponse, error) IDs(context.Context, *IDsRequest) (*IDsResponse, error) Exists(context.Context, *ExistsRequest) (*ExistsResponse, error) CreateKeygroup(context.Context, *CreateKeygroupRequest) (*CreateKeygroupResponse, error) DeleteKeygroup(context.Context, *DeleteKeygroupRequest) (*DeleteKeygroupResponse, error) ExistsKeygroup(context.Context, *ExistsKeygroupRequest) (*ExistsKeygroupResponse, error) AddKeygroupTrigger(context.Context, *AddKeygroupTriggerRequest) (*AddKeygroupTriggerResponse, error) DeleteKeygroupTrigger(context.Context, *DeleteKeygroupTriggerRequest) (*DeleteKeygroupTriggerResponse, error) GetKeygroupTrigger(context.Context, *GetKeygroupTriggerRequest) (*GetKeygroupTriggerResponse, error) }
DatabaseServer is the server API for Database service. All implementations should embed UnimplementedDatabaseServer for forward compatibility
type DeleteKeygroupRequest ¶ added in v0.2.1
type DeleteKeygroupRequest struct { Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"` // contains filtered or unexported fields }
func (*DeleteKeygroupRequest) Descriptor
deprecated
added in
v0.2.1
func (*DeleteKeygroupRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteKeygroupRequest.ProtoReflect.Descriptor instead.
func (*DeleteKeygroupRequest) GetKeygroup ¶ added in v0.2.1
func (x *DeleteKeygroupRequest) GetKeygroup() string
func (*DeleteKeygroupRequest) ProtoMessage ¶ added in v0.2.1
func (*DeleteKeygroupRequest) ProtoMessage()
func (*DeleteKeygroupRequest) ProtoReflect ¶ added in v0.2.1
func (x *DeleteKeygroupRequest) ProtoReflect() protoreflect.Message
func (*DeleteKeygroupRequest) Reset ¶ added in v0.2.1
func (x *DeleteKeygroupRequest) Reset()
func (*DeleteKeygroupRequest) String ¶ added in v0.2.1
func (x *DeleteKeygroupRequest) String() string
type DeleteKeygroupResponse ¶ added in v0.2.1
type DeleteKeygroupResponse struct {
// contains filtered or unexported fields
}
func (*DeleteKeygroupResponse) Descriptor
deprecated
added in
v0.2.1
func (*DeleteKeygroupResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteKeygroupResponse.ProtoReflect.Descriptor instead.
func (*DeleteKeygroupResponse) ProtoMessage ¶ added in v0.2.1
func (*DeleteKeygroupResponse) ProtoMessage()
func (*DeleteKeygroupResponse) ProtoReflect ¶ added in v0.2.1
func (x *DeleteKeygroupResponse) ProtoReflect() protoreflect.Message
func (*DeleteKeygroupResponse) Reset ¶ added in v0.2.1
func (x *DeleteKeygroupResponse) Reset()
func (*DeleteKeygroupResponse) String ¶ added in v0.2.1
func (x *DeleteKeygroupResponse) String() string
type DeleteKeygroupTriggerRequest ¶ added in v0.2.1
type DeleteKeygroupTriggerRequest 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"` // contains filtered or unexported fields }
func (*DeleteKeygroupTriggerRequest) Descriptor
deprecated
added in
v0.2.1
func (*DeleteKeygroupTriggerRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteKeygroupTriggerRequest.ProtoReflect.Descriptor instead.
func (*DeleteKeygroupTriggerRequest) GetId ¶ added in v0.2.1
func (x *DeleteKeygroupTriggerRequest) GetId() string
func (*DeleteKeygroupTriggerRequest) GetKeygroup ¶ added in v0.2.1
func (x *DeleteKeygroupTriggerRequest) GetKeygroup() string
func (*DeleteKeygroupTriggerRequest) ProtoMessage ¶ added in v0.2.1
func (*DeleteKeygroupTriggerRequest) ProtoMessage()
func (*DeleteKeygroupTriggerRequest) ProtoReflect ¶ added in v0.2.1
func (x *DeleteKeygroupTriggerRequest) ProtoReflect() protoreflect.Message
func (*DeleteKeygroupTriggerRequest) Reset ¶ added in v0.2.1
func (x *DeleteKeygroupTriggerRequest) Reset()
func (*DeleteKeygroupTriggerRequest) String ¶ added in v0.2.1
func (x *DeleteKeygroupTriggerRequest) String() string
type DeleteKeygroupTriggerResponse ¶ added in v0.2.1
type DeleteKeygroupTriggerResponse struct {
// contains filtered or unexported fields
}
func (*DeleteKeygroupTriggerResponse) Descriptor
deprecated
added in
v0.2.1
func (*DeleteKeygroupTriggerResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteKeygroupTriggerResponse.ProtoReflect.Descriptor instead.
func (*DeleteKeygroupTriggerResponse) ProtoMessage ¶ added in v0.2.1
func (*DeleteKeygroupTriggerResponse) ProtoMessage()
func (*DeleteKeygroupTriggerResponse) ProtoReflect ¶ added in v0.2.1
func (x *DeleteKeygroupTriggerResponse) ProtoReflect() protoreflect.Message
func (*DeleteKeygroupTriggerResponse) Reset ¶ added in v0.2.1
func (x *DeleteKeygroupTriggerResponse) Reset()
func (*DeleteKeygroupTriggerResponse) String ¶ added in v0.2.1
func (x *DeleteKeygroupTriggerResponse) String() string
type DeleteRequest ¶ added in v0.2.1
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"` Version map[string]uint64 `` /* 156-byte string literal not displayed */ // contains filtered or unexported fields }
func (*DeleteRequest) Descriptor
deprecated
added in
v0.2.1
func (*DeleteRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.
func (*DeleteRequest) GetId ¶ added in v0.2.1
func (x *DeleteRequest) GetId() string
func (*DeleteRequest) GetKeygroup ¶ added in v0.2.1
func (x *DeleteRequest) GetKeygroup() string
func (*DeleteRequest) GetVersion ¶ added in v0.2.1
func (x *DeleteRequest) GetVersion() map[string]uint64
func (*DeleteRequest) ProtoMessage ¶ added in v0.2.1
func (*DeleteRequest) ProtoMessage()
func (*DeleteRequest) ProtoReflect ¶ added in v0.2.1
func (x *DeleteRequest) ProtoReflect() protoreflect.Message
func (*DeleteRequest) Reset ¶ added in v0.2.1
func (x *DeleteRequest) Reset()
func (*DeleteRequest) String ¶ added in v0.2.1
func (x *DeleteRequest) String() string
type DeleteResponse ¶ added in v0.2.1
type DeleteResponse struct {
// 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) 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 ExistsKeygroupRequest ¶ added in v0.2.1
type ExistsKeygroupRequest struct { Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"` // contains filtered or unexported fields }
func (*ExistsKeygroupRequest) Descriptor
deprecated
added in
v0.2.1
func (*ExistsKeygroupRequest) Descriptor() ([]byte, []int)
Deprecated: Use ExistsKeygroupRequest.ProtoReflect.Descriptor instead.
func (*ExistsKeygroupRequest) GetKeygroup ¶ added in v0.2.1
func (x *ExistsKeygroupRequest) GetKeygroup() string
func (*ExistsKeygroupRequest) ProtoMessage ¶ added in v0.2.1
func (*ExistsKeygroupRequest) ProtoMessage()
func (*ExistsKeygroupRequest) ProtoReflect ¶ added in v0.2.1
func (x *ExistsKeygroupRequest) ProtoReflect() protoreflect.Message
func (*ExistsKeygroupRequest) Reset ¶ added in v0.2.1
func (x *ExistsKeygroupRequest) Reset()
func (*ExistsKeygroupRequest) String ¶ added in v0.2.1
func (x *ExistsKeygroupRequest) String() string
type ExistsKeygroupResponse ¶ added in v0.2.1
type ExistsKeygroupResponse struct { Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"` // contains filtered or unexported fields }
func (*ExistsKeygroupResponse) Descriptor
deprecated
added in
v0.2.1
func (*ExistsKeygroupResponse) Descriptor() ([]byte, []int)
Deprecated: Use ExistsKeygroupResponse.ProtoReflect.Descriptor instead.
func (*ExistsKeygroupResponse) GetExists ¶ added in v0.2.1
func (x *ExistsKeygroupResponse) GetExists() bool
func (*ExistsKeygroupResponse) ProtoMessage ¶ added in v0.2.1
func (*ExistsKeygroupResponse) ProtoMessage()
func (*ExistsKeygroupResponse) ProtoReflect ¶ added in v0.2.1
func (x *ExistsKeygroupResponse) ProtoReflect() protoreflect.Message
func (*ExistsKeygroupResponse) Reset ¶ added in v0.2.1
func (x *ExistsKeygroupResponse) Reset()
func (*ExistsKeygroupResponse) String ¶ added in v0.2.1
func (x *ExistsKeygroupResponse) String() string
type ExistsRequest ¶ added in v0.2.1
type ExistsRequest 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"` // contains filtered or unexported fields }
func (*ExistsRequest) Descriptor
deprecated
added in
v0.2.1
func (*ExistsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ExistsRequest.ProtoReflect.Descriptor instead.
func (*ExistsRequest) GetId ¶ added in v0.2.1
func (x *ExistsRequest) GetId() string
func (*ExistsRequest) GetKeygroup ¶ added in v0.2.1
func (x *ExistsRequest) GetKeygroup() string
func (*ExistsRequest) ProtoMessage ¶ added in v0.2.1
func (*ExistsRequest) ProtoMessage()
func (*ExistsRequest) ProtoReflect ¶ added in v0.2.1
func (x *ExistsRequest) ProtoReflect() protoreflect.Message
func (*ExistsRequest) Reset ¶ added in v0.2.1
func (x *ExistsRequest) Reset()
func (*ExistsRequest) String ¶ added in v0.2.1
func (x *ExistsRequest) String() string
type ExistsResponse ¶ added in v0.2.1
type ExistsResponse struct { Exists bool `protobuf:"varint,1,opt,name=exists,proto3" json:"exists,omitempty"` // contains filtered or unexported fields }
func (*ExistsResponse) Descriptor
deprecated
added in
v0.2.1
func (*ExistsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ExistsResponse.ProtoReflect.Descriptor instead.
func (*ExistsResponse) GetExists ¶ added in v0.2.1
func (x *ExistsResponse) GetExists() bool
func (*ExistsResponse) ProtoMessage ¶ added in v0.2.1
func (*ExistsResponse) ProtoMessage()
func (*ExistsResponse) ProtoReflect ¶ added in v0.2.1
func (x *ExistsResponse) ProtoReflect() protoreflect.Message
func (*ExistsResponse) Reset ¶ added in v0.2.1
func (x *ExistsResponse) Reset()
func (*ExistsResponse) String ¶ added in v0.2.1
func (x *ExistsResponse) String() string
type GetKeygroupTriggerRequest ¶ added in v0.2.1
type GetKeygroupTriggerRequest struct { Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"` // contains filtered or unexported fields }
func (*GetKeygroupTriggerRequest) Descriptor
deprecated
added in
v0.2.1
func (*GetKeygroupTriggerRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetKeygroupTriggerRequest.ProtoReflect.Descriptor instead.
func (*GetKeygroupTriggerRequest) GetKeygroup ¶ added in v0.2.1
func (x *GetKeygroupTriggerRequest) GetKeygroup() string
func (*GetKeygroupTriggerRequest) ProtoMessage ¶ added in v0.2.1
func (*GetKeygroupTriggerRequest) ProtoMessage()
func (*GetKeygroupTriggerRequest) ProtoReflect ¶ added in v0.2.1
func (x *GetKeygroupTriggerRequest) ProtoReflect() protoreflect.Message
func (*GetKeygroupTriggerRequest) Reset ¶ added in v0.2.1
func (x *GetKeygroupTriggerRequest) Reset()
func (*GetKeygroupTriggerRequest) String ¶ added in v0.2.1
func (x *GetKeygroupTriggerRequest) String() string
type GetKeygroupTriggerResponse ¶ added in v0.2.1
type GetKeygroupTriggerResponse struct { Triggers []*Trigger `protobuf:"bytes,1,rep,name=triggers,proto3" json:"triggers,omitempty"` // contains filtered or unexported fields }
func (*GetKeygroupTriggerResponse) Descriptor
deprecated
added in
v0.2.1
func (*GetKeygroupTriggerResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetKeygroupTriggerResponse.ProtoReflect.Descriptor instead.
func (*GetKeygroupTriggerResponse) GetTriggers ¶ added in v0.2.1
func (x *GetKeygroupTriggerResponse) GetTriggers() []*Trigger
func (*GetKeygroupTriggerResponse) ProtoMessage ¶ added in v0.2.1
func (*GetKeygroupTriggerResponse) ProtoMessage()
func (*GetKeygroupTriggerResponse) ProtoReflect ¶ added in v0.2.1
func (x *GetKeygroupTriggerResponse) ProtoReflect() protoreflect.Message
func (*GetKeygroupTriggerResponse) Reset ¶ added in v0.2.1
func (x *GetKeygroupTriggerResponse) Reset()
func (*GetKeygroupTriggerResponse) String ¶ added in v0.2.1
func (x *GetKeygroupTriggerResponse) String() string
type IDsRequest ¶ added in v0.2.1
type IDsRequest struct { Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"` // contains filtered or unexported fields }
func (*IDsRequest) Descriptor
deprecated
added in
v0.2.1
func (*IDsRequest) Descriptor() ([]byte, []int)
Deprecated: Use IDsRequest.ProtoReflect.Descriptor instead.
func (*IDsRequest) GetKeygroup ¶ added in v0.2.1
func (x *IDsRequest) GetKeygroup() string
func (*IDsRequest) ProtoMessage ¶ added in v0.2.1
func (*IDsRequest) ProtoMessage()
func (*IDsRequest) ProtoReflect ¶ added in v0.2.1
func (x *IDsRequest) ProtoReflect() protoreflect.Message
func (*IDsRequest) Reset ¶ added in v0.2.1
func (x *IDsRequest) Reset()
func (*IDsRequest) String ¶ added in v0.2.1
func (x *IDsRequest) String() string
type IDsResponse ¶ added in v0.2.1
type IDsResponse struct { Ids []string `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"` // contains filtered or unexported fields }
func (*IDsResponse) Descriptor
deprecated
added in
v0.2.1
func (*IDsResponse) Descriptor() ([]byte, []int)
Deprecated: Use IDsResponse.ProtoReflect.Descriptor instead.
func (*IDsResponse) GetIds ¶ added in v0.2.1
func (x *IDsResponse) GetIds() []string
func (*IDsResponse) ProtoMessage ¶ added in v0.2.1
func (*IDsResponse) ProtoMessage()
func (*IDsResponse) ProtoReflect ¶ added in v0.2.1
func (x *IDsResponse) ProtoReflect() protoreflect.Message
func (*IDsResponse) Reset ¶ added in v0.2.1
func (x *IDsResponse) Reset()
func (*IDsResponse) String ¶ added in v0.2.1
func (x *IDsResponse) String() string
type Item ¶
type Item 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"` Val string `protobuf:"bytes,3,opt,name=val,proto3" json:"val,omitempty"` Version map[string]uint64 `` /* 156-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Item) Descriptor
deprecated
func (*Item) GetKeygroup ¶
func (*Item) GetVersion ¶ added in v0.2.1
func (*Item) ProtoMessage ¶
func (*Item) ProtoMessage()
func (*Item) ProtoReflect ¶
func (x *Item) ProtoReflect() protoreflect.Message
type ReadAllRequest ¶ added in v0.2.1
type ReadAllRequest struct { Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"` // contains filtered or unexported fields }
func (*ReadAllRequest) Descriptor
deprecated
added in
v0.2.1
func (*ReadAllRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadAllRequest.ProtoReflect.Descriptor instead.
func (*ReadAllRequest) GetKeygroup ¶ added in v0.2.1
func (x *ReadAllRequest) GetKeygroup() string
func (*ReadAllRequest) ProtoMessage ¶ added in v0.2.1
func (*ReadAllRequest) ProtoMessage()
func (*ReadAllRequest) ProtoReflect ¶ added in v0.2.1
func (x *ReadAllRequest) ProtoReflect() protoreflect.Message
func (*ReadAllRequest) Reset ¶ added in v0.2.1
func (x *ReadAllRequest) Reset()
func (*ReadAllRequest) String ¶ added in v0.2.1
func (x *ReadAllRequest) String() string
type ReadAllResponse ¶ added in v0.2.1
type ReadAllResponse struct { Items []*Item `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"` // contains filtered or unexported fields }
func (*ReadAllResponse) Descriptor
deprecated
added in
v0.2.1
func (*ReadAllResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReadAllResponse.ProtoReflect.Descriptor instead.
func (*ReadAllResponse) GetItems ¶ added in v0.2.1
func (x *ReadAllResponse) GetItems() []*Item
func (*ReadAllResponse) ProtoMessage ¶ added in v0.2.1
func (*ReadAllResponse) ProtoMessage()
func (*ReadAllResponse) ProtoReflect ¶ added in v0.2.1
func (x *ReadAllResponse) ProtoReflect() protoreflect.Message
func (*ReadAllResponse) Reset ¶ added in v0.2.1
func (x *ReadAllResponse) Reset()
func (*ReadAllResponse) String ¶ added in v0.2.1
func (x *ReadAllResponse) String() string
type ReadRequest ¶ added in v0.2.1
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"` // contains filtered or unexported fields }
func (*ReadRequest) Descriptor
deprecated
added in
v0.2.1
func (*ReadRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadRequest.ProtoReflect.Descriptor instead.
func (*ReadRequest) GetId ¶ added in v0.2.1
func (x *ReadRequest) GetId() string
func (*ReadRequest) GetKeygroup ¶ added in v0.2.1
func (x *ReadRequest) GetKeygroup() string
func (*ReadRequest) ProtoMessage ¶ added in v0.2.1
func (*ReadRequest) ProtoMessage()
func (*ReadRequest) ProtoReflect ¶ added in v0.2.1
func (x *ReadRequest) ProtoReflect() protoreflect.Message
func (*ReadRequest) Reset ¶ added in v0.2.1
func (x *ReadRequest) Reset()
func (*ReadRequest) String ¶ added in v0.2.1
func (x *ReadRequest) String() string
type ReadResponse ¶ added in v0.2.1
type ReadResponse struct { Items []*Item `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"` // contains filtered or unexported fields }
func (*ReadResponse) Descriptor
deprecated
added in
v0.2.1
func (*ReadResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReadResponse.ProtoReflect.Descriptor instead.
func (*ReadResponse) GetItems ¶ added in v0.2.1
func (x *ReadResponse) GetItems() []*Item
func (*ReadResponse) ProtoMessage ¶ added in v0.2.1
func (*ReadResponse) ProtoMessage()
func (*ReadResponse) ProtoReflect ¶ added in v0.2.1
func (x *ReadResponse) ProtoReflect() protoreflect.Message
func (*ReadResponse) Reset ¶ added in v0.2.1
func (x *ReadResponse) Reset()
func (*ReadResponse) String ¶ added in v0.2.1
func (x *ReadResponse) String() string
type ScanRequest ¶
type ScanRequest struct { Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"` Start string `protobuf:"bytes,2,opt,name=start,proto3" json:"start,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) GetKeygroup ¶ added in v0.2.1
func (x *ScanRequest) GetKeygroup() string
func (*ScanRequest) GetStart ¶ added in v0.2.1
func (x *ScanRequest) GetStart() 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 ¶ added in v0.2.1
type ScanResponse struct { Items []*Item `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"` // contains filtered or unexported fields }
func (*ScanResponse) Descriptor
deprecated
added in
v0.2.1
func (*ScanResponse) Descriptor() ([]byte, []int)
Deprecated: Use ScanResponse.ProtoReflect.Descriptor instead.
func (*ScanResponse) GetItems ¶ added in v0.2.1
func (x *ScanResponse) GetItems() []*Item
func (*ScanResponse) ProtoMessage ¶ added in v0.2.1
func (*ScanResponse) ProtoMessage()
func (*ScanResponse) ProtoReflect ¶ added in v0.2.1
func (x *ScanResponse) ProtoReflect() protoreflect.Message
func (*ScanResponse) Reset ¶ added in v0.2.1
func (x *ScanResponse) Reset()
func (*ScanResponse) String ¶ added in v0.2.1
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 UnimplementedDatabaseServer ¶
type UnimplementedDatabaseServer struct { }
UnimplementedDatabaseServer should be embedded to have forward compatible implementations.
func (UnimplementedDatabaseServer) AddKeygroupTrigger ¶
func (UnimplementedDatabaseServer) AddKeygroupTrigger(context.Context, *AddKeygroupTriggerRequest) (*AddKeygroupTriggerResponse, error)
func (UnimplementedDatabaseServer) Append ¶
func (UnimplementedDatabaseServer) Append(context.Context, *AppendRequest) (*AppendResponse, error)
func (UnimplementedDatabaseServer) CreateKeygroup ¶
func (UnimplementedDatabaseServer) CreateKeygroup(context.Context, *CreateKeygroupRequest) (*CreateKeygroupResponse, error)
func (UnimplementedDatabaseServer) Delete ¶
func (UnimplementedDatabaseServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
func (UnimplementedDatabaseServer) DeleteKeygroup ¶
func (UnimplementedDatabaseServer) DeleteKeygroup(context.Context, *DeleteKeygroupRequest) (*DeleteKeygroupResponse, error)
func (UnimplementedDatabaseServer) DeleteKeygroupTrigger ¶
func (UnimplementedDatabaseServer) DeleteKeygroupTrigger(context.Context, *DeleteKeygroupTriggerRequest) (*DeleteKeygroupTriggerResponse, error)
func (UnimplementedDatabaseServer) Exists ¶
func (UnimplementedDatabaseServer) Exists(context.Context, *ExistsRequest) (*ExistsResponse, error)
func (UnimplementedDatabaseServer) ExistsKeygroup ¶
func (UnimplementedDatabaseServer) ExistsKeygroup(context.Context, *ExistsKeygroupRequest) (*ExistsKeygroupResponse, error)
func (UnimplementedDatabaseServer) GetKeygroupTrigger ¶
func (UnimplementedDatabaseServer) GetKeygroupTrigger(context.Context, *GetKeygroupTriggerRequest) (*GetKeygroupTriggerResponse, error)
func (UnimplementedDatabaseServer) IDs ¶
func (UnimplementedDatabaseServer) IDs(context.Context, *IDsRequest) (*IDsResponse, error)
func (UnimplementedDatabaseServer) Read ¶
func (UnimplementedDatabaseServer) Read(context.Context, *ReadRequest) (*ReadResponse, error)
func (UnimplementedDatabaseServer) ReadAll ¶
func (UnimplementedDatabaseServer) ReadAll(context.Context, *ReadAllRequest) (*ReadAllResponse, error)
func (UnimplementedDatabaseServer) Scan ¶
func (UnimplementedDatabaseServer) Scan(context.Context, *ScanRequest) (*ScanResponse, error)
func (UnimplementedDatabaseServer) Update ¶
func (UnimplementedDatabaseServer) Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
type UnsafeDatabaseServer ¶
type UnsafeDatabaseServer interface {
// contains filtered or unexported methods
}
UnsafeDatabaseServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DatabaseServer will result in compilation errors.
type UpdateRequest ¶ added in v0.2.1
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"` Val string `protobuf:"bytes,3,opt,name=val,proto3" json:"val,omitempty"` Expiry int64 `protobuf:"varint,5,opt,name=expiry,proto3" json:"expiry,omitempty"` Version map[string]uint64 `` /* 156-byte string literal not displayed */ // contains filtered or unexported fields }
func (*UpdateRequest) Descriptor
deprecated
added in
v0.2.1
func (*UpdateRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateRequest.ProtoReflect.Descriptor instead.
func (*UpdateRequest) GetExpiry ¶ added in v0.2.1
func (x *UpdateRequest) GetExpiry() int64
func (*UpdateRequest) GetId ¶ added in v0.2.1
func (x *UpdateRequest) GetId() string
func (*UpdateRequest) GetKeygroup ¶ added in v0.2.1
func (x *UpdateRequest) GetKeygroup() string
func (*UpdateRequest) GetVal ¶ added in v0.2.1
func (x *UpdateRequest) GetVal() string
func (*UpdateRequest) GetVersion ¶ added in v0.2.1
func (x *UpdateRequest) GetVersion() map[string]uint64
func (*UpdateRequest) ProtoMessage ¶ added in v0.2.1
func (*UpdateRequest) ProtoMessage()
func (*UpdateRequest) ProtoReflect ¶ added in v0.2.1
func (x *UpdateRequest) ProtoReflect() protoreflect.Message
func (*UpdateRequest) Reset ¶ added in v0.2.1
func (x *UpdateRequest) Reset()
func (*UpdateRequest) String ¶ added in v0.2.1
func (x *UpdateRequest) String() string
type UpdateResponse ¶ added in v0.2.1
type UpdateResponse struct {
// 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) 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