Documentation ¶
Index ¶
- Variables
- func RegisterContextServer(s grpc.ServiceRegistrar, srv ContextServer)
- type ClearRequest
- type ClearResponse
- func (*ClearResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ClearResponse) GetError() string
- func (x *ClearResponse) GetIndex() uint64
- func (*ClearResponse) ProtoMessage()
- func (x *ClearResponse) ProtoReflect() protoreflect.Message
- func (x *ClearResponse) Reset()
- func (x *ClearResponse) String() string
- type ContextClient
- type ContextServer
- type GetRequest
- type GetResponse
- func (*GetResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetResponse) GetError() string
- func (x *GetResponse) GetIndex() uint64
- func (x *GetResponse) GetKey() string
- func (x *GetResponse) GetValue() []byte
- func (*GetResponse) ProtoMessage()
- func (x *GetResponse) ProtoReflect() protoreflect.Message
- func (x *GetResponse) Reset()
- func (x *GetResponse) String() string
- type ListRequest
- type ListResponse
- func (*ListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListResponse) GetError() string
- func (x *ListResponse) GetIndex() uint64
- func (x *ListResponse) GetKeys() []string
- func (*ListResponse) ProtoMessage()
- func (x *ListResponse) ProtoReflect() protoreflect.Message
- func (x *ListResponse) Reset()
- func (x *ListResponse) String() string
- type RemoveRequest
- type RemoveResponse
- func (*RemoveResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveResponse) GetError() string
- func (x *RemoveResponse) GetIndex() uint64
- func (x *RemoveResponse) GetKey() string
- func (x *RemoveResponse) GetValue() []byte
- func (*RemoveResponse) ProtoMessage()
- func (x *RemoveResponse) ProtoReflect() protoreflect.Message
- func (x *RemoveResponse) Reset()
- func (x *RemoveResponse) String() string
- type SetRequest
- type SetResponse
- type UnimplementedContextServer
- func (UnimplementedContextServer) Clear(context.Context, *ClearRequest) (*ClearResponse, error)
- func (UnimplementedContextServer) Get(context.Context, *GetRequest) (*GetResponse, error)
- func (UnimplementedContextServer) List(context.Context, *ListRequest) (*ListResponse, error)
- func (UnimplementedContextServer) Remove(context.Context, *RemoveRequest) (*RemoveResponse, error)
- func (UnimplementedContextServer) Set(context.Context, *SetRequest) (*SetResponse, error)
- type UnsafeContextServer
Constants ¶
This section is empty.
Variables ¶
var Context_ServiceDesc = grpc.ServiceDesc{ ServiceName: "rafter.Context", HandlerType: (*ContextServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Set", Handler: _Context_Set_Handler, }, { MethodName: "Get", Handler: _Context_Get_Handler, }, { MethodName: "Remove", Handler: _Context_Remove_Handler, }, { MethodName: "List", Handler: _Context_List_Handler, }, { MethodName: "Clear", Handler: _Context_Clear_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "application/proto/service.proto", }
Context_ServiceDesc is the grpc.ServiceDesc for Context service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_application_proto_service_proto protoreflect.FileDescriptor
Functions ¶
func RegisterContextServer ¶
func RegisterContextServer(s grpc.ServiceRegistrar, srv ContextServer)
Types ¶
type ClearRequest ¶
type ClearRequest struct { Filter string `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"` // contains filtered or unexported fields }
func (*ClearRequest) Descriptor
deprecated
func (*ClearRequest) Descriptor() ([]byte, []int)
Deprecated: Use ClearRequest.ProtoReflect.Descriptor instead.
func (*ClearRequest) GetFilter ¶
func (x *ClearRequest) GetFilter() string
func (*ClearRequest) ProtoMessage ¶
func (*ClearRequest) ProtoMessage()
func (*ClearRequest) ProtoReflect ¶
func (x *ClearRequest) ProtoReflect() protoreflect.Message
func (*ClearRequest) Reset ¶
func (x *ClearRequest) Reset()
func (*ClearRequest) String ¶
func (x *ClearRequest) String() string
type ClearResponse ¶
type ClearResponse struct { Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"` Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*ClearResponse) Descriptor
deprecated
func (*ClearResponse) Descriptor() ([]byte, []int)
Deprecated: Use ClearResponse.ProtoReflect.Descriptor instead.
func (*ClearResponse) GetError ¶
func (x *ClearResponse) GetError() string
func (*ClearResponse) GetIndex ¶
func (x *ClearResponse) GetIndex() uint64
func (*ClearResponse) ProtoMessage ¶
func (*ClearResponse) ProtoMessage()
func (*ClearResponse) ProtoReflect ¶
func (x *ClearResponse) ProtoReflect() protoreflect.Message
func (*ClearResponse) Reset ¶
func (x *ClearResponse) Reset()
func (*ClearResponse) String ¶
func (x *ClearResponse) String() string
type ContextClient ¶
type ContextClient interface { Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*SetResponse, error) Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*RemoveResponse, error) List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error) Clear(ctx context.Context, in *ClearRequest, opts ...grpc.CallOption) (*ClearResponse, error) }
ContextClient is the client API for Context 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 NewContextClient ¶
func NewContextClient(cc grpc.ClientConnInterface) ContextClient
type ContextServer ¶
type ContextServer interface { Set(context.Context, *SetRequest) (*SetResponse, error) Get(context.Context, *GetRequest) (*GetResponse, error) Remove(context.Context, *RemoveRequest) (*RemoveResponse, error) List(context.Context, *ListRequest) (*ListResponse, error) Clear(context.Context, *ClearRequest) (*ClearResponse, error) // contains filtered or unexported methods }
ContextServer is the server API for Context service. All implementations must embed UnimplementedContextServer for forward compatibility
type GetRequest ¶
type GetRequest struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // contains filtered or unexported fields }
func (*GetRequest) Descriptor
deprecated
func (*GetRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.
func (*GetRequest) GetKey ¶
func (x *GetRequest) GetKey() string
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) ProtoReflect ¶
func (x *GetRequest) ProtoReflect() protoreflect.Message
func (*GetRequest) Reset ¶
func (x *GetRequest) Reset()
func (*GetRequest) String ¶
func (x *GetRequest) String() string
type GetResponse ¶
type GetResponse struct { Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"` Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*GetResponse) Descriptor
deprecated
func (*GetResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.
func (*GetResponse) GetError ¶
func (x *GetResponse) GetError() string
func (*GetResponse) GetIndex ¶
func (x *GetResponse) GetIndex() uint64
func (*GetResponse) GetKey ¶
func (x *GetResponse) GetKey() string
func (*GetResponse) GetValue ¶
func (x *GetResponse) GetValue() []byte
func (*GetResponse) ProtoMessage ¶
func (*GetResponse) ProtoMessage()
func (*GetResponse) ProtoReflect ¶
func (x *GetResponse) ProtoReflect() protoreflect.Message
func (*GetResponse) Reset ¶
func (x *GetResponse) Reset()
func (*GetResponse) String ¶
func (x *GetResponse) String() string
type ListRequest ¶
type ListRequest struct { Filter string `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"` // contains filtered or unexported fields }
func (*ListRequest) Descriptor
deprecated
func (*ListRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.
func (*ListRequest) GetFilter ¶
func (x *ListRequest) GetFilter() string
func (*ListRequest) ProtoMessage ¶
func (*ListRequest) ProtoMessage()
func (*ListRequest) ProtoReflect ¶
func (x *ListRequest) ProtoReflect() protoreflect.Message
func (*ListRequest) Reset ¶
func (x *ListRequest) Reset()
func (*ListRequest) String ¶
func (x *ListRequest) String() string
type ListResponse ¶
type ListResponse struct { Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"` Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` Keys []string `protobuf:"bytes,3,rep,name=keys,proto3" json:"keys,omitempty"` // contains filtered or unexported fields }
func (*ListResponse) Descriptor
deprecated
func (*ListResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.
func (*ListResponse) GetError ¶
func (x *ListResponse) GetError() string
func (*ListResponse) GetIndex ¶
func (x *ListResponse) GetIndex() uint64
func (*ListResponse) GetKeys ¶
func (x *ListResponse) GetKeys() []string
func (*ListResponse) ProtoMessage ¶
func (*ListResponse) ProtoMessage()
func (*ListResponse) ProtoReflect ¶
func (x *ListResponse) ProtoReflect() protoreflect.Message
func (*ListResponse) Reset ¶
func (x *ListResponse) Reset()
func (*ListResponse) String ¶
func (x *ListResponse) String() string
type RemoveRequest ¶
type RemoveRequest struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // contains filtered or unexported fields }
func (*RemoveRequest) Descriptor
deprecated
func (*RemoveRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemoveRequest.ProtoReflect.Descriptor instead.
func (*RemoveRequest) GetKey ¶
func (x *RemoveRequest) GetKey() string
func (*RemoveRequest) ProtoMessage ¶
func (*RemoveRequest) ProtoMessage()
func (*RemoveRequest) ProtoReflect ¶
func (x *RemoveRequest) ProtoReflect() protoreflect.Message
func (*RemoveRequest) Reset ¶
func (x *RemoveRequest) Reset()
func (*RemoveRequest) String ¶
func (x *RemoveRequest) String() string
type RemoveResponse ¶
type RemoveResponse struct { Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"` Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` Error string `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*RemoveResponse) Descriptor
deprecated
func (*RemoveResponse) Descriptor() ([]byte, []int)
Deprecated: Use RemoveResponse.ProtoReflect.Descriptor instead.
func (*RemoveResponse) GetError ¶
func (x *RemoveResponse) GetError() string
func (*RemoveResponse) GetIndex ¶
func (x *RemoveResponse) GetIndex() uint64
func (*RemoveResponse) GetKey ¶
func (x *RemoveResponse) GetKey() string
func (*RemoveResponse) GetValue ¶
func (x *RemoveResponse) GetValue() []byte
func (*RemoveResponse) ProtoMessage ¶
func (*RemoveResponse) ProtoMessage()
func (*RemoveResponse) ProtoReflect ¶
func (x *RemoveResponse) ProtoReflect() protoreflect.Message
func (*RemoveResponse) Reset ¶
func (x *RemoveResponse) Reset()
func (*RemoveResponse) String ¶
func (x *RemoveResponse) String() string
type SetRequest ¶
type SetRequest struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*SetRequest) Descriptor
deprecated
func (*SetRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetRequest.ProtoReflect.Descriptor instead.
func (*SetRequest) GetKey ¶
func (x *SetRequest) GetKey() string
func (*SetRequest) GetValue ¶
func (x *SetRequest) GetValue() []byte
func (*SetRequest) ProtoMessage ¶
func (*SetRequest) ProtoMessage()
func (*SetRequest) ProtoReflect ¶
func (x *SetRequest) ProtoReflect() protoreflect.Message
func (*SetRequest) Reset ¶
func (x *SetRequest) Reset()
func (*SetRequest) String ¶
func (x *SetRequest) String() string
type SetResponse ¶
type SetResponse struct { Index uint64 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"` Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*SetResponse) Descriptor
deprecated
func (*SetResponse) Descriptor() ([]byte, []int)
Deprecated: Use SetResponse.ProtoReflect.Descriptor instead.
func (*SetResponse) GetError ¶
func (x *SetResponse) GetError() string
func (*SetResponse) GetIndex ¶
func (x *SetResponse) GetIndex() uint64
func (*SetResponse) ProtoMessage ¶
func (*SetResponse) ProtoMessage()
func (*SetResponse) ProtoReflect ¶
func (x *SetResponse) ProtoReflect() protoreflect.Message
func (*SetResponse) Reset ¶
func (x *SetResponse) Reset()
func (*SetResponse) String ¶
func (x *SetResponse) String() string
type UnimplementedContextServer ¶
type UnimplementedContextServer struct { }
UnimplementedContextServer must be embedded to have forward compatible implementations.
func (UnimplementedContextServer) Clear ¶
func (UnimplementedContextServer) Clear(context.Context, *ClearRequest) (*ClearResponse, error)
func (UnimplementedContextServer) Get ¶
func (UnimplementedContextServer) Get(context.Context, *GetRequest) (*GetResponse, error)
func (UnimplementedContextServer) List ¶
func (UnimplementedContextServer) List(context.Context, *ListRequest) (*ListResponse, error)
func (UnimplementedContextServer) Remove ¶
func (UnimplementedContextServer) Remove(context.Context, *RemoveRequest) (*RemoveResponse, error)
func (UnimplementedContextServer) Set ¶
func (UnimplementedContextServer) Set(context.Context, *SetRequest) (*SetResponse, error)
type UnsafeContextServer ¶
type UnsafeContextServer interface {
// contains filtered or unexported methods
}
UnsafeContextServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ContextServer will result in compilation errors.