proto

package
v1.0.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 19, 2025 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source
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"
)
View Source
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"
)
View Source
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"
)
View Source
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

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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.

View Source
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)

View Source
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)

View Source
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)

View Source
var File_ally_xiao_proto protoreflect.FileDescriptor
View Source
var File_atomic_ally_xiao_proto protoreflect.FileDescriptor
View Source
var File_cache_ally_xiao_proto protoreflect.FileDescriptor
View Source
var File_locker_ally_xiao_proto protoreflect.FileDescriptor
View Source
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) Descriptor() ([]byte, []int)

Deprecated: Use Address.ProtoReflect.Descriptor instead.

func (*Address) GetAddress

func (x *Address) GetAddress() string

func (*Address) GetCreated

func (x *Address) GetCreated() int64

func (*Address) GetNetwork

func (x *Address) GetNetwork() string

func (*Address) GetRefs

func (x *Address) GetRefs() uint64

func (*Address) GetUpdated

func (x *Address) GetUpdated() int64

func (*Address) ProtoMessage

func (*Address) ProtoMessage()

func (*Address) ProtoReflect

func (x *Address) ProtoReflect() protoreflect.Message

func (*Address) Reset

func (x *Address) Reset()

func (*Address) String

func (x *Address) String() string

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

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) Descriptor() ([]byte, []int)

Deprecated: Use AppInfo.ProtoReflect.Descriptor instead.

func (*AppInfo) GetAddresses

func (x *AppInfo) GetAddresses() []*Address

func (*AppInfo) GetArgs

func (x *AppInfo) GetArgs() []string

func (*AppInfo) GetBin

func (x *AppInfo) GetBin() string

func (*AppInfo) GetCrashWait

func (x *AppInfo) GetCrashWait() uint64

func (*AppInfo) GetEnable

func (x *AppInfo) GetEnable() bool

func (*AppInfo) GetEnvs

func (x *AppInfo) GetEnvs() []string

func (*AppInfo) GetEphemeral

func (x *AppInfo) GetEphemeral() bool

func (*AppInfo) GetFamily

func (x *AppInfo) GetFamily() string

func (*AppInfo) GetGroup

func (x *AppInfo) GetGroup() string

func (*AppInfo) GetInstances

func (x *AppInfo) GetInstances() []*InstanceInfo

func (*AppInfo) GetLastError

func (x *AppInfo) GetLastError() string

func (*AppInfo) GetMain

func (x *AppInfo) GetMain() uint64

func (*AppInfo) GetName

func (x *AppInfo) GetName() string

func (*AppInfo) GetPath

func (x *AppInfo) GetPath() string

func (*AppInfo) GetPwd

func (x *AppInfo) GetPwd() string

func (*AppInfo) GetStartTime

func (x *AppInfo) GetStartTime() int64

func (*AppInfo) GetStat

func (x *AppInfo) GetStat() AppStat_Enum

func (*AppInfo) GetUser

func (x *AppInfo) GetUser() string

func (*AppInfo) ProtoMessage

func (*AppInfo) ProtoMessage()

func (*AppInfo) ProtoReflect

func (x *AppInfo) ProtoReflect() protoreflect.Message

func (*AppInfo) Reset

func (x *AppInfo) Reset()

func (*AppInfo) String

func (x *AppInfo) String() string

type AppStat

type AppStat struct {
	// contains filtered or unexported fields
}

func (*AppStat) Descriptor deprecated

func (*AppStat) Descriptor() ([]byte, []int)

Deprecated: Use AppStat.ProtoReflect.Descriptor instead.

func (*AppStat) ProtoMessage

func (*AppStat) ProtoMessage()

func (*AppStat) ProtoReflect

func (x *AppStat) ProtoReflect() protoreflect.Message

func (*AppStat) Reset

func (x *AppStat) Reset()

func (*AppStat) String

func (x *AppStat) String() string

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) 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 (AppStat_Enum) String

func (x AppStat_Enum) String() string

func (AppStat_Enum) Type

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 (*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 (*AtomicCompareAndSwapResponse) Reset

func (x *AtomicCompareAndSwapResponse) Reset()

func (*AtomicCompareAndSwapResponse) 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

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

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 (*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) Enum

func (CloseSocketResponse_Code) EnumDescriptor deprecated

func (CloseSocketResponse_Code) EnumDescriptor() ([]byte, []int)

Deprecated: Use CloseSocketResponse_Code.Descriptor instead.

func (CloseSocketResponse_Code) Number

func (CloseSocketResponse_Code) String

func (x CloseSocketResponse_Code) String() string

func (CloseSocketResponse_Code) Type

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 (*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) Enum

func (GetInstanceInfoResponse_Code) EnumDescriptor deprecated

func (GetInstanceInfoResponse_Code) EnumDescriptor() ([]byte, []int)

Deprecated: Use GetInstanceInfoResponse_Code.Descriptor instead.

func (GetInstanceInfoResponse_Code) Number

func (GetInstanceInfoResponse_Code) String

func (GetInstanceInfoResponse_Code) Type

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 (*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) Enum

func (HeartbeatResponse_Code) EnumDescriptor deprecated

func (HeartbeatResponse_Code) EnumDescriptor() ([]byte, []int)

Deprecated: Use HeartbeatResponse_Code.Descriptor instead.

func (HeartbeatResponse_Code) Number

func (HeartbeatResponse_Code) String

func (x HeartbeatResponse_Code) String() string

func (HeartbeatResponse_Code) Type

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) Enum

func (InstanceStat_Enum) EnumDescriptor deprecated

func (InstanceStat_Enum) EnumDescriptor() ([]byte, []int)

Deprecated: Use InstanceStat_Enum.Descriptor instead.

func (InstanceStat_Enum) Number

func (InstanceStat_Enum) String

func (x InstanceStat_Enum) String() string

func (InstanceStat_Enum) Type

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 (*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) Enum

func (ListenSocketResponse_Code) EnumDescriptor deprecated

func (ListenSocketResponse_Code) EnumDescriptor() ([]byte, []int)

Deprecated: Use ListenSocketResponse_Code.Descriptor instead.

func (ListenSocketResponse_Code) Number

func (ListenSocketResponse_Code) String

func (x ListenSocketResponse_Code) String() string

func (ListenSocketResponse_Code) Type

type LockerClient

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

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 (*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) Enum

func (ReloadAppResponse_Code) EnumDescriptor deprecated

func (ReloadAppResponse_Code) EnumDescriptor() ([]byte, []int)

Deprecated: Use ReloadAppResponse_Code.Descriptor instead.

func (ReloadAppResponse_Code) Number

func (ReloadAppResponse_Code) String

func (x ReloadAppResponse_Code) String() string

func (ReloadAppResponse_Code) Type

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) GetAppInfo

func (UnimplementedAllyServer) GetInstanceInfo

func (UnimplementedAllyServer) Heartbeat

func (UnimplementedAllyServer) ListenSocket

func (UnimplementedAllyServer) ReloadApp

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) AtomicLoad

func (UnimplementedAtomicServer) AtomicStore

func (UnimplementedAtomicServer) AtomicSwap

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) CacheDel

func (UnimplementedCacheServer) CacheExists

func (UnimplementedCacheServer) CacheFlush

func (UnimplementedCacheServer) CacheGet

func (UnimplementedCacheServer) CacheItems

func (UnimplementedCacheServer) CacheKeys

func (UnimplementedCacheServer) CacheSet

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) LockerQueues

func (UnimplementedLockerServer) LockerRLock

func (UnimplementedLockerServer) LockerRUnlock

func (UnimplementedLockerServer) LockerTryLock

func (UnimplementedLockerServer) LockerTryRLock

func (UnimplementedLockerServer) LockerUnlock

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL