Versions in this module Expand all Collapse all v1 v1.0.2 Jun 10, 2023 Changes in this version + var File_lib_proto_master_proto protoreflect.FileDescriptor + var File_lib_proto_slave_proto protoreflect.FileDescriptor + var MasterGrpcService_ServiceDesc = grpc.ServiceDesc + var SlaveGrpcService_ServiceDesc = grpc.ServiceDesc + func RegisterMasterGrpcServiceServer(s grpc.ServiceRegistrar, srv MasterGrpcServiceServer) + func RegisterSlaveGrpcServiceServer(s grpc.ServiceRegistrar, srv SlaveGrpcServiceServer) + type MasterDelRequest struct + Key string + func (*MasterDelRequest) Descriptor() ([]byte, []int) + func (*MasterDelRequest) ProtoMessage() + func (x *MasterDelRequest) GetKey() string + func (x *MasterDelRequest) ProtoReflect() protoreflect.Message + func (x *MasterDelRequest) Reset() + func (x *MasterDelRequest) String() string + type MasterDelResponse struct + Ok bool + func (*MasterDelResponse) Descriptor() ([]byte, []int) + func (*MasterDelResponse) ProtoMessage() + func (x *MasterDelResponse) GetOk() bool + func (x *MasterDelResponse) ProtoReflect() protoreflect.Message + func (x *MasterDelResponse) Reset() + func (x *MasterDelResponse) String() string + type MasterExpireRequest struct + Key string + Ttl int64 + func (*MasterExpireRequest) Descriptor() ([]byte, []int) + func (*MasterExpireRequest) ProtoMessage() + func (x *MasterExpireRequest) GetKey() string + func (x *MasterExpireRequest) GetTtl() int64 + func (x *MasterExpireRequest) ProtoReflect() protoreflect.Message + func (x *MasterExpireRequest) Reset() + func (x *MasterExpireRequest) String() string + type MasterExpireResponse struct + Ok bool + func (*MasterExpireResponse) Descriptor() ([]byte, []int) + func (*MasterExpireResponse) ProtoMessage() + func (x *MasterExpireResponse) GetOk() bool + func (x *MasterExpireResponse) ProtoReflect() protoreflect.Message + func (x *MasterExpireResponse) Reset() + func (x *MasterExpireResponse) String() string + type MasterGetRequest struct + Key string + func (*MasterGetRequest) Descriptor() ([]byte, []int) + func (*MasterGetRequest) ProtoMessage() + func (x *MasterGetRequest) GetKey() string + func (x *MasterGetRequest) ProtoReflect() protoreflect.Message + func (x *MasterGetRequest) Reset() + func (x *MasterGetRequest) String() string + type MasterGetResponse struct + Value string + func (*MasterGetResponse) Descriptor() ([]byte, []int) + func (*MasterGetResponse) ProtoMessage() + func (x *MasterGetResponse) GetValue() string + func (x *MasterGetResponse) ProtoReflect() protoreflect.Message + func (x *MasterGetResponse) Reset() + func (x *MasterGetResponse) String() string + type MasterGrpcServiceClient interface + Del func(ctx context.Context, in *MasterDelRequest, opts ...grpc.CallOption) (*MasterDelResponse, error) + Expire func(ctx context.Context, in *MasterExpireRequest, opts ...grpc.CallOption) (*MasterExpireResponse, error) + Get func(ctx context.Context, in *MasterGetRequest, opts ...grpc.CallOption) (*MasterGetResponse, error) + Keys func(ctx context.Context, in *MasterKeysRequest, opts ...grpc.CallOption) (*MasterKeysResponse, error) + Ping func(ctx context.Context, in *MasterPingRequest, opts ...grpc.CallOption) (*MasterPingResponse, error) + RegisterSlave func(ctx context.Context, in *MasterRegisterSlaveRequest, opts ...grpc.CallOption) (*MasterRegisterSlaveResponse, error) + Scan func(ctx context.Context, in *MasterScanRequest, opts ...grpc.CallOption) (*MasterScanResponse, error) + Set func(ctx context.Context, in *MasterSetRequest, opts ...grpc.CallOption) (*MasterSetResponse, error) + Shutdown func(ctx context.Context, in *MasterShutdownRequest, opts ...grpc.CallOption) (*MasterShutdownResponse, error) + TTL func(ctx context.Context, in *MasterTTLRequest, opts ...grpc.CallOption) (*MasterTTLResponse, error) + func NewMasterGrpcServiceClient(cc grpc.ClientConnInterface) MasterGrpcServiceClient + type MasterGrpcServiceServer interface + Del func(context.Context, *MasterDelRequest) (*MasterDelResponse, error) + Expire func(context.Context, *MasterExpireRequest) (*MasterExpireResponse, error) + Get func(context.Context, *MasterGetRequest) (*MasterGetResponse, error) + Keys func(context.Context, *MasterKeysRequest) (*MasterKeysResponse, error) + Ping func(context.Context, *MasterPingRequest) (*MasterPingResponse, error) + RegisterSlave func(context.Context, *MasterRegisterSlaveRequest) (*MasterRegisterSlaveResponse, error) + Scan func(context.Context, *MasterScanRequest) (*MasterScanResponse, error) + Set func(context.Context, *MasterSetRequest) (*MasterSetResponse, error) + Shutdown func(context.Context, *MasterShutdownRequest) (*MasterShutdownResponse, error) + TTL func(context.Context, *MasterTTLRequest) (*MasterTTLResponse, error) + type MasterKeysRequest struct + Pattern string + func (*MasterKeysRequest) Descriptor() ([]byte, []int) + func (*MasterKeysRequest) ProtoMessage() + func (x *MasterKeysRequest) GetPattern() string + func (x *MasterKeysRequest) ProtoReflect() protoreflect.Message + func (x *MasterKeysRequest) Reset() + func (x *MasterKeysRequest) String() string + type MasterKeysResponse struct + Keys []string + func (*MasterKeysResponse) Descriptor() ([]byte, []int) + func (*MasterKeysResponse) ProtoMessage() + func (x *MasterKeysResponse) GetKeys() []string + func (x *MasterKeysResponse) ProtoReflect() protoreflect.Message + func (x *MasterKeysResponse) Reset() + func (x *MasterKeysResponse) String() string + type MasterPingRequest struct + Message string + func (*MasterPingRequest) Descriptor() ([]byte, []int) + func (*MasterPingRequest) ProtoMessage() + func (x *MasterPingRequest) GetMessage() string + func (x *MasterPingRequest) ProtoReflect() protoreflect.Message + func (x *MasterPingRequest) Reset() + func (x *MasterPingRequest) String() string + type MasterPingResponse struct + Message string + func (*MasterPingResponse) Descriptor() ([]byte, []int) + func (*MasterPingResponse) ProtoMessage() + func (x *MasterPingResponse) GetMessage() string + func (x *MasterPingResponse) ProtoReflect() protoreflect.Message + func (x *MasterPingResponse) Reset() + func (x *MasterPingResponse) String() string + type MasterRegisterSlaveRequest struct + Addr string + func (*MasterRegisterSlaveRequest) Descriptor() ([]byte, []int) + func (*MasterRegisterSlaveRequest) ProtoMessage() + func (x *MasterRegisterSlaveRequest) GetAddr() string + func (x *MasterRegisterSlaveRequest) ProtoReflect() protoreflect.Message + func (x *MasterRegisterSlaveRequest) Reset() + func (x *MasterRegisterSlaveRequest) String() string + type MasterRegisterSlaveResponse struct + Ok bool + func (*MasterRegisterSlaveResponse) Descriptor() ([]byte, []int) + func (*MasterRegisterSlaveResponse) ProtoMessage() + func (x *MasterRegisterSlaveResponse) GetOk() bool + func (x *MasterRegisterSlaveResponse) ProtoReflect() protoreflect.Message + func (x *MasterRegisterSlaveResponse) Reset() + func (x *MasterRegisterSlaveResponse) String() string + type MasterScanRequest struct + Pattern string + func (*MasterScanRequest) Descriptor() ([]byte, []int) + func (*MasterScanRequest) ProtoMessage() + func (x *MasterScanRequest) GetPattern() string + func (x *MasterScanRequest) ProtoReflect() protoreflect.Message + func (x *MasterScanRequest) Reset() + func (x *MasterScanRequest) String() string + type MasterScanResponse struct + Keys []string + func (*MasterScanResponse) Descriptor() ([]byte, []int) + func (*MasterScanResponse) ProtoMessage() + func (x *MasterScanResponse) GetKeys() []string + func (x *MasterScanResponse) ProtoReflect() protoreflect.Message + func (x *MasterScanResponse) Reset() + func (x *MasterScanResponse) String() string + type MasterSetRequest struct + Key string + Value string + func (*MasterSetRequest) Descriptor() ([]byte, []int) + func (*MasterSetRequest) ProtoMessage() + func (x *MasterSetRequest) GetKey() string + func (x *MasterSetRequest) GetValue() string + func (x *MasterSetRequest) ProtoReflect() protoreflect.Message + func (x *MasterSetRequest) Reset() + func (x *MasterSetRequest) String() string + type MasterSetResponse struct + Ok bool + func (*MasterSetResponse) Descriptor() ([]byte, []int) + func (*MasterSetResponse) ProtoMessage() + func (x *MasterSetResponse) GetOk() bool + func (x *MasterSetResponse) ProtoReflect() protoreflect.Message + func (x *MasterSetResponse) Reset() + func (x *MasterSetResponse) String() string + type MasterShutdownRequest struct + Message string + func (*MasterShutdownRequest) Descriptor() ([]byte, []int) + func (*MasterShutdownRequest) ProtoMessage() + func (x *MasterShutdownRequest) GetMessage() string + func (x *MasterShutdownRequest) ProtoReflect() protoreflect.Message + func (x *MasterShutdownRequest) Reset() + func (x *MasterShutdownRequest) String() string + type MasterShutdownResponse struct + Message string + func (*MasterShutdownResponse) Descriptor() ([]byte, []int) + func (*MasterShutdownResponse) ProtoMessage() + func (x *MasterShutdownResponse) GetMessage() string + func (x *MasterShutdownResponse) ProtoReflect() protoreflect.Message + func (x *MasterShutdownResponse) Reset() + func (x *MasterShutdownResponse) String() string + type MasterTTLRequest struct + Key string + func (*MasterTTLRequest) Descriptor() ([]byte, []int) + func (*MasterTTLRequest) ProtoMessage() + func (x *MasterTTLRequest) GetKey() string + func (x *MasterTTLRequest) ProtoReflect() protoreflect.Message + func (x *MasterTTLRequest) Reset() + func (x *MasterTTLRequest) String() string + type MasterTTLResponse struct + Ttl int64 + func (*MasterTTLResponse) Descriptor() ([]byte, []int) + func (*MasterTTLResponse) ProtoMessage() + func (x *MasterTTLResponse) GetTtl() int64 + func (x *MasterTTLResponse) ProtoReflect() protoreflect.Message + func (x *MasterTTLResponse) Reset() + func (x *MasterTTLResponse) String() string + type SlaveDelRequest struct + Key string + func (*SlaveDelRequest) Descriptor() ([]byte, []int) + func (*SlaveDelRequest) ProtoMessage() + func (x *SlaveDelRequest) GetKey() string + func (x *SlaveDelRequest) ProtoReflect() protoreflect.Message + func (x *SlaveDelRequest) Reset() + func (x *SlaveDelRequest) String() string + type SlaveDelResponse struct + Ok bool + func (*SlaveDelResponse) Descriptor() ([]byte, []int) + func (*SlaveDelResponse) ProtoMessage() + func (x *SlaveDelResponse) GetOk() bool + func (x *SlaveDelResponse) ProtoReflect() protoreflect.Message + func (x *SlaveDelResponse) Reset() + func (x *SlaveDelResponse) String() string + type SlaveExistsRequest struct + Key string + func (*SlaveExistsRequest) Descriptor() ([]byte, []int) + func (*SlaveExistsRequest) ProtoMessage() + func (x *SlaveExistsRequest) GetKey() string + func (x *SlaveExistsRequest) ProtoReflect() protoreflect.Message + func (x *SlaveExistsRequest) Reset() + func (x *SlaveExistsRequest) String() string + type SlaveExistsResponse struct + Exists bool + func (*SlaveExistsResponse) Descriptor() ([]byte, []int) + func (*SlaveExistsResponse) ProtoMessage() + func (x *SlaveExistsResponse) GetExists() bool + func (x *SlaveExistsResponse) ProtoReflect() protoreflect.Message + func (x *SlaveExistsResponse) Reset() + func (x *SlaveExistsResponse) String() string + type SlaveExpireRequest struct + Key string + Ttl int64 + func (*SlaveExpireRequest) Descriptor() ([]byte, []int) + func (*SlaveExpireRequest) ProtoMessage() + func (x *SlaveExpireRequest) GetKey() string + func (x *SlaveExpireRequest) GetTtl() int64 + func (x *SlaveExpireRequest) ProtoReflect() protoreflect.Message + func (x *SlaveExpireRequest) Reset() + func (x *SlaveExpireRequest) String() string + type SlaveExpireResponse struct + Ok bool + func (*SlaveExpireResponse) Descriptor() ([]byte, []int) + func (*SlaveExpireResponse) ProtoMessage() + func (x *SlaveExpireResponse) GetOk() bool + func (x *SlaveExpireResponse) ProtoReflect() protoreflect.Message + func (x *SlaveExpireResponse) Reset() + func (x *SlaveExpireResponse) String() string + type SlaveGetRequest struct + Key string + func (*SlaveGetRequest) Descriptor() ([]byte, []int) + func (*SlaveGetRequest) ProtoMessage() + func (x *SlaveGetRequest) GetKey() string + func (x *SlaveGetRequest) ProtoReflect() protoreflect.Message + func (x *SlaveGetRequest) Reset() + func (x *SlaveGetRequest) String() string + type SlaveGetResponse struct + Value string + func (*SlaveGetResponse) Descriptor() ([]byte, []int) + func (*SlaveGetResponse) ProtoMessage() + func (x *SlaveGetResponse) GetValue() string + func (x *SlaveGetResponse) ProtoReflect() protoreflect.Message + func (x *SlaveGetResponse) Reset() + func (x *SlaveGetResponse) String() string + type SlaveGrpcServiceClient interface + Del func(ctx context.Context, in *SlaveDelRequest, opts ...grpc.CallOption) (*SlaveDelResponse, error) + Exists func(ctx context.Context, in *SlaveExistsRequest, opts ...grpc.CallOption) (*SlaveExistsResponse, error) + Expire func(ctx context.Context, in *SlaveExpireRequest, opts ...grpc.CallOption) (*SlaveExpireResponse, error) + Get func(ctx context.Context, in *SlaveGetRequest, opts ...grpc.CallOption) (*SlaveGetResponse, error) + Heartbeat func(ctx context.Context, in *SlaveHeartbeatRequest, opts ...grpc.CallOption) (*SlaveHeartbeatResponse, error) + Keys func(ctx context.Context, in *SlaveKeysRequest, opts ...grpc.CallOption) (*SlaveKeysResponse, error) + Set func(ctx context.Context, in *SlaveSetRequest, opts ...grpc.CallOption) (*SlaveSetResponse, error) + TTL func(ctx context.Context, in *SlaveTTLRequest, opts ...grpc.CallOption) (*SlaveTTLResponse, error) + func NewSlaveGrpcServiceClient(cc grpc.ClientConnInterface) SlaveGrpcServiceClient + type SlaveGrpcServiceServer interface + Del func(context.Context, *SlaveDelRequest) (*SlaveDelResponse, error) + Exists func(context.Context, *SlaveExistsRequest) (*SlaveExistsResponse, error) + Expire func(context.Context, *SlaveExpireRequest) (*SlaveExpireResponse, error) + Get func(context.Context, *SlaveGetRequest) (*SlaveGetResponse, error) + Heartbeat func(context.Context, *SlaveHeartbeatRequest) (*SlaveHeartbeatResponse, error) + Keys func(context.Context, *SlaveKeysRequest) (*SlaveKeysResponse, error) + Set func(context.Context, *SlaveSetRequest) (*SlaveSetResponse, error) + TTL func(context.Context, *SlaveTTLRequest) (*SlaveTTLResponse, error) + type SlaveHeartbeatRequest struct + Id string + func (*SlaveHeartbeatRequest) Descriptor() ([]byte, []int) + func (*SlaveHeartbeatRequest) ProtoMessage() + func (x *SlaveHeartbeatRequest) GetId() string + func (x *SlaveHeartbeatRequest) ProtoReflect() protoreflect.Message + func (x *SlaveHeartbeatRequest) Reset() + func (x *SlaveHeartbeatRequest) String() string + type SlaveHeartbeatResponse struct + Ok bool + func (*SlaveHeartbeatResponse) Descriptor() ([]byte, []int) + func (*SlaveHeartbeatResponse) ProtoMessage() + func (x *SlaveHeartbeatResponse) GetOk() bool + func (x *SlaveHeartbeatResponse) ProtoReflect() protoreflect.Message + func (x *SlaveHeartbeatResponse) Reset() + func (x *SlaveHeartbeatResponse) String() string + type SlaveKeysRequest struct + Pattern string + func (*SlaveKeysRequest) Descriptor() ([]byte, []int) + func (*SlaveKeysRequest) ProtoMessage() + func (x *SlaveKeysRequest) GetPattern() string + func (x *SlaveKeysRequest) ProtoReflect() protoreflect.Message + func (x *SlaveKeysRequest) Reset() + func (x *SlaveKeysRequest) String() string + type SlaveKeysResponse struct + Keys []string + func (*SlaveKeysResponse) Descriptor() ([]byte, []int) + func (*SlaveKeysResponse) ProtoMessage() + func (x *SlaveKeysResponse) GetKeys() []string + func (x *SlaveKeysResponse) ProtoReflect() protoreflect.Message + func (x *SlaveKeysResponse) Reset() + func (x *SlaveKeysResponse) String() string + type SlaveSetRequest struct + Key string + Value string + func (*SlaveSetRequest) Descriptor() ([]byte, []int) + func (*SlaveSetRequest) ProtoMessage() + func (x *SlaveSetRequest) GetKey() string + func (x *SlaveSetRequest) GetValue() string + func (x *SlaveSetRequest) ProtoReflect() protoreflect.Message + func (x *SlaveSetRequest) Reset() + func (x *SlaveSetRequest) String() string + type SlaveSetResponse struct + Ok bool + func (*SlaveSetResponse) Descriptor() ([]byte, []int) + func (*SlaveSetResponse) ProtoMessage() + func (x *SlaveSetResponse) GetOk() bool + func (x *SlaveSetResponse) ProtoReflect() protoreflect.Message + func (x *SlaveSetResponse) Reset() + func (x *SlaveSetResponse) String() string + type SlaveTTLRequest struct + Key string + func (*SlaveTTLRequest) Descriptor() ([]byte, []int) + func (*SlaveTTLRequest) ProtoMessage() + func (x *SlaveTTLRequest) GetKey() string + func (x *SlaveTTLRequest) ProtoReflect() protoreflect.Message + func (x *SlaveTTLRequest) Reset() + func (x *SlaveTTLRequest) String() string + type SlaveTTLResponse struct + Ttl int64 + func (*SlaveTTLResponse) Descriptor() ([]byte, []int) + func (*SlaveTTLResponse) ProtoMessage() + func (x *SlaveTTLResponse) GetTtl() int64 + func (x *SlaveTTLResponse) ProtoReflect() protoreflect.Message + func (x *SlaveTTLResponse) Reset() + func (x *SlaveTTLResponse) String() string + type UnimplementedMasterGrpcServiceServer struct + func (UnimplementedMasterGrpcServiceServer) Del(context.Context, *MasterDelRequest) (*MasterDelResponse, error) + func (UnimplementedMasterGrpcServiceServer) Expire(context.Context, *MasterExpireRequest) (*MasterExpireResponse, error) + func (UnimplementedMasterGrpcServiceServer) Get(context.Context, *MasterGetRequest) (*MasterGetResponse, error) + func (UnimplementedMasterGrpcServiceServer) Keys(context.Context, *MasterKeysRequest) (*MasterKeysResponse, error) + func (UnimplementedMasterGrpcServiceServer) Ping(context.Context, *MasterPingRequest) (*MasterPingResponse, error) + func (UnimplementedMasterGrpcServiceServer) RegisterSlave(context.Context, *MasterRegisterSlaveRequest) (*MasterRegisterSlaveResponse, error) + func (UnimplementedMasterGrpcServiceServer) Scan(context.Context, *MasterScanRequest) (*MasterScanResponse, error) + func (UnimplementedMasterGrpcServiceServer) Set(context.Context, *MasterSetRequest) (*MasterSetResponse, error) + func (UnimplementedMasterGrpcServiceServer) Shutdown(context.Context, *MasterShutdownRequest) (*MasterShutdownResponse, error) + func (UnimplementedMasterGrpcServiceServer) TTL(context.Context, *MasterTTLRequest) (*MasterTTLResponse, error) + type UnimplementedSlaveGrpcServiceServer struct + func (UnimplementedSlaveGrpcServiceServer) Del(context.Context, *SlaveDelRequest) (*SlaveDelResponse, error) + func (UnimplementedSlaveGrpcServiceServer) Exists(context.Context, *SlaveExistsRequest) (*SlaveExistsResponse, error) + func (UnimplementedSlaveGrpcServiceServer) Expire(context.Context, *SlaveExpireRequest) (*SlaveExpireResponse, error) + func (UnimplementedSlaveGrpcServiceServer) Get(context.Context, *SlaveGetRequest) (*SlaveGetResponse, error) + func (UnimplementedSlaveGrpcServiceServer) Heartbeat(context.Context, *SlaveHeartbeatRequest) (*SlaveHeartbeatResponse, error) + func (UnimplementedSlaveGrpcServiceServer) Keys(context.Context, *SlaveKeysRequest) (*SlaveKeysResponse, error) + func (UnimplementedSlaveGrpcServiceServer) Set(context.Context, *SlaveSetRequest) (*SlaveSetResponse, error) + func (UnimplementedSlaveGrpcServiceServer) TTL(context.Context, *SlaveTTLRequest) (*SlaveTTLResponse, error) + type UnsafeMasterGrpcServiceServer interface + type UnsafeSlaveGrpcServiceServer interface
Go to main page