Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterAllyServer(s grpc.ServiceRegistrar, srv AllyServer)
- func RegisterAtomicServer(s grpc.ServiceRegistrar, srv AtomicServer)
- func RegisterCacheServer(s grpc.ServiceRegistrar, srv CacheServer)
- func RegisterLockerServer(s grpc.ServiceRegistrar, srv LockerServer)
- type Address
- func (*Address) Descriptor() ([]byte, []int)deprecated
- func (x *Address) GetAddress() string
- func (x *Address) GetCreated() int64
- func (x *Address) GetNetwork() string
- func (x *Address) GetRefs() uint64
- func (x *Address) GetUpdated() int64
- func (*Address) ProtoMessage()
- func (x *Address) ProtoReflect() protoreflect.Message
- func (x *Address) Reset()
- func (x *Address) String() string
- type AllyClient
- type AllyServer
- type AppInfo
- func (*AppInfo) Descriptor() ([]byte, []int)deprecated
- func (x *AppInfo) GetAddresses() []*Address
- func (x *AppInfo) GetArgs() []string
- func (x *AppInfo) GetBin() string
- func (x *AppInfo) GetCrashWait() uint64
- func (x *AppInfo) GetEnable() bool
- func (x *AppInfo) GetEnvs() []string
- func (x *AppInfo) GetEphemeral() bool
- func (x *AppInfo) GetFamily() string
- func (x *AppInfo) GetGroup() string
- func (x *AppInfo) GetInstances() []*InstanceInfo
- func (x *AppInfo) GetLastError() string
- func (x *AppInfo) GetMain() uint64
- func (x *AppInfo) GetName() string
- func (x *AppInfo) GetPath() string
- func (x *AppInfo) GetPwd() string
- func (x *AppInfo) GetStartTime() int64
- func (x *AppInfo) GetStat() AppStat_Enum
- func (x *AppInfo) GetUser() string
- func (*AppInfo) ProtoMessage()
- func (x *AppInfo) ProtoReflect() protoreflect.Message
- func (x *AppInfo) Reset()
- func (x *AppInfo) String() string
- type AppStat
- type AppStat_Enum
- func (AppStat_Enum) Descriptor() protoreflect.EnumDescriptor
- func (x AppStat_Enum) Enum() *AppStat_Enum
- func (AppStat_Enum) EnumDescriptor() ([]byte, []int)deprecated
- func (x AppStat_Enum) Number() protoreflect.EnumNumber
- func (x AppStat_Enum) String() string
- func (AppStat_Enum) Type() protoreflect.EnumType
- type AtomicAddRequest
- func (*AtomicAddRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AtomicAddRequest) GetDelta() int64
- func (x *AtomicAddRequest) GetName() string
- func (*AtomicAddRequest) ProtoMessage()
- func (x *AtomicAddRequest) ProtoReflect() protoreflect.Message
- func (x *AtomicAddRequest) Reset()
- func (x *AtomicAddRequest) String() string
- type AtomicAddResponse
- type AtomicClient
- type AtomicCompareAndSwapRequest
- func (*AtomicCompareAndSwapRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AtomicCompareAndSwapRequest) GetName() string
- func (x *AtomicCompareAndSwapRequest) GetNew() int64
- func (x *AtomicCompareAndSwapRequest) GetOld() int64
- func (*AtomicCompareAndSwapRequest) ProtoMessage()
- func (x *AtomicCompareAndSwapRequest) ProtoReflect() protoreflect.Message
- func (x *AtomicCompareAndSwapRequest) Reset()
- func (x *AtomicCompareAndSwapRequest) String() string
- type AtomicCompareAndSwapResponse
- func (*AtomicCompareAndSwapResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AtomicCompareAndSwapResponse) GetSwapped() bool
- func (*AtomicCompareAndSwapResponse) ProtoMessage()
- func (x *AtomicCompareAndSwapResponse) ProtoReflect() protoreflect.Message
- func (x *AtomicCompareAndSwapResponse) Reset()
- func (x *AtomicCompareAndSwapResponse) String() string
- type AtomicLoadRequest
- type AtomicLoadResponse
- type AtomicServer
- type AtomicStoreRequest
- func (*AtomicStoreRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AtomicStoreRequest) GetName() string
- func (x *AtomicStoreRequest) GetVal() int64
- func (*AtomicStoreRequest) ProtoMessage()
- func (x *AtomicStoreRequest) ProtoReflect() protoreflect.Message
- func (x *AtomicStoreRequest) Reset()
- func (x *AtomicStoreRequest) String() string
- type AtomicStoreResponse
- type AtomicSwapRequest
- func (*AtomicSwapRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AtomicSwapRequest) GetName() string
- func (x *AtomicSwapRequest) GetNew() int64
- func (*AtomicSwapRequest) ProtoMessage()
- func (x *AtomicSwapRequest) ProtoReflect() protoreflect.Message
- func (x *AtomicSwapRequest) Reset()
- func (x *AtomicSwapRequest) String() string
- type AtomicSwapResponse
- type CacheClient
- type CacheCountRequest
- type CacheCountResponse
- func (*CacheCountResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CacheCountResponse) GetCount() uint64
- func (*CacheCountResponse) ProtoMessage()
- func (x *CacheCountResponse) ProtoReflect() protoreflect.Message
- func (x *CacheCountResponse) Reset()
- func (x *CacheCountResponse) String() string
- type CacheDelRequest
- func (*CacheDelRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CacheDelRequest) GetKey() string
- func (x *CacheDelRequest) GetNs() string
- func (*CacheDelRequest) ProtoMessage()
- func (x *CacheDelRequest) ProtoReflect() protoreflect.Message
- func (x *CacheDelRequest) Reset()
- func (x *CacheDelRequest) String() string
- type CacheDelResponse
- type CacheExistsRequest
- func (*CacheExistsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CacheExistsRequest) GetKey() string
- func (x *CacheExistsRequest) GetNs() string
- func (*CacheExistsRequest) ProtoMessage()
- func (x *CacheExistsRequest) ProtoReflect() protoreflect.Message
- func (x *CacheExistsRequest) Reset()
- func (x *CacheExistsRequest) String() string
- type CacheExistsResponse
- func (*CacheExistsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CacheExistsResponse) GetFound() bool
- func (*CacheExistsResponse) ProtoMessage()
- func (x *CacheExistsResponse) ProtoReflect() protoreflect.Message
- func (x *CacheExistsResponse) Reset()
- func (x *CacheExistsResponse) String() string
- type CacheFlushRequest
- type CacheFlushResponse
- type CacheGetRequest
- func (*CacheGetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CacheGetRequest) GetKey() string
- func (x *CacheGetRequest) GetNs() string
- func (*CacheGetRequest) ProtoMessage()
- func (x *CacheGetRequest) ProtoReflect() protoreflect.Message
- func (x *CacheGetRequest) Reset()
- func (x *CacheGetRequest) String() string
- type CacheGetResponse
- func (*CacheGetResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CacheGetResponse) GetFound() bool
- func (x *CacheGetResponse) GetVal() []byte
- func (*CacheGetResponse) ProtoMessage()
- func (x *CacheGetResponse) ProtoReflect() protoreflect.Message
- func (x *CacheGetResponse) Reset()
- func (x *CacheGetResponse) String() string
- type CacheItemsRequest
- type CacheItemsResponse
- func (*CacheItemsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CacheItemsResponse) GetItems() map[string][]byte
- func (*CacheItemsResponse) ProtoMessage()
- func (x *CacheItemsResponse) ProtoReflect() protoreflect.Message
- func (x *CacheItemsResponse) Reset()
- func (x *CacheItemsResponse) String() string
- type CacheKeysRequest
- type CacheKeysResponse
- type CacheServer
- type CacheSetRequest
- func (*CacheSetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CacheSetRequest) GetKey() string
- func (x *CacheSetRequest) GetNs() string
- func (x *CacheSetRequest) GetTtl() uint64
- func (x *CacheSetRequest) GetVal() []byte
- func (*CacheSetRequest) ProtoMessage()
- func (x *CacheSetRequest) ProtoReflect() protoreflect.Message
- func (x *CacheSetRequest) Reset()
- func (x *CacheSetRequest) String() string
- type CacheSetResponse
- type CloseSocketRequest
- func (*CloseSocketRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CloseSocketRequest) GetAddress() string
- func (x *CloseSocketRequest) GetNetwork() string
- func (*CloseSocketRequest) ProtoMessage()
- func (x *CloseSocketRequest) ProtoReflect() protoreflect.Message
- func (x *CloseSocketRequest) Reset()
- func (x *CloseSocketRequest) String() string
- type CloseSocketResponse
- func (*CloseSocketResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CloseSocketResponse) GetCode() CloseSocketResponse_Code
- func (x *CloseSocketResponse) GetError() string
- func (*CloseSocketResponse) ProtoMessage()
- func (x *CloseSocketResponse) ProtoReflect() protoreflect.Message
- func (x *CloseSocketResponse) Reset()
- func (x *CloseSocketResponse) String() string
- type CloseSocketResponse_Code
- func (CloseSocketResponse_Code) Descriptor() protoreflect.EnumDescriptor
- func (x CloseSocketResponse_Code) Enum() *CloseSocketResponse_Code
- func (CloseSocketResponse_Code) EnumDescriptor() ([]byte, []int)deprecated
- func (x CloseSocketResponse_Code) Number() protoreflect.EnumNumber
- func (x CloseSocketResponse_Code) String() string
- func (CloseSocketResponse_Code) Type() protoreflect.EnumType
- type GetAppInfoRequest
- type GetAppInfoResponse
- func (*GetAppInfoResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetAppInfoResponse) GetCommit() string
- func (x *GetAppInfoResponse) GetCpu() float64
- func (x *GetAppInfoResponse) GetInfo() *AppInfo
- func (x *GetAppInfoResponse) GetPid() uint64
- func (x *GetAppInfoResponse) GetRam() float64
- func (x *GetAppInfoResponse) GetSock() string
- func (x *GetAppInfoResponse) GetStartTime() int64
- func (x *GetAppInfoResponse) GetVersion() string
- func (*GetAppInfoResponse) ProtoMessage()
- func (x *GetAppInfoResponse) ProtoReflect() protoreflect.Message
- func (x *GetAppInfoResponse) Reset()
- func (x *GetAppInfoResponse) String() string
- type GetInstanceInfoRequest
- type GetInstanceInfoResponse
- func (*GetInstanceInfoResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetInstanceInfoResponse) GetCode() GetInstanceInfoResponse_Code
- func (x *GetInstanceInfoResponse) GetError() string
- func (x *GetInstanceInfoResponse) GetInfo() *InstanceInfo
- func (*GetInstanceInfoResponse) ProtoMessage()
- func (x *GetInstanceInfoResponse) ProtoReflect() protoreflect.Message
- func (x *GetInstanceInfoResponse) Reset()
- func (x *GetInstanceInfoResponse) String() string
- type GetInstanceInfoResponse_Code
- func (GetInstanceInfoResponse_Code) Descriptor() protoreflect.EnumDescriptor
- func (x GetInstanceInfoResponse_Code) Enum() *GetInstanceInfoResponse_Code
- func (GetInstanceInfoResponse_Code) EnumDescriptor() ([]byte, []int)deprecated
- func (x GetInstanceInfoResponse_Code) Number() protoreflect.EnumNumber
- func (x GetInstanceInfoResponse_Code) String() string
- func (GetInstanceInfoResponse_Code) Type() protoreflect.EnumType
- type HeartbeatRequest
- func (*HeartbeatRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HeartbeatRequest) GetCommit() string
- func (x *HeartbeatRequest) GetDescription() string
- func (x *HeartbeatRequest) GetReady() bool
- func (x *HeartbeatRequest) GetTasks() uint64
- func (x *HeartbeatRequest) GetVersion() string
- func (*HeartbeatRequest) ProtoMessage()
- func (x *HeartbeatRequest) ProtoReflect() protoreflect.Message
- func (x *HeartbeatRequest) Reset()
- func (x *HeartbeatRequest) String() string
- type HeartbeatResponse
- func (*HeartbeatResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HeartbeatResponse) GetCode() HeartbeatResponse_Code
- func (x *HeartbeatResponse) GetError() string
- func (*HeartbeatResponse) ProtoMessage()
- func (x *HeartbeatResponse) ProtoReflect() protoreflect.Message
- func (x *HeartbeatResponse) Reset()
- func (x *HeartbeatResponse) String() string
- type HeartbeatResponse_Code
- func (HeartbeatResponse_Code) Descriptor() protoreflect.EnumDescriptor
- func (x HeartbeatResponse_Code) Enum() *HeartbeatResponse_Code
- func (HeartbeatResponse_Code) EnumDescriptor() ([]byte, []int)deprecated
- func (x HeartbeatResponse_Code) Number() protoreflect.EnumNumber
- func (x HeartbeatResponse_Code) String() string
- func (HeartbeatResponse_Code) Type() protoreflect.EnumType
- type InstanceInfo
- func (*InstanceInfo) Descriptor() ([]byte, []int)deprecated
- func (x *InstanceInfo) GetAddresses() []*Address
- func (x *InstanceInfo) GetAppname() string
- func (x *InstanceInfo) GetCommit() string
- func (x *InstanceInfo) GetCpu() float64
- func (x *InstanceInfo) GetDescription() string
- func (x *InstanceInfo) GetFamily() string
- func (x *InstanceInfo) GetId() uint64
- func (x *InstanceInfo) GetPid() uint64
- func (x *InstanceInfo) GetRam() float64
- func (x *InstanceInfo) GetStartTime() int64
- func (x *InstanceInfo) GetStat() InstanceStat_Enum
- func (x *InstanceInfo) GetTasks() uint64
- func (x *InstanceInfo) GetVersion() string
- func (*InstanceInfo) ProtoMessage()
- func (x *InstanceInfo) ProtoReflect() protoreflect.Message
- func (x *InstanceInfo) Reset()
- func (x *InstanceInfo) String() string
- type InstanceStat
- type InstanceStat_Enum
- func (InstanceStat_Enum) Descriptor() protoreflect.EnumDescriptor
- func (x InstanceStat_Enum) Enum() *InstanceStat_Enum
- func (InstanceStat_Enum) EnumDescriptor() ([]byte, []int)deprecated
- func (x InstanceStat_Enum) Number() protoreflect.EnumNumber
- func (x InstanceStat_Enum) String() string
- func (InstanceStat_Enum) Type() protoreflect.EnumType
- type ListenSocketRequest
- func (*ListenSocketRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListenSocketRequest) GetAddress() string
- func (x *ListenSocketRequest) GetNetwork() string
- func (*ListenSocketRequest) ProtoMessage()
- func (x *ListenSocketRequest) ProtoReflect() protoreflect.Message
- func (x *ListenSocketRequest) Reset()
- func (x *ListenSocketRequest) String() string
- type ListenSocketResponse
- func (*ListenSocketResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListenSocketResponse) GetCode() ListenSocketResponse_Code
- func (x *ListenSocketResponse) GetError() string
- func (*ListenSocketResponse) ProtoMessage()
- func (x *ListenSocketResponse) ProtoReflect() protoreflect.Message
- func (x *ListenSocketResponse) Reset()
- func (x *ListenSocketResponse) String() string
- type ListenSocketResponse_Code
- func (ListenSocketResponse_Code) Descriptor() protoreflect.EnumDescriptor
- func (x ListenSocketResponse_Code) Enum() *ListenSocketResponse_Code
- func (ListenSocketResponse_Code) EnumDescriptor() ([]byte, []int)deprecated
- func (x ListenSocketResponse_Code) Number() protoreflect.EnumNumber
- func (x ListenSocketResponse_Code) String() string
- func (ListenSocketResponse_Code) Type() protoreflect.EnumType
- type LockerClient
- type LockerLockRequest
- type LockerLockResponse
- type LockerQueuesRequest
- func (*LockerQueuesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LockerQueuesRequest) GetName() string
- func (*LockerQueuesRequest) ProtoMessage()
- func (x *LockerQueuesRequest) ProtoReflect() protoreflect.Message
- func (x *LockerQueuesRequest) Reset()
- func (x *LockerQueuesRequest) String() string
- type LockerQueuesResponse
- func (*LockerQueuesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LockerQueuesResponse) GetR() int64
- func (x *LockerQueuesResponse) GetW() int64
- func (*LockerQueuesResponse) ProtoMessage()
- func (x *LockerQueuesResponse) ProtoReflect() protoreflect.Message
- func (x *LockerQueuesResponse) Reset()
- func (x *LockerQueuesResponse) String() string
- type LockerRLockRequest
- func (*LockerRLockRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LockerRLockRequest) GetName() string
- func (*LockerRLockRequest) ProtoMessage()
- func (x *LockerRLockRequest) ProtoReflect() protoreflect.Message
- func (x *LockerRLockRequest) Reset()
- func (x *LockerRLockRequest) String() string
- type LockerRLockResponse
- type LockerRUnlockRequest
- func (*LockerRUnlockRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LockerRUnlockRequest) GetName() string
- func (*LockerRUnlockRequest) ProtoMessage()
- func (x *LockerRUnlockRequest) ProtoReflect() protoreflect.Message
- func (x *LockerRUnlockRequest) Reset()
- func (x *LockerRUnlockRequest) String() string
- type LockerRUnlockResponse
- type LockerServer
- type LockerTryLockRequest
- func (*LockerTryLockRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LockerTryLockRequest) GetName() string
- func (x *LockerTryLockRequest) GetTimeout() uint64
- func (*LockerTryLockRequest) ProtoMessage()
- func (x *LockerTryLockRequest) ProtoReflect() protoreflect.Message
- func (x *LockerTryLockRequest) Reset()
- func (x *LockerTryLockRequest) String() string
- type LockerTryLockResponse
- func (*LockerTryLockResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LockerTryLockResponse) GetAcquired() bool
- func (*LockerTryLockResponse) ProtoMessage()
- func (x *LockerTryLockResponse) ProtoReflect() protoreflect.Message
- func (x *LockerTryLockResponse) Reset()
- func (x *LockerTryLockResponse) String() string
- type LockerTryRLockRequest
- func (*LockerTryRLockRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LockerTryRLockRequest) GetName() string
- func (x *LockerTryRLockRequest) GetTimeout() uint64
- func (*LockerTryRLockRequest) ProtoMessage()
- func (x *LockerTryRLockRequest) ProtoReflect() protoreflect.Message
- func (x *LockerTryRLockRequest) Reset()
- func (x *LockerTryRLockRequest) String() string
- type LockerTryRLockResponse
- func (*LockerTryRLockResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LockerTryRLockResponse) GetAcquired() bool
- func (*LockerTryRLockResponse) ProtoMessage()
- func (x *LockerTryRLockResponse) ProtoReflect() protoreflect.Message
- func (x *LockerTryRLockResponse) Reset()
- func (x *LockerTryRLockResponse) String() string
- type LockerUnlockRequest
- func (*LockerUnlockRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LockerUnlockRequest) GetName() string
- func (*LockerUnlockRequest) ProtoMessage()
- func (x *LockerUnlockRequest) ProtoReflect() protoreflect.Message
- func (x *LockerUnlockRequest) Reset()
- func (x *LockerUnlockRequest) String() string
- type LockerUnlockResponse
- type ReloadAppRequest
- type ReloadAppResponse
- func (*ReloadAppResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ReloadAppResponse) GetCode() ReloadAppResponse_Code
- func (x *ReloadAppResponse) GetError() string
- func (*ReloadAppResponse) ProtoMessage()
- func (x *ReloadAppResponse) ProtoReflect() protoreflect.Message
- func (x *ReloadAppResponse) Reset()
- func (x *ReloadAppResponse) String() string
- type ReloadAppResponse_Code
- func (ReloadAppResponse_Code) Descriptor() protoreflect.EnumDescriptor
- func (x ReloadAppResponse_Code) Enum() *ReloadAppResponse_Code
- func (ReloadAppResponse_Code) EnumDescriptor() ([]byte, []int)deprecated
- func (x ReloadAppResponse_Code) Number() protoreflect.EnumNumber
- func (x ReloadAppResponse_Code) String() string
- func (ReloadAppResponse_Code) Type() protoreflect.EnumType
- type UnimplementedAllyServer
- func (UnimplementedAllyServer) CloseSocket(context.Context, *CloseSocketRequest) (*CloseSocketResponse, error)
- func (UnimplementedAllyServer) GetAppInfo(context.Context, *GetAppInfoRequest) (*GetAppInfoResponse, error)
- func (UnimplementedAllyServer) GetInstanceInfo(context.Context, *GetInstanceInfoRequest) (*GetInstanceInfoResponse, error)
- func (UnimplementedAllyServer) Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
- func (UnimplementedAllyServer) ListenSocket(context.Context, *ListenSocketRequest) (*ListenSocketResponse, error)
- func (UnimplementedAllyServer) ReloadApp(context.Context, *ReloadAppRequest) (*ReloadAppResponse, error)
- type UnimplementedAtomicServer
- func (UnimplementedAtomicServer) AtomicAdd(context.Context, *AtomicAddRequest) (*AtomicAddResponse, error)
- func (UnimplementedAtomicServer) AtomicCompareAndSwap(context.Context, *AtomicCompareAndSwapRequest) (*AtomicCompareAndSwapResponse, error)
- func (UnimplementedAtomicServer) AtomicLoad(context.Context, *AtomicLoadRequest) (*AtomicLoadResponse, error)
- func (UnimplementedAtomicServer) AtomicStore(context.Context, *AtomicStoreRequest) (*AtomicStoreResponse, error)
- func (UnimplementedAtomicServer) AtomicSwap(context.Context, *AtomicSwapRequest) (*AtomicSwapResponse, error)
- type UnimplementedCacheServer
- func (UnimplementedCacheServer) CacheCount(context.Context, *CacheCountRequest) (*CacheCountResponse, error)
- func (UnimplementedCacheServer) CacheDel(context.Context, *CacheDelRequest) (*CacheDelResponse, error)
- func (UnimplementedCacheServer) CacheExists(context.Context, *CacheExistsRequest) (*CacheExistsResponse, error)
- func (UnimplementedCacheServer) CacheFlush(context.Context, *CacheFlushRequest) (*CacheFlushResponse, error)
- func (UnimplementedCacheServer) CacheGet(context.Context, *CacheGetRequest) (*CacheGetResponse, error)
- func (UnimplementedCacheServer) CacheItems(context.Context, *CacheItemsRequest) (*CacheItemsResponse, error)
- func (UnimplementedCacheServer) CacheKeys(context.Context, *CacheKeysRequest) (*CacheKeysResponse, error)
- func (UnimplementedCacheServer) CacheSet(context.Context, *CacheSetRequest) (*CacheSetResponse, error)
- type UnimplementedLockerServer
- func (UnimplementedLockerServer) LockerLock(context.Context, *LockerLockRequest) (*LockerLockResponse, error)
- func (UnimplementedLockerServer) LockerQueues(context.Context, *LockerQueuesRequest) (*LockerQueuesResponse, error)
- func (UnimplementedLockerServer) LockerRLock(context.Context, *LockerRLockRequest) (*LockerRLockResponse, error)
- func (UnimplementedLockerServer) LockerRUnlock(context.Context, *LockerRUnlockRequest) (*LockerRUnlockResponse, error)
- func (UnimplementedLockerServer) LockerTryLock(context.Context, *LockerTryLockRequest) (*LockerTryLockResponse, error)
- func (UnimplementedLockerServer) LockerTryRLock(context.Context, *LockerTryRLockRequest) (*LockerTryRLockResponse, error)
- func (UnimplementedLockerServer) LockerUnlock(context.Context, *LockerUnlockRequest) (*LockerUnlockResponse, error)
- type UnsafeAllyServer
- type UnsafeAtomicServer
- type UnsafeCacheServer
- type UnsafeLockerServer
Constants ¶
const ( Ally_ListenSocket_FullMethodName = "/xiao.ally.Ally/ListenSocket" Ally_CloseSocket_FullMethodName = "/xiao.ally.Ally/CloseSocket" Ally_ReloadApp_FullMethodName = "/xiao.ally.Ally/ReloadApp" Ally_Heartbeat_FullMethodName = "/xiao.ally.Ally/Heartbeat" Ally_GetAppInfo_FullMethodName = "/xiao.ally.Ally/GetAppInfo" Ally_GetInstanceInfo_FullMethodName = "/xiao.ally.Ally/GetInstanceInfo" )
const ( Atomic_AtomicAdd_FullMethodName = "/xiao.ally.Atomic/AtomicAdd" Atomic_AtomicLoad_FullMethodName = "/xiao.ally.Atomic/AtomicLoad" Atomic_AtomicStore_FullMethodName = "/xiao.ally.Atomic/AtomicStore" Atomic_AtomicSwap_FullMethodName = "/xiao.ally.Atomic/AtomicSwap" Atomic_AtomicCompareAndSwap_FullMethodName = "/xiao.ally.Atomic/AtomicCompareAndSwap" )
const ( Cache_CacheSet_FullMethodName = "/xiao.ally.Cache/CacheSet" Cache_CacheGet_FullMethodName = "/xiao.ally.Cache/CacheGet" Cache_CacheDel_FullMethodName = "/xiao.ally.Cache/CacheDel" Cache_CacheKeys_FullMethodName = "/xiao.ally.Cache/CacheKeys" Cache_CacheCount_FullMethodName = "/xiao.ally.Cache/CacheCount" Cache_CacheItems_FullMethodName = "/xiao.ally.Cache/CacheItems" Cache_CacheFlush_FullMethodName = "/xiao.ally.Cache/CacheFlush" Cache_CacheExists_FullMethodName = "/xiao.ally.Cache/CacheExists" )
const ( Locker_LockerLock_FullMethodName = "/xiao.ally.Locker/LockerLock" Locker_LockerRLock_FullMethodName = "/xiao.ally.Locker/LockerRLock" Locker_LockerTryLock_FullMethodName = "/xiao.ally.Locker/LockerTryLock" Locker_LockerTryRLock_FullMethodName = "/xiao.ally.Locker/LockerTryRLock" Locker_LockerUnlock_FullMethodName = "/xiao.ally.Locker/LockerUnlock" Locker_LockerRUnlock_FullMethodName = "/xiao.ally.Locker/LockerRUnlock" Locker_LockerQueues_FullMethodName = "/xiao.ally.Locker/LockerQueues" )
Variables ¶
var ( ListenSocketResponse_Code_name = map[int32]string{ 0: "EC_OK", 1: "EC_PERMISSION", 2: "EC_BAD_ADDRESS", 3: "EC_LISTEN", 4: "EC_SEND", } ListenSocketResponse_Code_value = map[string]int32{ "EC_OK": 0, "EC_PERMISSION": 1, "EC_BAD_ADDRESS": 2, "EC_LISTEN": 3, "EC_SEND": 4, } )
Enum value maps for ListenSocketResponse_Code.
var ( CloseSocketResponse_Code_name = map[int32]string{ 0: "EC_OK", 1: "EC_PERMISSION", 2: "EC_BAD_ADDRESS", } CloseSocketResponse_Code_value = map[string]int32{ "EC_OK": 0, "EC_PERMISSION": 1, "EC_BAD_ADDRESS": 2, } )
Enum value maps for CloseSocketResponse_Code.
var ( ReloadAppResponse_Code_name = map[int32]string{ 0: "EC_OK", 1: "EC_PERMISSION", 2: "EC_RELOAD", } ReloadAppResponse_Code_value = map[string]int32{ "EC_OK": 0, "EC_PERMISSION": 1, "EC_RELOAD": 2, } )
Enum value maps for ReloadAppResponse_Code.
var ( HeartbeatResponse_Code_name = map[int32]string{ 0: "EC_OK", 1: "EC_PERMISSION", } HeartbeatResponse_Code_value = map[string]int32{ "EC_OK": 0, "EC_PERMISSION": 1, } )
Enum value maps for HeartbeatResponse_Code.
var ( InstanceStat_Enum_name = map[int32]string{ 0: "PREPARING", 1: "RUNNING", 2: "CLOSING", } InstanceStat_Enum_value = map[string]int32{ "PREPARING": 0, "RUNNING": 1, "CLOSING": 2, } )
Enum value maps for InstanceStat_Enum.
var ( AppStat_Enum_name = map[int32]string{ 0: "STOPPED", 1: "BOOTING1", 2: "BOOTING2", 3: "RUNNING", 4: "CLOSING", 5: "RELOADING1", 6: "RELOADING2", 7: "RELOADING3", 8: "RECOVERING", } AppStat_Enum_value = map[string]int32{ "STOPPED": 0, "BOOTING1": 1, "BOOTING2": 2, "RUNNING": 3, "CLOSING": 4, "RELOADING1": 5, "RELOADING2": 6, "RELOADING3": 7, "RECOVERING": 8, } )
Enum value maps for AppStat_Enum.
var ( GetInstanceInfoResponse_Code_name = map[int32]string{ 0: "EC_OK", 1: "EC_PERMISSION", } GetInstanceInfoResponse_Code_value = map[string]int32{ "EC_OK": 0, "EC_PERMISSION": 1, } )
Enum value maps for GetInstanceInfoResponse_Code.
var Ally_ServiceDesc = grpc.ServiceDesc{ ServiceName: "xiao.ally.Ally", HandlerType: (*AllyServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ListenSocket", Handler: _Ally_ListenSocket_Handler, }, { MethodName: "CloseSocket", Handler: _Ally_CloseSocket_Handler, }, { MethodName: "ReloadApp", Handler: _Ally_ReloadApp_Handler, }, { MethodName: "Heartbeat", Handler: _Ally_Heartbeat_Handler, }, { MethodName: "GetAppInfo", Handler: _Ally_GetAppInfo_Handler, }, { MethodName: "GetInstanceInfo", Handler: _Ally_GetInstanceInfo_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "ally.xiao.proto", }
Ally_ServiceDesc is the grpc.ServiceDesc for Ally service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Atomic_ServiceDesc = grpc.ServiceDesc{ ServiceName: "xiao.ally.Atomic", HandlerType: (*AtomicServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "AtomicAdd", Handler: _Atomic_AtomicAdd_Handler, }, { MethodName: "AtomicLoad", Handler: _Atomic_AtomicLoad_Handler, }, { MethodName: "AtomicStore", Handler: _Atomic_AtomicStore_Handler, }, { MethodName: "AtomicSwap", Handler: _Atomic_AtomicSwap_Handler, }, { MethodName: "AtomicCompareAndSwap", Handler: _Atomic_AtomicCompareAndSwap_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "atomic.ally.xiao.proto", }
Atomic_ServiceDesc is the grpc.ServiceDesc for Atomic service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Cache_ServiceDesc = grpc.ServiceDesc{ ServiceName: "xiao.ally.Cache", HandlerType: (*CacheServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CacheSet", Handler: _Cache_CacheSet_Handler, }, { MethodName: "CacheGet", Handler: _Cache_CacheGet_Handler, }, { MethodName: "CacheDel", Handler: _Cache_CacheDel_Handler, }, { MethodName: "CacheKeys", Handler: _Cache_CacheKeys_Handler, }, { MethodName: "CacheCount", Handler: _Cache_CacheCount_Handler, }, { MethodName: "CacheItems", Handler: _Cache_CacheItems_Handler, }, { MethodName: "CacheFlush", Handler: _Cache_CacheFlush_Handler, }, { MethodName: "CacheExists", Handler: _Cache_CacheExists_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "cache.ally.xiao.proto", }
Cache_ServiceDesc is the grpc.ServiceDesc for Cache service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_ally_xiao_proto protoreflect.FileDescriptor
var File_atomic_ally_xiao_proto protoreflect.FileDescriptor
var File_cache_ally_xiao_proto protoreflect.FileDescriptor
var File_locker_ally_xiao_proto protoreflect.FileDescriptor
var Locker_ServiceDesc = grpc.ServiceDesc{ ServiceName: "xiao.ally.Locker", HandlerType: (*LockerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "LockerLock", Handler: _Locker_LockerLock_Handler, }, { MethodName: "LockerRLock", Handler: _Locker_LockerRLock_Handler, }, { MethodName: "LockerTryLock", Handler: _Locker_LockerTryLock_Handler, }, { MethodName: "LockerTryRLock", Handler: _Locker_LockerTryRLock_Handler, }, { MethodName: "LockerUnlock", Handler: _Locker_LockerUnlock_Handler, }, { MethodName: "LockerRUnlock", Handler: _Locker_LockerRUnlock_Handler, }, { MethodName: "LockerQueues", Handler: _Locker_LockerQueues_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "locker.ally.xiao.proto", }
Locker_ServiceDesc is the grpc.ServiceDesc for Locker service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterAllyServer ¶
func RegisterAllyServer(s grpc.ServiceRegistrar, srv AllyServer)
func RegisterAtomicServer ¶
func RegisterAtomicServer(s grpc.ServiceRegistrar, srv AtomicServer)
func RegisterCacheServer ¶
func RegisterCacheServer(s grpc.ServiceRegistrar, srv CacheServer)
func RegisterLockerServer ¶
func RegisterLockerServer(s grpc.ServiceRegistrar, srv LockerServer)
Types ¶
type Address ¶
type Address struct {
Network string `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"` // 网络名称
Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` // 地址值
Refs uint64 `protobuf:"varint,3,opt,name=refs,proto3" json:"refs,omitempty"` // 引用计数
Created int64 `protobuf:"varint,4,opt,name=created,proto3" json:"created,omitempty"` // 首次被引用时间戳(纳秒)
Updated int64 `protobuf:"varint,5,opt,name=updated,proto3" json:"updated,omitempty"` // 最后被引用、解除引用的时间戳(纳秒)
// contains filtered or unexported fields
}
func (*Address) Descriptor
deprecated
func (*Address) GetAddress ¶
func (*Address) GetCreated ¶
func (*Address) GetNetwork ¶
func (*Address) GetUpdated ¶
func (*Address) ProtoMessage ¶
func (*Address) ProtoMessage()
func (*Address) ProtoReflect ¶
func (x *Address) ProtoReflect() protoreflect.Message
type AllyClient ¶
type AllyClient interface {
ListenSocket(ctx context.Context, in *ListenSocketRequest, opts ...grpc.CallOption) (*ListenSocketResponse, error)
CloseSocket(ctx context.Context, in *CloseSocketRequest, opts ...grpc.CallOption) (*CloseSocketResponse, error)
ReloadApp(ctx context.Context, in *ReloadAppRequest, opts ...grpc.CallOption) (*ReloadAppResponse, error)
Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*HeartbeatResponse, error)
GetAppInfo(ctx context.Context, in *GetAppInfoRequest, opts ...grpc.CallOption) (*GetAppInfoResponse, error)
GetInstanceInfo(ctx context.Context, in *GetInstanceInfoRequest, opts ...grpc.CallOption) (*GetInstanceInfoResponse, error)
}
AllyClient is the client API for Ally 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 NewAllyClient ¶
func NewAllyClient(cc grpc.ClientConnInterface) AllyClient
type AllyServer ¶
type AllyServer interface {
ListenSocket(context.Context, *ListenSocketRequest) (*ListenSocketResponse, error)
CloseSocket(context.Context, *CloseSocketRequest) (*CloseSocketResponse, error)
ReloadApp(context.Context, *ReloadAppRequest) (*ReloadAppResponse, error)
Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
GetAppInfo(context.Context, *GetAppInfoRequest) (*GetAppInfoResponse, error)
GetInstanceInfo(context.Context, *GetInstanceInfoRequest) (*GetInstanceInfoResponse, error)
// contains filtered or unexported methods
}
AllyServer is the server API for Ally service. All implementations must embed UnimplementedAllyServer for forward compatibility.
type AppInfo ¶
type AppInfo struct {
// config info
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // app名称
Family string `protobuf:"bytes,2,opt,name=family,proto3" json:"family,omitempty"` // app所属家族
Bin string `protobuf:"bytes,3,opt,name=bin,proto3" json:"bin,omitempty"` // app binary全路径
Pwd string `protobuf:"bytes,4,opt,name=pwd,proto3" json:"pwd,omitempty"` // app的工作目录
Path string `protobuf:"bytes,5,opt,name=path,proto3" json:"path,omitempty"` // app的工作PATH
CrashWait uint64 `protobuf:"varint,6,opt,name=crash_wait,json=crashWait,proto3" json:"crash_wait,omitempty"` // app crash后是否自动拉起,以及拉起的间隔时长(毫秒),值为0表示不自动拉起
Args []string `protobuf:"bytes,7,rep,name=args,proto3" json:"args,omitempty"` // app的启动参数表
Envs []string `protobuf:"bytes,8,rep,name=envs,proto3" json:"envs,omitempty"` // app启动时的额外环境变量值,VAR=VAL
User string `protobuf:"bytes,15,opt,name=user,proto3" json:"user,omitempty"` // app启动时应当使用的用户id或name
Group string `protobuf:"bytes,16,opt,name=group,proto3" json:"group,omitempty"` // app启动时应当使用的用户组id或name
// running info
Main uint64 `protobuf:"varint,9,opt,name=main,proto3" json:"main,omitempty"` // 主实例的id
StartTime int64 `protobuf:"varint,10,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` // app首次的启动时间戳(纳秒),即id=1的实例启动时间
LastError string `protobuf:"bytes,11,opt,name=last_error,json=lastError,proto3" json:"last_error,omitempty"` // 如果主实例运行失败或拉起失败,则记录最后一次拉起失败或主实例运行失败的错误信息
Stat AppStat_Enum `protobuf:"varint,12,opt,name=stat,proto3,enum=xiao.ally.AppStat_Enum" json:"stat,omitempty"` // app的状态
Addresses []*Address `protobuf:"bytes,13,rep,name=addresses,proto3" json:"addresses,omitempty"` // app关联的全部地址
// instances info
Instances []*InstanceInfo `protobuf:"bytes,14,rep,name=instances,proto3" json:"instances,omitempty"` // 所有实例信息
Enable bool `protobuf:"varint,100,opt,name=enable,proto3" json:"enable,omitempty"` // bypass, 标记是否需要在ally wakeup时启动,此值恒为false
Ephemeral bool `protobuf:"varint,101,opt,name=ephemeral,proto3" json:"ephemeral,omitempty"` // bypass, 标记是否是临时app(未被invite),此值恒为true
// contains filtered or unexported fields
}
func (*AppInfo) Descriptor
deprecated
func (*AppInfo) GetAddresses ¶
func (*AppInfo) GetCrashWait ¶
func (*AppInfo) GetEphemeral ¶
func (*AppInfo) GetInstances ¶
func (x *AppInfo) GetInstances() []*InstanceInfo
func (*AppInfo) GetLastError ¶
func (*AppInfo) GetStartTime ¶
func (*AppInfo) GetStat ¶
func (x *AppInfo) GetStat() AppStat_Enum
func (*AppInfo) ProtoMessage ¶
func (*AppInfo) ProtoMessage()
func (*AppInfo) ProtoReflect ¶
func (x *AppInfo) ProtoReflect() protoreflect.Message
type AppStat ¶
type AppStat struct {
// contains filtered or unexported fields
}
func (*AppStat) Descriptor
deprecated
func (*AppStat) ProtoMessage ¶
func (*AppStat) ProtoMessage()
func (*AppStat) ProtoReflect ¶
func (x *AppStat) ProtoReflect() protoreflect.Message
type AppStat_Enum ¶
type AppStat_Enum int32
const ( AppStat_STOPPED AppStat_Enum = 0 AppStat_BOOTING1 AppStat_Enum = 1 // 刚在boot AppStat_BOOTING2 AppStat_Enum = 2 // main启动了,但尚未ready AppStat_RUNNING AppStat_Enum = 3 AppStat_CLOSING AppStat_Enum = 4 AppStat_RELOADING1 AppStat_Enum = 5 // main在,进行booting AppStat_RELOADING2 AppStat_Enum = 6 // 新main启动了,但尚未ready AppStat_RELOADING3 AppStat_Enum = 7 // 新main已经ready,但是还有旧实例没结束 AppStat_RECOVERING AppStat_Enum = 8 // main没有,且不是第一次boot )
func (AppStat_Enum) Descriptor ¶
func (AppStat_Enum) Descriptor() protoreflect.EnumDescriptor
func (AppStat_Enum) Enum ¶
func (x AppStat_Enum) Enum() *AppStat_Enum
func (AppStat_Enum) EnumDescriptor
deprecated
func (AppStat_Enum) EnumDescriptor() ([]byte, []int)
Deprecated: Use AppStat_Enum.Descriptor instead.
func (AppStat_Enum) Number ¶
func (x AppStat_Enum) Number() protoreflect.EnumNumber
func (AppStat_Enum) String ¶
func (x AppStat_Enum) String() string
func (AppStat_Enum) Type ¶
func (AppStat_Enum) Type() protoreflect.EnumType
type AtomicAddRequest ¶
type AtomicAddRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Delta int64 `protobuf:"varint,2,opt,name=delta,proto3" json:"delta,omitempty"`
// contains filtered or unexported fields
}
func (*AtomicAddRequest) Descriptor
deprecated
func (*AtomicAddRequest) Descriptor() ([]byte, []int)
Deprecated: Use AtomicAddRequest.ProtoReflect.Descriptor instead.
func (*AtomicAddRequest) GetDelta ¶
func (x *AtomicAddRequest) GetDelta() int64
func (*AtomicAddRequest) GetName ¶
func (x *AtomicAddRequest) GetName() string
func (*AtomicAddRequest) ProtoMessage ¶
func (*AtomicAddRequest) ProtoMessage()
func (*AtomicAddRequest) ProtoReflect ¶
func (x *AtomicAddRequest) ProtoReflect() protoreflect.Message
func (*AtomicAddRequest) Reset ¶
func (x *AtomicAddRequest) Reset()
func (*AtomicAddRequest) String ¶
func (x *AtomicAddRequest) String() string
type AtomicAddResponse ¶
type AtomicAddResponse struct {
Val int64 `protobuf:"varint,1,opt,name=val,proto3" json:"val,omitempty"`
// contains filtered or unexported fields
}
func (*AtomicAddResponse) Descriptor
deprecated
func (*AtomicAddResponse) Descriptor() ([]byte, []int)
Deprecated: Use AtomicAddResponse.ProtoReflect.Descriptor instead.
func (*AtomicAddResponse) GetVal ¶
func (x *AtomicAddResponse) GetVal() int64
func (*AtomicAddResponse) ProtoMessage ¶
func (*AtomicAddResponse) ProtoMessage()
func (*AtomicAddResponse) ProtoReflect ¶
func (x *AtomicAddResponse) ProtoReflect() protoreflect.Message
func (*AtomicAddResponse) Reset ¶
func (x *AtomicAddResponse) Reset()
func (*AtomicAddResponse) String ¶
func (x *AtomicAddResponse) String() string
type AtomicClient ¶
type AtomicClient interface {
AtomicAdd(ctx context.Context, in *AtomicAddRequest, opts ...grpc.CallOption) (*AtomicAddResponse, error)
AtomicLoad(ctx context.Context, in *AtomicLoadRequest, opts ...grpc.CallOption) (*AtomicLoadResponse, error)
AtomicStore(ctx context.Context, in *AtomicStoreRequest, opts ...grpc.CallOption) (*AtomicStoreResponse, error)
AtomicSwap(ctx context.Context, in *AtomicSwapRequest, opts ...grpc.CallOption) (*AtomicSwapResponse, error)
AtomicCompareAndSwap(ctx context.Context, in *AtomicCompareAndSwapRequest, opts ...grpc.CallOption) (*AtomicCompareAndSwapResponse, error)
}
AtomicClient is the client API for Atomic 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 NewAtomicClient ¶
func NewAtomicClient(cc grpc.ClientConnInterface) AtomicClient
type AtomicCompareAndSwapRequest ¶
type AtomicCompareAndSwapRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Old int64 `protobuf:"varint,2,opt,name=old,proto3" json:"old,omitempty"`
New int64 `protobuf:"varint,3,opt,name=new,proto3" json:"new,omitempty"`
// contains filtered or unexported fields
}
func (*AtomicCompareAndSwapRequest) Descriptor
deprecated
func (*AtomicCompareAndSwapRequest) Descriptor() ([]byte, []int)
Deprecated: Use AtomicCompareAndSwapRequest.ProtoReflect.Descriptor instead.
func (*AtomicCompareAndSwapRequest) GetName ¶
func (x *AtomicCompareAndSwapRequest) GetName() string
func (*AtomicCompareAndSwapRequest) GetNew ¶
func (x *AtomicCompareAndSwapRequest) GetNew() int64
func (*AtomicCompareAndSwapRequest) GetOld ¶
func (x *AtomicCompareAndSwapRequest) GetOld() int64
func (*AtomicCompareAndSwapRequest) ProtoMessage ¶
func (*AtomicCompareAndSwapRequest) ProtoMessage()
func (*AtomicCompareAndSwapRequest) ProtoReflect ¶
func (x *AtomicCompareAndSwapRequest) ProtoReflect() protoreflect.Message
func (*AtomicCompareAndSwapRequest) Reset ¶
func (x *AtomicCompareAndSwapRequest) Reset()
func (*AtomicCompareAndSwapRequest) String ¶
func (x *AtomicCompareAndSwapRequest) String() string
type AtomicCompareAndSwapResponse ¶
type AtomicCompareAndSwapResponse struct {
Swapped bool `protobuf:"varint,1,opt,name=swapped,proto3" json:"swapped,omitempty"`
// contains filtered or unexported fields
}
func (*AtomicCompareAndSwapResponse) Descriptor
deprecated
func (*AtomicCompareAndSwapResponse) Descriptor() ([]byte, []int)
Deprecated: Use AtomicCompareAndSwapResponse.ProtoReflect.Descriptor instead.
func (*AtomicCompareAndSwapResponse) GetSwapped ¶
func (x *AtomicCompareAndSwapResponse) GetSwapped() bool
func (*AtomicCompareAndSwapResponse) ProtoMessage ¶
func (*AtomicCompareAndSwapResponse) ProtoMessage()
func (*AtomicCompareAndSwapResponse) ProtoReflect ¶
func (x *AtomicCompareAndSwapResponse) ProtoReflect() protoreflect.Message
func (*AtomicCompareAndSwapResponse) Reset ¶
func (x *AtomicCompareAndSwapResponse) Reset()
func (*AtomicCompareAndSwapResponse) String ¶
func (x *AtomicCompareAndSwapResponse) String() string
type AtomicLoadRequest ¶
type AtomicLoadRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*AtomicLoadRequest) Descriptor
deprecated
func (*AtomicLoadRequest) Descriptor() ([]byte, []int)
Deprecated: Use AtomicLoadRequest.ProtoReflect.Descriptor instead.
func (*AtomicLoadRequest) GetName ¶
func (x *AtomicLoadRequest) GetName() string
func (*AtomicLoadRequest) ProtoMessage ¶
func (*AtomicLoadRequest) ProtoMessage()
func (*AtomicLoadRequest) ProtoReflect ¶
func (x *AtomicLoadRequest) ProtoReflect() protoreflect.Message
func (*AtomicLoadRequest) Reset ¶
func (x *AtomicLoadRequest) Reset()
func (*AtomicLoadRequest) String ¶
func (x *AtomicLoadRequest) String() string
type AtomicLoadResponse ¶
type AtomicLoadResponse struct {
Val int64 `protobuf:"varint,1,opt,name=val,proto3" json:"val,omitempty"`
// contains filtered or unexported fields
}
func (*AtomicLoadResponse) Descriptor
deprecated
func (*AtomicLoadResponse) Descriptor() ([]byte, []int)
Deprecated: Use AtomicLoadResponse.ProtoReflect.Descriptor instead.
func (*AtomicLoadResponse) GetVal ¶
func (x *AtomicLoadResponse) GetVal() int64
func (*AtomicLoadResponse) ProtoMessage ¶
func (*AtomicLoadResponse) ProtoMessage()
func (*AtomicLoadResponse) ProtoReflect ¶
func (x *AtomicLoadResponse) ProtoReflect() protoreflect.Message
func (*AtomicLoadResponse) Reset ¶
func (x *AtomicLoadResponse) Reset()
func (*AtomicLoadResponse) String ¶
func (x *AtomicLoadResponse) String() string
type AtomicServer ¶
type AtomicServer interface {
AtomicAdd(context.Context, *AtomicAddRequest) (*AtomicAddResponse, error)
AtomicLoad(context.Context, *AtomicLoadRequest) (*AtomicLoadResponse, error)
AtomicStore(context.Context, *AtomicStoreRequest) (*AtomicStoreResponse, error)
AtomicSwap(context.Context, *AtomicSwapRequest) (*AtomicSwapResponse, error)
AtomicCompareAndSwap(context.Context, *AtomicCompareAndSwapRequest) (*AtomicCompareAndSwapResponse, error)
// contains filtered or unexported methods
}
AtomicServer is the server API for Atomic service. All implementations must embed UnimplementedAtomicServer for forward compatibility.
type AtomicStoreRequest ¶
type AtomicStoreRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Val int64 `protobuf:"varint,2,opt,name=val,proto3" json:"val,omitempty"`
// contains filtered or unexported fields
}
func (*AtomicStoreRequest) Descriptor
deprecated
func (*AtomicStoreRequest) Descriptor() ([]byte, []int)
Deprecated: Use AtomicStoreRequest.ProtoReflect.Descriptor instead.
func (*AtomicStoreRequest) GetName ¶
func (x *AtomicStoreRequest) GetName() string
func (*AtomicStoreRequest) GetVal ¶
func (x *AtomicStoreRequest) GetVal() int64
func (*AtomicStoreRequest) ProtoMessage ¶
func (*AtomicStoreRequest) ProtoMessage()
func (*AtomicStoreRequest) ProtoReflect ¶
func (x *AtomicStoreRequest) ProtoReflect() protoreflect.Message
func (*AtomicStoreRequest) Reset ¶
func (x *AtomicStoreRequest) Reset()
func (*AtomicStoreRequest) String ¶
func (x *AtomicStoreRequest) String() string
type AtomicStoreResponse ¶
type AtomicStoreResponse struct {
// contains filtered or unexported fields
}
func (*AtomicStoreResponse) Descriptor
deprecated
func (*AtomicStoreResponse) Descriptor() ([]byte, []int)
Deprecated: Use AtomicStoreResponse.ProtoReflect.Descriptor instead.
func (*AtomicStoreResponse) ProtoMessage ¶
func (*AtomicStoreResponse) ProtoMessage()
func (*AtomicStoreResponse) ProtoReflect ¶
func (x *AtomicStoreResponse) ProtoReflect() protoreflect.Message
func (*AtomicStoreResponse) Reset ¶
func (x *AtomicStoreResponse) Reset()
func (*AtomicStoreResponse) String ¶
func (x *AtomicStoreResponse) String() string
type AtomicSwapRequest ¶
type AtomicSwapRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
New int64 `protobuf:"varint,2,opt,name=new,proto3" json:"new,omitempty"`
// contains filtered or unexported fields
}
func (*AtomicSwapRequest) Descriptor
deprecated
func (*AtomicSwapRequest) Descriptor() ([]byte, []int)
Deprecated: Use AtomicSwapRequest.ProtoReflect.Descriptor instead.
func (*AtomicSwapRequest) GetName ¶
func (x *AtomicSwapRequest) GetName() string
func (*AtomicSwapRequest) GetNew ¶
func (x *AtomicSwapRequest) GetNew() int64
func (*AtomicSwapRequest) ProtoMessage ¶
func (*AtomicSwapRequest) ProtoMessage()
func (*AtomicSwapRequest) ProtoReflect ¶
func (x *AtomicSwapRequest) ProtoReflect() protoreflect.Message
func (*AtomicSwapRequest) Reset ¶
func (x *AtomicSwapRequest) Reset()
func (*AtomicSwapRequest) String ¶
func (x *AtomicSwapRequest) String() string
type AtomicSwapResponse ¶
type AtomicSwapResponse struct {
Old int64 `protobuf:"varint,1,opt,name=old,proto3" json:"old,omitempty"`
// contains filtered or unexported fields
}
func (*AtomicSwapResponse) Descriptor
deprecated
func (*AtomicSwapResponse) Descriptor() ([]byte, []int)
Deprecated: Use AtomicSwapResponse.ProtoReflect.Descriptor instead.
func (*AtomicSwapResponse) GetOld ¶
func (x *AtomicSwapResponse) GetOld() int64
func (*AtomicSwapResponse) ProtoMessage ¶
func (*AtomicSwapResponse) ProtoMessage()
func (*AtomicSwapResponse) ProtoReflect ¶
func (x *AtomicSwapResponse) ProtoReflect() protoreflect.Message
func (*AtomicSwapResponse) Reset ¶
func (x *AtomicSwapResponse) Reset()
func (*AtomicSwapResponse) String ¶
func (x *AtomicSwapResponse) String() string
type CacheClient ¶
type CacheClient interface {
CacheSet(ctx context.Context, in *CacheSetRequest, opts ...grpc.CallOption) (*CacheSetResponse, error)
CacheGet(ctx context.Context, in *CacheGetRequest, opts ...grpc.CallOption) (*CacheGetResponse, error)
CacheDel(ctx context.Context, in *CacheDelRequest, opts ...grpc.CallOption) (*CacheDelResponse, error)
CacheKeys(ctx context.Context, in *CacheKeysRequest, opts ...grpc.CallOption) (*CacheKeysResponse, error)
CacheCount(ctx context.Context, in *CacheCountRequest, opts ...grpc.CallOption) (*CacheCountResponse, error)
CacheItems(ctx context.Context, in *CacheItemsRequest, opts ...grpc.CallOption) (*CacheItemsResponse, error)
CacheFlush(ctx context.Context, in *CacheFlushRequest, opts ...grpc.CallOption) (*CacheFlushResponse, error)
CacheExists(ctx context.Context, in *CacheExistsRequest, opts ...grpc.CallOption) (*CacheExistsResponse, error)
}
CacheClient is the client API for Cache 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.
github.com/patrickmn/go-cache
func NewCacheClient ¶
func NewCacheClient(cc grpc.ClientConnInterface) CacheClient
type CacheCountRequest ¶
type CacheCountRequest struct {
Ns string `protobuf:"bytes,1,opt,name=ns,proto3" json:"ns,omitempty"`
// contains filtered or unexported fields
}
func (*CacheCountRequest) Descriptor
deprecated
func (*CacheCountRequest) Descriptor() ([]byte, []int)
Deprecated: Use CacheCountRequest.ProtoReflect.Descriptor instead.
func (*CacheCountRequest) GetNs ¶
func (x *CacheCountRequest) GetNs() string
func (*CacheCountRequest) ProtoMessage ¶
func (*CacheCountRequest) ProtoMessage()
func (*CacheCountRequest) ProtoReflect ¶
func (x *CacheCountRequest) ProtoReflect() protoreflect.Message
func (*CacheCountRequest) Reset ¶
func (x *CacheCountRequest) Reset()
func (*CacheCountRequest) String ¶
func (x *CacheCountRequest) String() string
type CacheCountResponse ¶
type CacheCountResponse struct {
Count uint64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
// contains filtered or unexported fields
}
func (*CacheCountResponse) Descriptor
deprecated
func (*CacheCountResponse) Descriptor() ([]byte, []int)
Deprecated: Use CacheCountResponse.ProtoReflect.Descriptor instead.
func (*CacheCountResponse) GetCount ¶
func (x *CacheCountResponse) GetCount() uint64
func (*CacheCountResponse) ProtoMessage ¶
func (*CacheCountResponse) ProtoMessage()
func (*CacheCountResponse) ProtoReflect ¶
func (x *CacheCountResponse) ProtoReflect() protoreflect.Message
func (*CacheCountResponse) Reset ¶
func (x *CacheCountResponse) Reset()
func (*CacheCountResponse) String ¶
func (x *CacheCountResponse) String() string
type CacheDelRequest ¶
type CacheDelRequest struct {
Ns string `protobuf:"bytes,1,opt,name=ns,proto3" json:"ns,omitempty"`
Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
// contains filtered or unexported fields
}
func (*CacheDelRequest) Descriptor
deprecated
func (*CacheDelRequest) Descriptor() ([]byte, []int)
Deprecated: Use CacheDelRequest.ProtoReflect.Descriptor instead.
func (*CacheDelRequest) GetKey ¶
func (x *CacheDelRequest) GetKey() string
func (*CacheDelRequest) GetNs ¶
func (x *CacheDelRequest) GetNs() string
func (*CacheDelRequest) ProtoMessage ¶
func (*CacheDelRequest) ProtoMessage()
func (*CacheDelRequest) ProtoReflect ¶
func (x *CacheDelRequest) ProtoReflect() protoreflect.Message
func (*CacheDelRequest) Reset ¶
func (x *CacheDelRequest) Reset()
func (*CacheDelRequest) String ¶
func (x *CacheDelRequest) String() string
type CacheDelResponse ¶
type CacheDelResponse struct {
// contains filtered or unexported fields
}
func (*CacheDelResponse) Descriptor
deprecated
func (*CacheDelResponse) Descriptor() ([]byte, []int)
Deprecated: Use CacheDelResponse.ProtoReflect.Descriptor instead.
func (*CacheDelResponse) ProtoMessage ¶
func (*CacheDelResponse) ProtoMessage()
func (*CacheDelResponse) ProtoReflect ¶
func (x *CacheDelResponse) ProtoReflect() protoreflect.Message
func (*CacheDelResponse) Reset ¶
func (x *CacheDelResponse) Reset()
func (*CacheDelResponse) String ¶
func (x *CacheDelResponse) String() string
type CacheExistsRequest ¶
type CacheExistsRequest struct {
Ns string `protobuf:"bytes,1,opt,name=ns,proto3" json:"ns,omitempty"`
Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
// contains filtered or unexported fields
}
func (*CacheExistsRequest) Descriptor
deprecated
func (*CacheExistsRequest) Descriptor() ([]byte, []int)
Deprecated: Use CacheExistsRequest.ProtoReflect.Descriptor instead.
func (*CacheExistsRequest) GetKey ¶
func (x *CacheExistsRequest) GetKey() string
func (*CacheExistsRequest) GetNs ¶
func (x *CacheExistsRequest) GetNs() string
func (*CacheExistsRequest) ProtoMessage ¶
func (*CacheExistsRequest) ProtoMessage()
func (*CacheExistsRequest) ProtoReflect ¶
func (x *CacheExistsRequest) ProtoReflect() protoreflect.Message
func (*CacheExistsRequest) Reset ¶
func (x *CacheExistsRequest) Reset()
func (*CacheExistsRequest) String ¶
func (x *CacheExistsRequest) String() string
type CacheExistsResponse ¶
type CacheExistsResponse struct {
Found bool `protobuf:"varint,1,opt,name=found,proto3" json:"found,omitempty"`
// contains filtered or unexported fields
}
func (*CacheExistsResponse) Descriptor
deprecated
func (*CacheExistsResponse) Descriptor() ([]byte, []int)
Deprecated: Use CacheExistsResponse.ProtoReflect.Descriptor instead.
func (*CacheExistsResponse) GetFound ¶
func (x *CacheExistsResponse) GetFound() bool
func (*CacheExistsResponse) ProtoMessage ¶
func (*CacheExistsResponse) ProtoMessage()
func (*CacheExistsResponse) ProtoReflect ¶
func (x *CacheExistsResponse) ProtoReflect() protoreflect.Message
func (*CacheExistsResponse) Reset ¶
func (x *CacheExistsResponse) Reset()
func (*CacheExistsResponse) String ¶
func (x *CacheExistsResponse) String() string
type CacheFlushRequest ¶
type CacheFlushRequest struct {
Ns string `protobuf:"bytes,1,opt,name=ns,proto3" json:"ns,omitempty"`
// contains filtered or unexported fields
}
func (*CacheFlushRequest) Descriptor
deprecated
func (*CacheFlushRequest) Descriptor() ([]byte, []int)
Deprecated: Use CacheFlushRequest.ProtoReflect.Descriptor instead.
func (*CacheFlushRequest) GetNs ¶
func (x *CacheFlushRequest) GetNs() string
func (*CacheFlushRequest) ProtoMessage ¶
func (*CacheFlushRequest) ProtoMessage()
func (*CacheFlushRequest) ProtoReflect ¶
func (x *CacheFlushRequest) ProtoReflect() protoreflect.Message
func (*CacheFlushRequest) Reset ¶
func (x *CacheFlushRequest) Reset()
func (*CacheFlushRequest) String ¶
func (x *CacheFlushRequest) String() string
type CacheFlushResponse ¶
type CacheFlushResponse struct {
// contains filtered or unexported fields
}
func (*CacheFlushResponse) Descriptor
deprecated
func (*CacheFlushResponse) Descriptor() ([]byte, []int)
Deprecated: Use CacheFlushResponse.ProtoReflect.Descriptor instead.
func (*CacheFlushResponse) ProtoMessage ¶
func (*CacheFlushResponse) ProtoMessage()
func (*CacheFlushResponse) ProtoReflect ¶
func (x *CacheFlushResponse) ProtoReflect() protoreflect.Message
func (*CacheFlushResponse) Reset ¶
func (x *CacheFlushResponse) Reset()
func (*CacheFlushResponse) String ¶
func (x *CacheFlushResponse) String() string
type CacheGetRequest ¶
type CacheGetRequest struct {
Ns string `protobuf:"bytes,1,opt,name=ns,proto3" json:"ns,omitempty"`
Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
// contains filtered or unexported fields
}
func (*CacheGetRequest) Descriptor
deprecated
func (*CacheGetRequest) Descriptor() ([]byte, []int)
Deprecated: Use CacheGetRequest.ProtoReflect.Descriptor instead.
func (*CacheGetRequest) GetKey ¶
func (x *CacheGetRequest) GetKey() string
func (*CacheGetRequest) GetNs ¶
func (x *CacheGetRequest) GetNs() string
func (*CacheGetRequest) ProtoMessage ¶
func (*CacheGetRequest) ProtoMessage()
func (*CacheGetRequest) ProtoReflect ¶
func (x *CacheGetRequest) ProtoReflect() protoreflect.Message
func (*CacheGetRequest) Reset ¶
func (x *CacheGetRequest) Reset()
func (*CacheGetRequest) String ¶
func (x *CacheGetRequest) String() string
type CacheGetResponse ¶
type CacheGetResponse struct {
Found bool `protobuf:"varint,1,opt,name=found,proto3" json:"found,omitempty"`
Val []byte `protobuf:"bytes,2,opt,name=val,proto3" json:"val,omitempty"`
// contains filtered or unexported fields
}
func (*CacheGetResponse) Descriptor
deprecated
func (*CacheGetResponse) Descriptor() ([]byte, []int)
Deprecated: Use CacheGetResponse.ProtoReflect.Descriptor instead.
func (*CacheGetResponse) GetFound ¶
func (x *CacheGetResponse) GetFound() bool
func (*CacheGetResponse) GetVal ¶
func (x *CacheGetResponse) GetVal() []byte
func (*CacheGetResponse) ProtoMessage ¶
func (*CacheGetResponse) ProtoMessage()
func (*CacheGetResponse) ProtoReflect ¶
func (x *CacheGetResponse) ProtoReflect() protoreflect.Message
func (*CacheGetResponse) Reset ¶
func (x *CacheGetResponse) Reset()
func (*CacheGetResponse) String ¶
func (x *CacheGetResponse) String() string
type CacheItemsRequest ¶
type CacheItemsRequest struct {
Ns string `protobuf:"bytes,1,opt,name=ns,proto3" json:"ns,omitempty"`
// contains filtered or unexported fields
}
func (*CacheItemsRequest) Descriptor
deprecated
func (*CacheItemsRequest) Descriptor() ([]byte, []int)
Deprecated: Use CacheItemsRequest.ProtoReflect.Descriptor instead.
func (*CacheItemsRequest) GetNs ¶
func (x *CacheItemsRequest) GetNs() string
func (*CacheItemsRequest) ProtoMessage ¶
func (*CacheItemsRequest) ProtoMessage()
func (*CacheItemsRequest) ProtoReflect ¶
func (x *CacheItemsRequest) ProtoReflect() protoreflect.Message
func (*CacheItemsRequest) Reset ¶
func (x *CacheItemsRequest) Reset()
func (*CacheItemsRequest) String ¶
func (x *CacheItemsRequest) String() string
type CacheItemsResponse ¶
type CacheItemsResponse struct {
Items map[string][]byte `` /* 151-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*CacheItemsResponse) Descriptor
deprecated
func (*CacheItemsResponse) Descriptor() ([]byte, []int)
Deprecated: Use CacheItemsResponse.ProtoReflect.Descriptor instead.
func (*CacheItemsResponse) GetItems ¶
func (x *CacheItemsResponse) GetItems() map[string][]byte
func (*CacheItemsResponse) ProtoMessage ¶
func (*CacheItemsResponse) ProtoMessage()
func (*CacheItemsResponse) ProtoReflect ¶
func (x *CacheItemsResponse) ProtoReflect() protoreflect.Message
func (*CacheItemsResponse) Reset ¶
func (x *CacheItemsResponse) Reset()
func (*CacheItemsResponse) String ¶
func (x *CacheItemsResponse) String() string
type CacheKeysRequest ¶
type CacheKeysRequest struct {
Ns string `protobuf:"bytes,1,opt,name=ns,proto3" json:"ns,omitempty"`
// contains filtered or unexported fields
}
func (*CacheKeysRequest) Descriptor
deprecated
func (*CacheKeysRequest) Descriptor() ([]byte, []int)
Deprecated: Use CacheKeysRequest.ProtoReflect.Descriptor instead.
func (*CacheKeysRequest) GetNs ¶
func (x *CacheKeysRequest) GetNs() string
func (*CacheKeysRequest) ProtoMessage ¶
func (*CacheKeysRequest) ProtoMessage()
func (*CacheKeysRequest) ProtoReflect ¶
func (x *CacheKeysRequest) ProtoReflect() protoreflect.Message
func (*CacheKeysRequest) Reset ¶
func (x *CacheKeysRequest) Reset()
func (*CacheKeysRequest) String ¶
func (x *CacheKeysRequest) String() string
type CacheKeysResponse ¶
type CacheKeysResponse struct {
Keys []string `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
// contains filtered or unexported fields
}
func (*CacheKeysResponse) Descriptor
deprecated
func (*CacheKeysResponse) Descriptor() ([]byte, []int)
Deprecated: Use CacheKeysResponse.ProtoReflect.Descriptor instead.
func (*CacheKeysResponse) GetKeys ¶
func (x *CacheKeysResponse) GetKeys() []string
func (*CacheKeysResponse) ProtoMessage ¶
func (*CacheKeysResponse) ProtoMessage()
func (*CacheKeysResponse) ProtoReflect ¶
func (x *CacheKeysResponse) ProtoReflect() protoreflect.Message
func (*CacheKeysResponse) Reset ¶
func (x *CacheKeysResponse) Reset()
func (*CacheKeysResponse) String ¶
func (x *CacheKeysResponse) String() string
type CacheServer ¶
type CacheServer interface {
CacheSet(context.Context, *CacheSetRequest) (*CacheSetResponse, error)
CacheGet(context.Context, *CacheGetRequest) (*CacheGetResponse, error)
CacheDel(context.Context, *CacheDelRequest) (*CacheDelResponse, error)
CacheKeys(context.Context, *CacheKeysRequest) (*CacheKeysResponse, error)
CacheCount(context.Context, *CacheCountRequest) (*CacheCountResponse, error)
CacheItems(context.Context, *CacheItemsRequest) (*CacheItemsResponse, error)
CacheFlush(context.Context, *CacheFlushRequest) (*CacheFlushResponse, error)
CacheExists(context.Context, *CacheExistsRequest) (*CacheExistsResponse, error)
// contains filtered or unexported methods
}
CacheServer is the server API for Cache service. All implementations must embed UnimplementedCacheServer for forward compatibility.
github.com/patrickmn/go-cache
type CacheSetRequest ¶
type CacheSetRequest struct {
Ns string `protobuf:"bytes,1,opt,name=ns,proto3" json:"ns,omitempty"`
Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
Ttl uint64 `protobuf:"varint,3,opt,name=ttl,proto3" json:"ttl,omitempty"` // ms
Val []byte `protobuf:"bytes,4,opt,name=val,proto3" json:"val,omitempty"`
// contains filtered or unexported fields
}
func (*CacheSetRequest) Descriptor
deprecated
func (*CacheSetRequest) Descriptor() ([]byte, []int)
Deprecated: Use CacheSetRequest.ProtoReflect.Descriptor instead.
func (*CacheSetRequest) GetKey ¶
func (x *CacheSetRequest) GetKey() string
func (*CacheSetRequest) GetNs ¶
func (x *CacheSetRequest) GetNs() string
func (*CacheSetRequest) GetTtl ¶
func (x *CacheSetRequest) GetTtl() uint64
func (*CacheSetRequest) GetVal ¶
func (x *CacheSetRequest) GetVal() []byte
func (*CacheSetRequest) ProtoMessage ¶
func (*CacheSetRequest) ProtoMessage()
func (*CacheSetRequest) ProtoReflect ¶
func (x *CacheSetRequest) ProtoReflect() protoreflect.Message
func (*CacheSetRequest) Reset ¶
func (x *CacheSetRequest) Reset()
func (*CacheSetRequest) String ¶
func (x *CacheSetRequest) String() string
type CacheSetResponse ¶
type CacheSetResponse struct {
// contains filtered or unexported fields
}
func (*CacheSetResponse) Descriptor
deprecated
func (*CacheSetResponse) Descriptor() ([]byte, []int)
Deprecated: Use CacheSetResponse.ProtoReflect.Descriptor instead.
func (*CacheSetResponse) ProtoMessage ¶
func (*CacheSetResponse) ProtoMessage()
func (*CacheSetResponse) ProtoReflect ¶
func (x *CacheSetResponse) ProtoReflect() protoreflect.Message
func (*CacheSetResponse) Reset ¶
func (x *CacheSetResponse) Reset()
func (*CacheSetResponse) String ¶
func (x *CacheSetResponse) String() string
type CloseSocketRequest ¶
type CloseSocketRequest struct {
Network string `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"`
Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
// contains filtered or unexported fields
}
func (*CloseSocketRequest) Descriptor
deprecated
func (*CloseSocketRequest) Descriptor() ([]byte, []int)
Deprecated: Use CloseSocketRequest.ProtoReflect.Descriptor instead.
func (*CloseSocketRequest) GetAddress ¶
func (x *CloseSocketRequest) GetAddress() string
func (*CloseSocketRequest) GetNetwork ¶
func (x *CloseSocketRequest) GetNetwork() string
func (*CloseSocketRequest) ProtoMessage ¶
func (*CloseSocketRequest) ProtoMessage()
func (*CloseSocketRequest) ProtoReflect ¶
func (x *CloseSocketRequest) ProtoReflect() protoreflect.Message
func (*CloseSocketRequest) Reset ¶
func (x *CloseSocketRequest) Reset()
func (*CloseSocketRequest) String ¶
func (x *CloseSocketRequest) String() string
type CloseSocketResponse ¶
type CloseSocketResponse struct {
Code CloseSocketResponse_Code `protobuf:"varint,1,opt,name=code,proto3,enum=xiao.ally.CloseSocketResponse_Code" json:"code,omitempty"`
Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*CloseSocketResponse) Descriptor
deprecated
func (*CloseSocketResponse) Descriptor() ([]byte, []int)
Deprecated: Use CloseSocketResponse.ProtoReflect.Descriptor instead.
func (*CloseSocketResponse) GetCode ¶
func (x *CloseSocketResponse) GetCode() CloseSocketResponse_Code
func (*CloseSocketResponse) GetError ¶
func (x *CloseSocketResponse) GetError() string
func (*CloseSocketResponse) ProtoMessage ¶
func (*CloseSocketResponse) ProtoMessage()
func (*CloseSocketResponse) ProtoReflect ¶
func (x *CloseSocketResponse) ProtoReflect() protoreflect.Message
func (*CloseSocketResponse) Reset ¶
func (x *CloseSocketResponse) Reset()
func (*CloseSocketResponse) String ¶
func (x *CloseSocketResponse) String() string
type CloseSocketResponse_Code ¶
type CloseSocketResponse_Code int32
const ( CloseSocketResponse_EC_OK CloseSocketResponse_Code = 0 CloseSocketResponse_EC_PERMISSION CloseSocketResponse_Code = 1 // 仅允许app实例访问此接口 CloseSocketResponse_EC_BAD_ADDRESS CloseSocketResponse_Code = 2 // 地址格式问题 )
func (CloseSocketResponse_Code) Descriptor ¶
func (CloseSocketResponse_Code) Descriptor() protoreflect.EnumDescriptor
func (CloseSocketResponse_Code) Enum ¶
func (x CloseSocketResponse_Code) Enum() *CloseSocketResponse_Code
func (CloseSocketResponse_Code) EnumDescriptor
deprecated
func (CloseSocketResponse_Code) EnumDescriptor() ([]byte, []int)
Deprecated: Use CloseSocketResponse_Code.Descriptor instead.
func (CloseSocketResponse_Code) Number ¶
func (x CloseSocketResponse_Code) Number() protoreflect.EnumNumber
func (CloseSocketResponse_Code) String ¶
func (x CloseSocketResponse_Code) String() string
func (CloseSocketResponse_Code) Type ¶
func (CloseSocketResponse_Code) Type() protoreflect.EnumType
type GetAppInfoRequest ¶
type GetAppInfoRequest struct {
// contains filtered or unexported fields
}
func (*GetAppInfoRequest) Descriptor
deprecated
func (*GetAppInfoRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetAppInfoRequest.ProtoReflect.Descriptor instead.
func (*GetAppInfoRequest) ProtoMessage ¶
func (*GetAppInfoRequest) ProtoMessage()
func (*GetAppInfoRequest) ProtoReflect ¶
func (x *GetAppInfoRequest) ProtoReflect() protoreflect.Message
func (*GetAppInfoRequest) Reset ¶
func (x *GetAppInfoRequest) Reset()
func (*GetAppInfoRequest) String ¶
func (x *GetAppInfoRequest) String() string
type GetAppInfoResponse ¶
type GetAppInfoResponse struct {
Pid uint64 `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"` // ally的pid
Cpu float64 `protobuf:"fixed64,2,opt,name=cpu,proto3" json:"cpu,omitempty"` // ally的cpu实时使用率
Ram float64 `protobuf:"fixed64,3,opt,name=ram,proto3" json:"ram,omitempty"` // ally的内存实时使用量,Bytes
Sock string `protobuf:"bytes,4,opt,name=sock,proto3" json:"sock,omitempty"` // ally sock的路径
Commit string `protobuf:"bytes,5,opt,name=commit,proto3" json:"commit,omitempty"` // ally的版本commit信息
Version string `protobuf:"bytes,6,opt,name=version,proto3" json:"version,omitempty"` // ally的版本号
StartTime int64 `protobuf:"varint,7,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` // ally的启动时间戳(纳秒)
Info *AppInfo `protobuf:"bytes,8,opt,name=info,proto3" json:"info,omitempty"` // app信息
// contains filtered or unexported fields
}
func (*GetAppInfoResponse) Descriptor
deprecated
func (*GetAppInfoResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetAppInfoResponse.ProtoReflect.Descriptor instead.
func (*GetAppInfoResponse) GetCommit ¶
func (x *GetAppInfoResponse) GetCommit() string
func (*GetAppInfoResponse) GetCpu ¶
func (x *GetAppInfoResponse) GetCpu() float64
func (*GetAppInfoResponse) GetInfo ¶
func (x *GetAppInfoResponse) GetInfo() *AppInfo
func (*GetAppInfoResponse) GetPid ¶
func (x *GetAppInfoResponse) GetPid() uint64
func (*GetAppInfoResponse) GetRam ¶
func (x *GetAppInfoResponse) GetRam() float64
func (*GetAppInfoResponse) GetSock ¶
func (x *GetAppInfoResponse) GetSock() string
func (*GetAppInfoResponse) GetStartTime ¶
func (x *GetAppInfoResponse) GetStartTime() int64
func (*GetAppInfoResponse) GetVersion ¶
func (x *GetAppInfoResponse) GetVersion() string
func (*GetAppInfoResponse) ProtoMessage ¶
func (*GetAppInfoResponse) ProtoMessage()
func (*GetAppInfoResponse) ProtoReflect ¶
func (x *GetAppInfoResponse) ProtoReflect() protoreflect.Message
func (*GetAppInfoResponse) Reset ¶
func (x *GetAppInfoResponse) Reset()
func (*GetAppInfoResponse) String ¶
func (x *GetAppInfoResponse) String() string
type GetInstanceInfoRequest ¶
type GetInstanceInfoRequest struct {
// contains filtered or unexported fields
}
获取本实例的信息
func (*GetInstanceInfoRequest) Descriptor
deprecated
func (*GetInstanceInfoRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetInstanceInfoRequest.ProtoReflect.Descriptor instead.
func (*GetInstanceInfoRequest) ProtoMessage ¶
func (*GetInstanceInfoRequest) ProtoMessage()
func (*GetInstanceInfoRequest) ProtoReflect ¶
func (x *GetInstanceInfoRequest) ProtoReflect() protoreflect.Message
func (*GetInstanceInfoRequest) Reset ¶
func (x *GetInstanceInfoRequest) Reset()
func (*GetInstanceInfoRequest) String ¶
func (x *GetInstanceInfoRequest) String() string
type GetInstanceInfoResponse ¶
type GetInstanceInfoResponse struct {
Code GetInstanceInfoResponse_Code `protobuf:"varint,1,opt,name=code,proto3,enum=xiao.ally.GetInstanceInfoResponse_Code" json:"code,omitempty"`
Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
Info *InstanceInfo `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
// contains filtered or unexported fields
}
func (*GetInstanceInfoResponse) Descriptor
deprecated
func (*GetInstanceInfoResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetInstanceInfoResponse.ProtoReflect.Descriptor instead.
func (*GetInstanceInfoResponse) GetCode ¶
func (x *GetInstanceInfoResponse) GetCode() GetInstanceInfoResponse_Code
func (*GetInstanceInfoResponse) GetError ¶
func (x *GetInstanceInfoResponse) GetError() string
func (*GetInstanceInfoResponse) GetInfo ¶
func (x *GetInstanceInfoResponse) GetInfo() *InstanceInfo
func (*GetInstanceInfoResponse) ProtoMessage ¶
func (*GetInstanceInfoResponse) ProtoMessage()
func (*GetInstanceInfoResponse) ProtoReflect ¶
func (x *GetInstanceInfoResponse) ProtoReflect() protoreflect.Message
func (*GetInstanceInfoResponse) Reset ¶
func (x *GetInstanceInfoResponse) Reset()
func (*GetInstanceInfoResponse) String ¶
func (x *GetInstanceInfoResponse) String() string
type GetInstanceInfoResponse_Code ¶
type GetInstanceInfoResponse_Code int32
const ( GetInstanceInfoResponse_EC_OK GetInstanceInfoResponse_Code = 0 GetInstanceInfoResponse_EC_PERMISSION GetInstanceInfoResponse_Code = 1 // 仅允许app实例访问此接口 )
func (GetInstanceInfoResponse_Code) Descriptor ¶
func (GetInstanceInfoResponse_Code) Descriptor() protoreflect.EnumDescriptor
func (GetInstanceInfoResponse_Code) Enum ¶
func (x GetInstanceInfoResponse_Code) Enum() *GetInstanceInfoResponse_Code
func (GetInstanceInfoResponse_Code) EnumDescriptor
deprecated
func (GetInstanceInfoResponse_Code) EnumDescriptor() ([]byte, []int)
Deprecated: Use GetInstanceInfoResponse_Code.Descriptor instead.
func (GetInstanceInfoResponse_Code) Number ¶
func (x GetInstanceInfoResponse_Code) Number() protoreflect.EnumNumber
func (GetInstanceInfoResponse_Code) String ¶
func (x GetInstanceInfoResponse_Code) String() string
func (GetInstanceInfoResponse_Code) Type ¶
func (GetInstanceInfoResponse_Code) Type() protoreflect.EnumType
type HeartbeatRequest ¶
type HeartbeatRequest struct {
Ready bool `protobuf:"varint,1,opt,name=ready,proto3" json:"ready,omitempty"`
Tasks uint64 `protobuf:"varint,2,opt,name=tasks,proto3" json:"tasks,omitempty"`
Commit string `protobuf:"bytes,3,opt,name=commit,proto3" json:"commit,omitempty"`
Version string `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
// contains filtered or unexported fields
}
func (*HeartbeatRequest) Descriptor
deprecated
func (*HeartbeatRequest) Descriptor() ([]byte, []int)
Deprecated: Use HeartbeatRequest.ProtoReflect.Descriptor instead.
func (*HeartbeatRequest) GetCommit ¶
func (x *HeartbeatRequest) GetCommit() string
func (*HeartbeatRequest) GetDescription ¶
func (x *HeartbeatRequest) GetDescription() string
func (*HeartbeatRequest) GetReady ¶
func (x *HeartbeatRequest) GetReady() bool
func (*HeartbeatRequest) GetTasks ¶
func (x *HeartbeatRequest) GetTasks() uint64
func (*HeartbeatRequest) GetVersion ¶
func (x *HeartbeatRequest) GetVersion() string
func (*HeartbeatRequest) ProtoMessage ¶
func (*HeartbeatRequest) ProtoMessage()
func (*HeartbeatRequest) ProtoReflect ¶
func (x *HeartbeatRequest) ProtoReflect() protoreflect.Message
func (*HeartbeatRequest) Reset ¶
func (x *HeartbeatRequest) Reset()
func (*HeartbeatRequest) String ¶
func (x *HeartbeatRequest) String() string
type HeartbeatResponse ¶
type HeartbeatResponse struct {
Code HeartbeatResponse_Code `protobuf:"varint,1,opt,name=code,proto3,enum=xiao.ally.HeartbeatResponse_Code" json:"code,omitempty"`
Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*HeartbeatResponse) Descriptor
deprecated
func (*HeartbeatResponse) Descriptor() ([]byte, []int)
Deprecated: Use HeartbeatResponse.ProtoReflect.Descriptor instead.
func (*HeartbeatResponse) GetCode ¶
func (x *HeartbeatResponse) GetCode() HeartbeatResponse_Code
func (*HeartbeatResponse) GetError ¶
func (x *HeartbeatResponse) GetError() string
func (*HeartbeatResponse) ProtoMessage ¶
func (*HeartbeatResponse) ProtoMessage()
func (*HeartbeatResponse) ProtoReflect ¶
func (x *HeartbeatResponse) ProtoReflect() protoreflect.Message
func (*HeartbeatResponse) Reset ¶
func (x *HeartbeatResponse) Reset()
func (*HeartbeatResponse) String ¶
func (x *HeartbeatResponse) String() string
type HeartbeatResponse_Code ¶
type HeartbeatResponse_Code int32
const ( HeartbeatResponse_EC_OK HeartbeatResponse_Code = 0 HeartbeatResponse_EC_PERMISSION HeartbeatResponse_Code = 1 // 仅允许app实例访问此接口 )
func (HeartbeatResponse_Code) Descriptor ¶
func (HeartbeatResponse_Code) Descriptor() protoreflect.EnumDescriptor
func (HeartbeatResponse_Code) Enum ¶
func (x HeartbeatResponse_Code) Enum() *HeartbeatResponse_Code
func (HeartbeatResponse_Code) EnumDescriptor
deprecated
func (HeartbeatResponse_Code) EnumDescriptor() ([]byte, []int)
Deprecated: Use HeartbeatResponse_Code.Descriptor instead.
func (HeartbeatResponse_Code) Number ¶
func (x HeartbeatResponse_Code) Number() protoreflect.EnumNumber
func (HeartbeatResponse_Code) String ¶
func (x HeartbeatResponse_Code) String() string
func (HeartbeatResponse_Code) Type ¶
func (HeartbeatResponse_Code) Type() protoreflect.EnumType
type InstanceInfo ¶
type InstanceInfo struct {
Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` // app实例的id序列,总是从1开始,每次reload递增1
Pid uint64 `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"` // app实例的pid
Cpu float64 `protobuf:"fixed64,3,opt,name=cpu,proto3" json:"cpu,omitempty"` // app实例的cpu实时使用率
Ram float64 `protobuf:"fixed64,4,opt,name=ram,proto3" json:"ram,omitempty"` // app实例的内存实时使用量,Bytes
Appname string `protobuf:"bytes,5,opt,name=appname,proto3" json:"appname,omitempty"` // app的名称
Family string `protobuf:"bytes,6,opt,name=family,proto3" json:"family,omitempty"` // app的家族
StartTime int64 `protobuf:"varint,7,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` // app实例的启动时间戳(纳秒)
Tasks uint64 `protobuf:"varint,8,opt,name=tasks,proto3" json:"tasks,omitempty"` // app实例上报不可中断的任务数量
Commit string `protobuf:"bytes,9,opt,name=commit,proto3" json:"commit,omitempty"` // app实例上报的版本commit
Version string `protobuf:"bytes,10,opt,name=version,proto3" json:"version,omitempty"` // app实例上报的版本号
Description string `protobuf:"bytes,11,opt,name=description,proto3" json:"description,omitempty"` // app实例上报的动态描述文字
Stat InstanceStat_Enum `protobuf:"varint,12,opt,name=stat,proto3,enum=xiao.ally.InstanceStat_Enum" json:"stat,omitempty"` // app实例的状态
Addresses []*Address `protobuf:"bytes,13,rep,name=addresses,proto3" json:"addresses,omitempty"` // app实例在使用中的地址
// contains filtered or unexported fields
}
func (*InstanceInfo) Descriptor
deprecated
func (*InstanceInfo) Descriptor() ([]byte, []int)
Deprecated: Use InstanceInfo.ProtoReflect.Descriptor instead.
func (*InstanceInfo) GetAddresses ¶
func (x *InstanceInfo) GetAddresses() []*Address
func (*InstanceInfo) GetAppname ¶
func (x *InstanceInfo) GetAppname() string
func (*InstanceInfo) GetCommit ¶
func (x *InstanceInfo) GetCommit() string
func (*InstanceInfo) GetCpu ¶
func (x *InstanceInfo) GetCpu() float64
func (*InstanceInfo) GetDescription ¶
func (x *InstanceInfo) GetDescription() string
func (*InstanceInfo) GetFamily ¶
func (x *InstanceInfo) GetFamily() string
func (*InstanceInfo) GetId ¶
func (x *InstanceInfo) GetId() uint64
func (*InstanceInfo) GetPid ¶
func (x *InstanceInfo) GetPid() uint64
func (*InstanceInfo) GetRam ¶
func (x *InstanceInfo) GetRam() float64
func (*InstanceInfo) GetStartTime ¶
func (x *InstanceInfo) GetStartTime() int64
func (*InstanceInfo) GetStat ¶
func (x *InstanceInfo) GetStat() InstanceStat_Enum
func (*InstanceInfo) GetTasks ¶
func (x *InstanceInfo) GetTasks() uint64
func (*InstanceInfo) GetVersion ¶
func (x *InstanceInfo) GetVersion() string
func (*InstanceInfo) ProtoMessage ¶
func (*InstanceInfo) ProtoMessage()
func (*InstanceInfo) ProtoReflect ¶
func (x *InstanceInfo) ProtoReflect() protoreflect.Message
func (*InstanceInfo) Reset ¶
func (x *InstanceInfo) Reset()
func (*InstanceInfo) String ¶
func (x *InstanceInfo) String() string
type InstanceStat ¶
type InstanceStat struct {
// contains filtered or unexported fields
}
func (*InstanceStat) Descriptor
deprecated
func (*InstanceStat) Descriptor() ([]byte, []int)
Deprecated: Use InstanceStat.ProtoReflect.Descriptor instead.
func (*InstanceStat) ProtoMessage ¶
func (*InstanceStat) ProtoMessage()
func (*InstanceStat) ProtoReflect ¶
func (x *InstanceStat) ProtoReflect() protoreflect.Message
func (*InstanceStat) Reset ¶
func (x *InstanceStat) Reset()
func (*InstanceStat) String ¶
func (x *InstanceStat) String() string
type InstanceStat_Enum ¶
type InstanceStat_Enum int32
const ( InstanceStat_PREPARING InstanceStat_Enum = 0 InstanceStat_RUNNING InstanceStat_Enum = 1 InstanceStat_CLOSING InstanceStat_Enum = 2 )
func (InstanceStat_Enum) Descriptor ¶
func (InstanceStat_Enum) Descriptor() protoreflect.EnumDescriptor
func (InstanceStat_Enum) Enum ¶
func (x InstanceStat_Enum) Enum() *InstanceStat_Enum
func (InstanceStat_Enum) EnumDescriptor
deprecated
func (InstanceStat_Enum) EnumDescriptor() ([]byte, []int)
Deprecated: Use InstanceStat_Enum.Descriptor instead.
func (InstanceStat_Enum) Number ¶
func (x InstanceStat_Enum) Number() protoreflect.EnumNumber
func (InstanceStat_Enum) String ¶
func (x InstanceStat_Enum) String() string
func (InstanceStat_Enum) Type ¶
func (InstanceStat_Enum) Type() protoreflect.EnumType
type ListenSocketRequest ¶
type ListenSocketRequest struct {
Network string `protobuf:"bytes,1,opt,name=network,proto3" json:"network,omitempty"`
Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
// contains filtered or unexported fields
}
func (*ListenSocketRequest) Descriptor
deprecated
func (*ListenSocketRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListenSocketRequest.ProtoReflect.Descriptor instead.
func (*ListenSocketRequest) GetAddress ¶
func (x *ListenSocketRequest) GetAddress() string
func (*ListenSocketRequest) GetNetwork ¶
func (x *ListenSocketRequest) GetNetwork() string
func (*ListenSocketRequest) ProtoMessage ¶
func (*ListenSocketRequest) ProtoMessage()
func (*ListenSocketRequest) ProtoReflect ¶
func (x *ListenSocketRequest) ProtoReflect() protoreflect.Message
func (*ListenSocketRequest) Reset ¶
func (x *ListenSocketRequest) Reset()
func (*ListenSocketRequest) String ¶
func (x *ListenSocketRequest) String() string
type ListenSocketResponse ¶
type ListenSocketResponse struct {
Code ListenSocketResponse_Code `protobuf:"varint,1,opt,name=code,proto3,enum=xiao.ally.ListenSocketResponse_Code" json:"code,omitempty"`
Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*ListenSocketResponse) Descriptor
deprecated
func (*ListenSocketResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListenSocketResponse.ProtoReflect.Descriptor instead.
func (*ListenSocketResponse) GetCode ¶
func (x *ListenSocketResponse) GetCode() ListenSocketResponse_Code
func (*ListenSocketResponse) GetError ¶
func (x *ListenSocketResponse) GetError() string
func (*ListenSocketResponse) ProtoMessage ¶
func (*ListenSocketResponse) ProtoMessage()
func (*ListenSocketResponse) ProtoReflect ¶
func (x *ListenSocketResponse) ProtoReflect() protoreflect.Message
func (*ListenSocketResponse) Reset ¶
func (x *ListenSocketResponse) Reset()
func (*ListenSocketResponse) String ¶
func (x *ListenSocketResponse) String() string
type ListenSocketResponse_Code ¶
type ListenSocketResponse_Code int32
const ( ListenSocketResponse_EC_OK ListenSocketResponse_Code = 0 ListenSocketResponse_EC_PERMISSION ListenSocketResponse_Code = 1 // 仅允许app实例访问此接口 ListenSocketResponse_EC_BAD_ADDRESS ListenSocketResponse_Code = 2 // 地址格式问题 ListenSocketResponse_EC_LISTEN ListenSocketResponse_Code = 3 // listen失败 ListenSocketResponse_EC_SEND ListenSocketResponse_Code = 4 // 发送fd给app失败 )
func (ListenSocketResponse_Code) Descriptor ¶
func (ListenSocketResponse_Code) Descriptor() protoreflect.EnumDescriptor
func (ListenSocketResponse_Code) Enum ¶
func (x ListenSocketResponse_Code) Enum() *ListenSocketResponse_Code
func (ListenSocketResponse_Code) EnumDescriptor
deprecated
func (ListenSocketResponse_Code) EnumDescriptor() ([]byte, []int)
Deprecated: Use ListenSocketResponse_Code.Descriptor instead.
func (ListenSocketResponse_Code) Number ¶
func (x ListenSocketResponse_Code) Number() protoreflect.EnumNumber
func (ListenSocketResponse_Code) String ¶
func (x ListenSocketResponse_Code) String() string
func (ListenSocketResponse_Code) Type ¶
func (ListenSocketResponse_Code) Type() protoreflect.EnumType
type LockerClient ¶
type LockerClient interface {
LockerLock(ctx context.Context, in *LockerLockRequest, opts ...grpc.CallOption) (*LockerLockResponse, error)
LockerRLock(ctx context.Context, in *LockerRLockRequest, opts ...grpc.CallOption) (*LockerRLockResponse, error)
LockerTryLock(ctx context.Context, in *LockerTryLockRequest, opts ...grpc.CallOption) (*LockerTryLockResponse, error)
LockerTryRLock(ctx context.Context, in *LockerTryRLockRequest, opts ...grpc.CallOption) (*LockerTryRLockResponse, error)
LockerUnlock(ctx context.Context, in *LockerUnlockRequest, opts ...grpc.CallOption) (*LockerUnlockResponse, error)
LockerRUnlock(ctx context.Context, in *LockerRUnlockRequest, opts ...grpc.CallOption) (*LockerRUnlockResponse, error)
LockerQueues(ctx context.Context, in *LockerQueuesRequest, opts ...grpc.CallOption) (*LockerQueuesResponse, error)
}
LockerClient is the client API for Locker 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 NewLockerClient ¶
func NewLockerClient(cc grpc.ClientConnInterface) LockerClient
type LockerLockRequest ¶
type LockerLockRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*LockerLockRequest) Descriptor
deprecated
func (*LockerLockRequest) Descriptor() ([]byte, []int)
Deprecated: Use LockerLockRequest.ProtoReflect.Descriptor instead.
func (*LockerLockRequest) GetName ¶
func (x *LockerLockRequest) GetName() string
func (*LockerLockRequest) ProtoMessage ¶
func (*LockerLockRequest) ProtoMessage()
func (*LockerLockRequest) ProtoReflect ¶
func (x *LockerLockRequest) ProtoReflect() protoreflect.Message
func (*LockerLockRequest) Reset ¶
func (x *LockerLockRequest) Reset()
func (*LockerLockRequest) String ¶
func (x *LockerLockRequest) String() string
type LockerLockResponse ¶
type LockerLockResponse struct {
// contains filtered or unexported fields
}
func (*LockerLockResponse) Descriptor
deprecated
func (*LockerLockResponse) Descriptor() ([]byte, []int)
Deprecated: Use LockerLockResponse.ProtoReflect.Descriptor instead.
func (*LockerLockResponse) ProtoMessage ¶
func (*LockerLockResponse) ProtoMessage()
func (*LockerLockResponse) ProtoReflect ¶
func (x *LockerLockResponse) ProtoReflect() protoreflect.Message
func (*LockerLockResponse) Reset ¶
func (x *LockerLockResponse) Reset()
func (*LockerLockResponse) String ¶
func (x *LockerLockResponse) String() string
type LockerQueuesRequest ¶
type LockerQueuesRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*LockerQueuesRequest) Descriptor
deprecated
func (*LockerQueuesRequest) Descriptor() ([]byte, []int)
Deprecated: Use LockerQueuesRequest.ProtoReflect.Descriptor instead.
func (*LockerQueuesRequest) GetName ¶
func (x *LockerQueuesRequest) GetName() string
func (*LockerQueuesRequest) ProtoMessage ¶
func (*LockerQueuesRequest) ProtoMessage()
func (*LockerQueuesRequest) ProtoReflect ¶
func (x *LockerQueuesRequest) ProtoReflect() protoreflect.Message
func (*LockerQueuesRequest) Reset ¶
func (x *LockerQueuesRequest) Reset()
func (*LockerQueuesRequest) String ¶
func (x *LockerQueuesRequest) String() string
type LockerQueuesResponse ¶
type LockerQueuesResponse struct {
R int64 `protobuf:"varint,1,opt,name=r,proto3" json:"r,omitempty"`
W int64 `protobuf:"varint,2,opt,name=w,proto3" json:"w,omitempty"`
// contains filtered or unexported fields
}
func (*LockerQueuesResponse) Descriptor
deprecated
func (*LockerQueuesResponse) Descriptor() ([]byte, []int)
Deprecated: Use LockerQueuesResponse.ProtoReflect.Descriptor instead.
func (*LockerQueuesResponse) GetR ¶
func (x *LockerQueuesResponse) GetR() int64
func (*LockerQueuesResponse) GetW ¶
func (x *LockerQueuesResponse) GetW() int64
func (*LockerQueuesResponse) ProtoMessage ¶
func (*LockerQueuesResponse) ProtoMessage()
func (*LockerQueuesResponse) ProtoReflect ¶
func (x *LockerQueuesResponse) ProtoReflect() protoreflect.Message
func (*LockerQueuesResponse) Reset ¶
func (x *LockerQueuesResponse) Reset()
func (*LockerQueuesResponse) String ¶
func (x *LockerQueuesResponse) String() string
type LockerRLockRequest ¶
type LockerRLockRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*LockerRLockRequest) Descriptor
deprecated
func (*LockerRLockRequest) Descriptor() ([]byte, []int)
Deprecated: Use LockerRLockRequest.ProtoReflect.Descriptor instead.
func (*LockerRLockRequest) GetName ¶
func (x *LockerRLockRequest) GetName() string
func (*LockerRLockRequest) ProtoMessage ¶
func (*LockerRLockRequest) ProtoMessage()
func (*LockerRLockRequest) ProtoReflect ¶
func (x *LockerRLockRequest) ProtoReflect() protoreflect.Message
func (*LockerRLockRequest) Reset ¶
func (x *LockerRLockRequest) Reset()
func (*LockerRLockRequest) String ¶
func (x *LockerRLockRequest) String() string
type LockerRLockResponse ¶
type LockerRLockResponse struct {
// contains filtered or unexported fields
}
func (*LockerRLockResponse) Descriptor
deprecated
func (*LockerRLockResponse) Descriptor() ([]byte, []int)
Deprecated: Use LockerRLockResponse.ProtoReflect.Descriptor instead.
func (*LockerRLockResponse) ProtoMessage ¶
func (*LockerRLockResponse) ProtoMessage()
func (*LockerRLockResponse) ProtoReflect ¶
func (x *LockerRLockResponse) ProtoReflect() protoreflect.Message
func (*LockerRLockResponse) Reset ¶
func (x *LockerRLockResponse) Reset()
func (*LockerRLockResponse) String ¶
func (x *LockerRLockResponse) String() string
type LockerRUnlockRequest ¶
type LockerRUnlockRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*LockerRUnlockRequest) Descriptor
deprecated
func (*LockerRUnlockRequest) Descriptor() ([]byte, []int)
Deprecated: Use LockerRUnlockRequest.ProtoReflect.Descriptor instead.
func (*LockerRUnlockRequest) GetName ¶
func (x *LockerRUnlockRequest) GetName() string
func (*LockerRUnlockRequest) ProtoMessage ¶
func (*LockerRUnlockRequest) ProtoMessage()
func (*LockerRUnlockRequest) ProtoReflect ¶
func (x *LockerRUnlockRequest) ProtoReflect() protoreflect.Message
func (*LockerRUnlockRequest) Reset ¶
func (x *LockerRUnlockRequest) Reset()
func (*LockerRUnlockRequest) String ¶
func (x *LockerRUnlockRequest) String() string
type LockerRUnlockResponse ¶
type LockerRUnlockResponse struct {
// contains filtered or unexported fields
}
func (*LockerRUnlockResponse) Descriptor
deprecated
func (*LockerRUnlockResponse) Descriptor() ([]byte, []int)
Deprecated: Use LockerRUnlockResponse.ProtoReflect.Descriptor instead.
func (*LockerRUnlockResponse) ProtoMessage ¶
func (*LockerRUnlockResponse) ProtoMessage()
func (*LockerRUnlockResponse) ProtoReflect ¶
func (x *LockerRUnlockResponse) ProtoReflect() protoreflect.Message
func (*LockerRUnlockResponse) Reset ¶
func (x *LockerRUnlockResponse) Reset()
func (*LockerRUnlockResponse) String ¶
func (x *LockerRUnlockResponse) String() string
type LockerServer ¶
type LockerServer interface {
LockerLock(context.Context, *LockerLockRequest) (*LockerLockResponse, error)
LockerRLock(context.Context, *LockerRLockRequest) (*LockerRLockResponse, error)
LockerTryLock(context.Context, *LockerTryLockRequest) (*LockerTryLockResponse, error)
LockerTryRLock(context.Context, *LockerTryRLockRequest) (*LockerTryRLockResponse, error)
LockerUnlock(context.Context, *LockerUnlockRequest) (*LockerUnlockResponse, error)
LockerRUnlock(context.Context, *LockerRUnlockRequest) (*LockerRUnlockResponse, error)
LockerQueues(context.Context, *LockerQueuesRequest) (*LockerQueuesResponse, error)
// contains filtered or unexported methods
}
LockerServer is the server API for Locker service. All implementations must embed UnimplementedLockerServer for forward compatibility.
type LockerTryLockRequest ¶
type LockerTryLockRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Timeout uint64 `protobuf:"varint,2,opt,name=timeout,proto3" json:"timeout,omitempty"` // ms
// contains filtered or unexported fields
}
func (*LockerTryLockRequest) Descriptor
deprecated
func (*LockerTryLockRequest) Descriptor() ([]byte, []int)
Deprecated: Use LockerTryLockRequest.ProtoReflect.Descriptor instead.
func (*LockerTryLockRequest) GetName ¶
func (x *LockerTryLockRequest) GetName() string
func (*LockerTryLockRequest) GetTimeout ¶
func (x *LockerTryLockRequest) GetTimeout() uint64
func (*LockerTryLockRequest) ProtoMessage ¶
func (*LockerTryLockRequest) ProtoMessage()
func (*LockerTryLockRequest) ProtoReflect ¶
func (x *LockerTryLockRequest) ProtoReflect() protoreflect.Message
func (*LockerTryLockRequest) Reset ¶
func (x *LockerTryLockRequest) Reset()
func (*LockerTryLockRequest) String ¶
func (x *LockerTryLockRequest) String() string
type LockerTryLockResponse ¶
type LockerTryLockResponse struct {
Acquired bool `protobuf:"varint,1,opt,name=acquired,proto3" json:"acquired,omitempty"`
// contains filtered or unexported fields
}
func (*LockerTryLockResponse) Descriptor
deprecated
func (*LockerTryLockResponse) Descriptor() ([]byte, []int)
Deprecated: Use LockerTryLockResponse.ProtoReflect.Descriptor instead.
func (*LockerTryLockResponse) GetAcquired ¶
func (x *LockerTryLockResponse) GetAcquired() bool
func (*LockerTryLockResponse) ProtoMessage ¶
func (*LockerTryLockResponse) ProtoMessage()
func (*LockerTryLockResponse) ProtoReflect ¶
func (x *LockerTryLockResponse) ProtoReflect() protoreflect.Message
func (*LockerTryLockResponse) Reset ¶
func (x *LockerTryLockResponse) Reset()
func (*LockerTryLockResponse) String ¶
func (x *LockerTryLockResponse) String() string
type LockerTryRLockRequest ¶
type LockerTryRLockRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Timeout uint64 `protobuf:"varint,2,opt,name=timeout,proto3" json:"timeout,omitempty"` // ms
// contains filtered or unexported fields
}
func (*LockerTryRLockRequest) Descriptor
deprecated
func (*LockerTryRLockRequest) Descriptor() ([]byte, []int)
Deprecated: Use LockerTryRLockRequest.ProtoReflect.Descriptor instead.
func (*LockerTryRLockRequest) GetName ¶
func (x *LockerTryRLockRequest) GetName() string
func (*LockerTryRLockRequest) GetTimeout ¶
func (x *LockerTryRLockRequest) GetTimeout() uint64
func (*LockerTryRLockRequest) ProtoMessage ¶
func (*LockerTryRLockRequest) ProtoMessage()
func (*LockerTryRLockRequest) ProtoReflect ¶
func (x *LockerTryRLockRequest) ProtoReflect() protoreflect.Message
func (*LockerTryRLockRequest) Reset ¶
func (x *LockerTryRLockRequest) Reset()
func (*LockerTryRLockRequest) String ¶
func (x *LockerTryRLockRequest) String() string
type LockerTryRLockResponse ¶
type LockerTryRLockResponse struct {
Acquired bool `protobuf:"varint,1,opt,name=acquired,proto3" json:"acquired,omitempty"`
// contains filtered or unexported fields
}
func (*LockerTryRLockResponse) Descriptor
deprecated
func (*LockerTryRLockResponse) Descriptor() ([]byte, []int)
Deprecated: Use LockerTryRLockResponse.ProtoReflect.Descriptor instead.
func (*LockerTryRLockResponse) GetAcquired ¶
func (x *LockerTryRLockResponse) GetAcquired() bool
func (*LockerTryRLockResponse) ProtoMessage ¶
func (*LockerTryRLockResponse) ProtoMessage()
func (*LockerTryRLockResponse) ProtoReflect ¶
func (x *LockerTryRLockResponse) ProtoReflect() protoreflect.Message
func (*LockerTryRLockResponse) Reset ¶
func (x *LockerTryRLockResponse) Reset()
func (*LockerTryRLockResponse) String ¶
func (x *LockerTryRLockResponse) String() string
type LockerUnlockRequest ¶
type LockerUnlockRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*LockerUnlockRequest) Descriptor
deprecated
func (*LockerUnlockRequest) Descriptor() ([]byte, []int)
Deprecated: Use LockerUnlockRequest.ProtoReflect.Descriptor instead.
func (*LockerUnlockRequest) GetName ¶
func (x *LockerUnlockRequest) GetName() string
func (*LockerUnlockRequest) ProtoMessage ¶
func (*LockerUnlockRequest) ProtoMessage()
func (*LockerUnlockRequest) ProtoReflect ¶
func (x *LockerUnlockRequest) ProtoReflect() protoreflect.Message
func (*LockerUnlockRequest) Reset ¶
func (x *LockerUnlockRequest) Reset()
func (*LockerUnlockRequest) String ¶
func (x *LockerUnlockRequest) String() string
type LockerUnlockResponse ¶
type LockerUnlockResponse struct {
// contains filtered or unexported fields
}
func (*LockerUnlockResponse) Descriptor
deprecated
func (*LockerUnlockResponse) Descriptor() ([]byte, []int)
Deprecated: Use LockerUnlockResponse.ProtoReflect.Descriptor instead.
func (*LockerUnlockResponse) ProtoMessage ¶
func (*LockerUnlockResponse) ProtoMessage()
func (*LockerUnlockResponse) ProtoReflect ¶
func (x *LockerUnlockResponse) ProtoReflect() protoreflect.Message
func (*LockerUnlockResponse) Reset ¶
func (x *LockerUnlockResponse) Reset()
func (*LockerUnlockResponse) String ¶
func (x *LockerUnlockResponse) String() string
type ReloadAppRequest ¶
type ReloadAppRequest struct {
// contains filtered or unexported fields
}
func (*ReloadAppRequest) Descriptor
deprecated
func (*ReloadAppRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReloadAppRequest.ProtoReflect.Descriptor instead.
func (*ReloadAppRequest) ProtoMessage ¶
func (*ReloadAppRequest) ProtoMessage()
func (*ReloadAppRequest) ProtoReflect ¶
func (x *ReloadAppRequest) ProtoReflect() protoreflect.Message
func (*ReloadAppRequest) Reset ¶
func (x *ReloadAppRequest) Reset()
func (*ReloadAppRequest) String ¶
func (x *ReloadAppRequest) String() string
type ReloadAppResponse ¶
type ReloadAppResponse struct {
Code ReloadAppResponse_Code `protobuf:"varint,1,opt,name=code,proto3,enum=xiao.ally.ReloadAppResponse_Code" json:"code,omitempty"`
Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*ReloadAppResponse) Descriptor
deprecated
func (*ReloadAppResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReloadAppResponse.ProtoReflect.Descriptor instead.
func (*ReloadAppResponse) GetCode ¶
func (x *ReloadAppResponse) GetCode() ReloadAppResponse_Code
func (*ReloadAppResponse) GetError ¶
func (x *ReloadAppResponse) GetError() string
func (*ReloadAppResponse) ProtoMessage ¶
func (*ReloadAppResponse) ProtoMessage()
func (*ReloadAppResponse) ProtoReflect ¶
func (x *ReloadAppResponse) ProtoReflect() protoreflect.Message
func (*ReloadAppResponse) Reset ¶
func (x *ReloadAppResponse) Reset()
func (*ReloadAppResponse) String ¶
func (x *ReloadAppResponse) String() string
type ReloadAppResponse_Code ¶
type ReloadAppResponse_Code int32
const ( ReloadAppResponse_EC_OK ReloadAppResponse_Code = 0 ReloadAppResponse_EC_PERMISSION ReloadAppResponse_Code = 1 // 仅允许最新app实例访问此接口 ReloadAppResponse_EC_RELOAD ReloadAppResponse_Code = 2 )
func (ReloadAppResponse_Code) Descriptor ¶
func (ReloadAppResponse_Code) Descriptor() protoreflect.EnumDescriptor
func (ReloadAppResponse_Code) Enum ¶
func (x ReloadAppResponse_Code) Enum() *ReloadAppResponse_Code
func (ReloadAppResponse_Code) EnumDescriptor
deprecated
func (ReloadAppResponse_Code) EnumDescriptor() ([]byte, []int)
Deprecated: Use ReloadAppResponse_Code.Descriptor instead.
func (ReloadAppResponse_Code) Number ¶
func (x ReloadAppResponse_Code) Number() protoreflect.EnumNumber
func (ReloadAppResponse_Code) String ¶
func (x ReloadAppResponse_Code) String() string
func (ReloadAppResponse_Code) Type ¶
func (ReloadAppResponse_Code) Type() protoreflect.EnumType
type UnimplementedAllyServer ¶
type UnimplementedAllyServer struct{}
UnimplementedAllyServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedAllyServer) CloseSocket ¶
func (UnimplementedAllyServer) CloseSocket(context.Context, *CloseSocketRequest) (*CloseSocketResponse, error)
func (UnimplementedAllyServer) GetAppInfo ¶
func (UnimplementedAllyServer) GetAppInfo(context.Context, *GetAppInfoRequest) (*GetAppInfoResponse, error)
func (UnimplementedAllyServer) GetInstanceInfo ¶
func (UnimplementedAllyServer) GetInstanceInfo(context.Context, *GetInstanceInfoRequest) (*GetInstanceInfoResponse, error)
func (UnimplementedAllyServer) Heartbeat ¶
func (UnimplementedAllyServer) Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
func (UnimplementedAllyServer) ListenSocket ¶
func (UnimplementedAllyServer) ListenSocket(context.Context, *ListenSocketRequest) (*ListenSocketResponse, error)
func (UnimplementedAllyServer) ReloadApp ¶
func (UnimplementedAllyServer) ReloadApp(context.Context, *ReloadAppRequest) (*ReloadAppResponse, error)
type UnimplementedAtomicServer ¶
type UnimplementedAtomicServer struct{}
UnimplementedAtomicServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedAtomicServer) AtomicAdd ¶
func (UnimplementedAtomicServer) AtomicAdd(context.Context, *AtomicAddRequest) (*AtomicAddResponse, error)
func (UnimplementedAtomicServer) AtomicCompareAndSwap ¶
func (UnimplementedAtomicServer) AtomicCompareAndSwap(context.Context, *AtomicCompareAndSwapRequest) (*AtomicCompareAndSwapResponse, error)
func (UnimplementedAtomicServer) AtomicLoad ¶
func (UnimplementedAtomicServer) AtomicLoad(context.Context, *AtomicLoadRequest) (*AtomicLoadResponse, error)
func (UnimplementedAtomicServer) AtomicStore ¶
func (UnimplementedAtomicServer) AtomicStore(context.Context, *AtomicStoreRequest) (*AtomicStoreResponse, error)
func (UnimplementedAtomicServer) AtomicSwap ¶
func (UnimplementedAtomicServer) AtomicSwap(context.Context, *AtomicSwapRequest) (*AtomicSwapResponse, error)
type UnimplementedCacheServer ¶
type UnimplementedCacheServer struct{}
UnimplementedCacheServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedCacheServer) CacheCount ¶
func (UnimplementedCacheServer) CacheCount(context.Context, *CacheCountRequest) (*CacheCountResponse, error)
func (UnimplementedCacheServer) CacheDel ¶
func (UnimplementedCacheServer) CacheDel(context.Context, *CacheDelRequest) (*CacheDelResponse, error)
func (UnimplementedCacheServer) CacheExists ¶
func (UnimplementedCacheServer) CacheExists(context.Context, *CacheExistsRequest) (*CacheExistsResponse, error)
func (UnimplementedCacheServer) CacheFlush ¶
func (UnimplementedCacheServer) CacheFlush(context.Context, *CacheFlushRequest) (*CacheFlushResponse, error)
func (UnimplementedCacheServer) CacheGet ¶
func (UnimplementedCacheServer) CacheGet(context.Context, *CacheGetRequest) (*CacheGetResponse, error)
func (UnimplementedCacheServer) CacheItems ¶
func (UnimplementedCacheServer) CacheItems(context.Context, *CacheItemsRequest) (*CacheItemsResponse, error)
func (UnimplementedCacheServer) CacheKeys ¶
func (UnimplementedCacheServer) CacheKeys(context.Context, *CacheKeysRequest) (*CacheKeysResponse, error)
func (UnimplementedCacheServer) CacheSet ¶
func (UnimplementedCacheServer) CacheSet(context.Context, *CacheSetRequest) (*CacheSetResponse, error)
type UnimplementedLockerServer ¶
type UnimplementedLockerServer struct{}
UnimplementedLockerServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedLockerServer) LockerLock ¶
func (UnimplementedLockerServer) LockerLock(context.Context, *LockerLockRequest) (*LockerLockResponse, error)
func (UnimplementedLockerServer) LockerQueues ¶
func (UnimplementedLockerServer) LockerQueues(context.Context, *LockerQueuesRequest) (*LockerQueuesResponse, error)
func (UnimplementedLockerServer) LockerRLock ¶
func (UnimplementedLockerServer) LockerRLock(context.Context, *LockerRLockRequest) (*LockerRLockResponse, error)
func (UnimplementedLockerServer) LockerRUnlock ¶
func (UnimplementedLockerServer) LockerRUnlock(context.Context, *LockerRUnlockRequest) (*LockerRUnlockResponse, error)
func (UnimplementedLockerServer) LockerTryLock ¶
func (UnimplementedLockerServer) LockerTryLock(context.Context, *LockerTryLockRequest) (*LockerTryLockResponse, error)
func (UnimplementedLockerServer) LockerTryRLock ¶
func (UnimplementedLockerServer) LockerTryRLock(context.Context, *LockerTryRLockRequest) (*LockerTryRLockResponse, error)
func (UnimplementedLockerServer) LockerUnlock ¶
func (UnimplementedLockerServer) LockerUnlock(context.Context, *LockerUnlockRequest) (*LockerUnlockResponse, error)
type UnsafeAllyServer ¶
type UnsafeAllyServer interface {
// contains filtered or unexported methods
}
UnsafeAllyServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AllyServer will result in compilation errors.
type UnsafeAtomicServer ¶
type UnsafeAtomicServer interface {
// contains filtered or unexported methods
}
UnsafeAtomicServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AtomicServer will result in compilation errors.
type UnsafeCacheServer ¶
type UnsafeCacheServer interface {
// contains filtered or unexported methods
}
UnsafeCacheServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CacheServer will result in compilation errors.
type UnsafeLockerServer ¶
type UnsafeLockerServer interface {
// contains filtered or unexported methods
}
UnsafeLockerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LockerServer will result in compilation errors.