Documentation
¶
Index ¶
- Variables
- func MasterServerAddr(app string, pid int) string
- func RegisterCtiServiceServer(s grpc.ServiceRegistrar, srv CtiServiceServer)
- func RegisterMasterServer(s grpc.ServiceRegistrar, srv MasterServer)
- func RegisterWorkerServiceServer(s grpc.ServiceRegistrar, srv WorkerServiceServer)
- func WorkerServerAddr(app string, pid int) string
- type ClusterRequest
- type ClusterResponse
- type CtiServiceClient
- type CtiServiceServer
- type EnvConfig
- type Error
- type HelloRequest
- type HelloResponse
- type InfoRequest
- type InfoResponse
- func (*InfoResponse) Descriptor() ([]byte, []int)deprecated
- func (x *InfoResponse) GetCode() string
- func (x *InfoResponse) GetInfo() *NodeInfo
- func (x *InfoResponse) GetMsg() string
- func (*InfoResponse) ProtoMessage()
- func (x *InfoResponse) ProtoReflect() protoreflect.Message
- func (x *InfoResponse) Reset()
- func (x *InfoResponse) String() string
- type JoinRequest
- func (*JoinRequest) Descriptor() ([]byte, []int)deprecated
- func (x *JoinRequest) GetBroadcastIP() string
- func (x *JoinRequest) GetBroadcastPort() int32
- func (x *JoinRequest) GetClusterAddress() []string
- func (x *JoinRequest) GetProtocol() string
- func (x *JoinRequest) GetSecret() *NodeSecret
- func (*JoinRequest) ProtoMessage()
- func (x *JoinRequest) ProtoReflect() protoreflect.Message
- func (x *JoinRequest) Reset()
- func (x *JoinRequest) String() string
- type JoinResponse
- func (*JoinResponse) Descriptor() ([]byte, []int)deprecated
- func (x *JoinResponse) GetCode() string
- func (x *JoinResponse) GetInfo() *NodeSecret
- func (x *JoinResponse) GetMsg() string
- func (*JoinResponse) ProtoMessage()
- func (x *JoinResponse) ProtoReflect() protoreflect.Message
- func (x *JoinResponse) Reset()
- func (x *JoinResponse) String() string
- type LeaveRequest
- type LeaveResponse
- func (*LeaveResponse) Descriptor() ([]byte, []int)deprecated
- func (x *LeaveResponse) GetCode() string
- func (x *LeaveResponse) GetMsg() string
- func (x *LeaveResponse) GetSecret() *NodeSecret
- func (*LeaveResponse) ProtoMessage()
- func (x *LeaveResponse) ProtoReflect() protoreflect.Message
- func (x *LeaveResponse) Reset()
- func (x *LeaveResponse) String() string
- type ListRequest
- type ListResponse
- func (*ListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListResponse) GetCode() string
- func (x *ListResponse) GetInfo() []*NodeInfo
- func (x *ListResponse) GetMsg() string
- func (*ListResponse) ProtoMessage()
- func (x *ListResponse) ProtoReflect() protoreflect.Message
- func (x *ListResponse) Reset()
- func (x *ListResponse) String() string
- type MasterClient
- type MasterServer
- type NodeInfo
- func (*NodeInfo) Descriptor() ([]byte, []int)deprecated
- func (x *NodeInfo) GetAddr() string
- func (x *NodeInfo) GetLeaderID() int32
- func (x *NodeInfo) GetNodeID() int32
- func (x *NodeInfo) GetNodeKey() string
- func (x *NodeInfo) GetRaftState() string
- func (x *NodeInfo) GetStatus() string
- func (x *NodeInfo) GetTerm() int32
- func (*NodeInfo) ProtoMessage()
- func (x *NodeInfo) ProtoReflect() protoreflect.Message
- func (x *NodeInfo) Reset()
- func (x *NodeInfo) String() string
- type NodeSecret
- type Traffic
- func (*Traffic) Descriptor() ([]byte, []int)deprecated
- func (x *Traffic) GetAddr() string
- func (x *Traffic) GetFD() uint64
- func (x *Traffic) GetNetwork() string
- func (*Traffic) ProtoMessage()
- func (x *Traffic) ProtoReflect() protoreflect.Message
- func (x *Traffic) Reset()
- func (x *Traffic) String() string
- type UnimplementedCtiServiceServer
- func (UnimplementedCtiServiceServer) Info(context.Context, *InfoRequest) (*InfoResponse, error)
- func (UnimplementedCtiServiceServer) Join(context.Context, *JoinRequest) (*JoinResponse, error)
- func (UnimplementedCtiServiceServer) Leave(context.Context, *LeaveRequest) (*LeaveResponse, error)
- func (UnimplementedCtiServiceServer) List(context.Context, *ListRequest) (*ListResponse, error)
- type UnimplementedMasterServer
- type UnimplementedWorkerServiceServer
- func (UnimplementedWorkerServiceServer) Delete(context.Context, *WorkerDeleteRequest) (*WorkerDeleteResponse, error)
- func (UnimplementedWorkerServiceServer) DeleteCheck(context.Context, *WorkerDeleteRequest) (*WorkerDeleteResponse, error)
- func (UnimplementedWorkerServiceServer) Ping(context.Context, *WorkerHelloRequest) (*WorkerHelloResponse, error)
- func (UnimplementedWorkerServiceServer) Refresh(context.Context, *WorkerRefreshRequest) (*WorkerRefreshResponse, error)
- func (UnimplementedWorkerServiceServer) Set(context.Context, *WorkerSetRequest) (*WorkerSetResponse, error)
- func (UnimplementedWorkerServiceServer) SetCheck(context.Context, *WorkerSetRequest) (*WorkerSetResponse, error)
- type UnsafeCtiServiceServer
- type UnsafeMasterServer
- type UnsafeWorkerServiceServer
- type WorkerConfig
- func (*WorkerConfig) Descriptor() ([]byte, []int)deprecated
- func (x *WorkerConfig) GetStore() []byte
- func (x *WorkerConfig) GetTraffic() *Traffic
- func (*WorkerConfig) ProtoMessage()
- func (x *WorkerConfig) ProtoReflect() protoreflect.Message
- func (x *WorkerConfig) Reset()
- func (x *WorkerConfig) String() string
- type WorkerDeleteRequest
- func (*WorkerDeleteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WorkerDeleteRequest) GetId() string
- func (*WorkerDeleteRequest) ProtoMessage()
- func (x *WorkerDeleteRequest) ProtoReflect() protoreflect.Message
- func (x *WorkerDeleteRequest) Reset()
- func (x *WorkerDeleteRequest) String() string
- type WorkerDeleteResponse
- func (*WorkerDeleteResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WorkerDeleteResponse) GetMessage() string
- func (x *WorkerDeleteResponse) GetResource() *WorkerResource
- func (x *WorkerDeleteResponse) GetStatus() WorkerStatusCode
- func (*WorkerDeleteResponse) ProtoMessage()
- func (x *WorkerDeleteResponse) ProtoReflect() protoreflect.Message
- func (x *WorkerDeleteResponse) Reset()
- func (x *WorkerDeleteResponse) String() string
- type WorkerHelloRequest
- func (*WorkerHelloRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WorkerHelloRequest) GetHello() string
- func (*WorkerHelloRequest) ProtoMessage()
- func (x *WorkerHelloRequest) ProtoReflect() protoreflect.Message
- func (x *WorkerHelloRequest) Reset()
- func (x *WorkerHelloRequest) String() string
- type WorkerHelloResponse
- func (*WorkerHelloResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WorkerHelloResponse) GetHello() string
- func (x *WorkerHelloResponse) GetResource() *WorkerResource
- func (*WorkerHelloResponse) ProtoMessage()
- func (x *WorkerHelloResponse) ProtoReflect() protoreflect.Message
- func (x *WorkerHelloResponse) Reset()
- func (x *WorkerHelloResponse) String() string
- type WorkerRefreshRequest
- func (*WorkerRefreshRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WorkerRefreshRequest) GetPorts() []int32
- func (*WorkerRefreshRequest) ProtoMessage()
- func (x *WorkerRefreshRequest) ProtoReflect() protoreflect.Message
- func (x *WorkerRefreshRequest) Reset()
- func (x *WorkerRefreshRequest) String() string
- type WorkerRefreshResponse
- func (*WorkerRefreshResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WorkerRefreshResponse) GetMessage() string
- func (x *WorkerRefreshResponse) GetStatus() WorkerStatusCode
- func (*WorkerRefreshResponse) ProtoMessage()
- func (x *WorkerRefreshResponse) ProtoReflect() protoreflect.Message
- func (x *WorkerRefreshResponse) Reset()
- func (x *WorkerRefreshResponse) String() string
- type WorkerResource
- type WorkerServiceClient
- type WorkerServiceServer
- type WorkerSetRequest
- func (*WorkerSetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WorkerSetRequest) GetBody() []byte
- func (x *WorkerSetRequest) GetDriver() string
- func (x *WorkerSetRequest) GetId() string
- func (x *WorkerSetRequest) GetName() string
- func (x *WorkerSetRequest) GetProfession() string
- func (*WorkerSetRequest) ProtoMessage()
- func (x *WorkerSetRequest) ProtoReflect() protoreflect.Message
- func (x *WorkerSetRequest) Reset()
- func (x *WorkerSetRequest) String() string
- type WorkerSetResponse
- func (*WorkerSetResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WorkerSetResponse) GetMessage() string
- func (x *WorkerSetResponse) GetResource() *WorkerResource
- func (x *WorkerSetResponse) GetStatus() WorkerStatusCode
- func (*WorkerSetResponse) ProtoMessage()
- func (x *WorkerSetResponse) ProtoReflect() protoreflect.Message
- func (x *WorkerSetResponse) Reset()
- func (x *WorkerSetResponse) String() string
- type WorkerStatusCode
- func (WorkerStatusCode) Descriptor() protoreflect.EnumDescriptor
- func (x WorkerStatusCode) Enum() *WorkerStatusCode
- func (WorkerStatusCode) EnumDescriptor() ([]byte, []int)deprecated
- func (x WorkerStatusCode) Number() protoreflect.EnumNumber
- func (x WorkerStatusCode) String() string
- func (WorkerStatusCode) Type() protoreflect.EnumType
Constants ¶
This section is empty.
Variables ¶
var ( WorkerStatusCode_name = map[int32]string{ 0: "SUCCESS", 1: "FAIL", 2: "SKILL", } WorkerStatusCode_value = map[string]int32{ "SUCCESS": 0, "FAIL": 1, "SKILL": 2, } )
Enum value maps for WorkerStatusCode.
var CtiService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "service.CtiService", HandlerType: (*CtiServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Join", Handler: _CtiService_Join_Handler, }, { MethodName: "Leave", Handler: _CtiService_Leave_Handler, }, { MethodName: "List", Handler: _CtiService_List_Handler, }, { MethodName: "Info", Handler: _CtiService_Info_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "service/ctl.proto", }
CtiService_ServiceDesc is the grpc.ServiceDesc for CtiService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_service_ctl_proto protoreflect.FileDescriptor
var File_service_master_proto protoreflect.FileDescriptor
var File_service_service_proto protoreflect.FileDescriptor
var File_service_worker_proto protoreflect.FileDescriptor
var Master_ServiceDesc = grpc.ServiceDesc{ ServiceName: "service.Master", HandlerType: (*MasterServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Hello", Handler: _Master_Hello_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "service/master.proto", }
Master_ServiceDesc is the grpc.ServiceDesc for Master service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var WorkerService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "service.WorkerService", HandlerType: (*WorkerServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "deleteCheck", Handler: _WorkerService_DeleteCheck_Handler, }, { MethodName: "setCheck", Handler: _WorkerService_SetCheck_Handler, }, { MethodName: "delete", Handler: _WorkerService_Delete_Handler, }, { MethodName: "set", Handler: _WorkerService_Set_Handler, }, { MethodName: "ping", Handler: _WorkerService_Ping_Handler, }, { MethodName: "refresh", Handler: _WorkerService_Refresh_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "service/worker.proto", }
WorkerService_ServiceDesc is the grpc.ServiceDesc for WorkerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func MasterServerAddr ¶
func RegisterCtiServiceServer ¶
func RegisterCtiServiceServer(s grpc.ServiceRegistrar, srv CtiServiceServer)
func RegisterMasterServer ¶
func RegisterMasterServer(s grpc.ServiceRegistrar, srv MasterServer)
func RegisterWorkerServiceServer ¶
func RegisterWorkerServiceServer(s grpc.ServiceRegistrar, srv WorkerServiceServer)
func WorkerServerAddr ¶
Types ¶
type ClusterRequest ¶
type ClusterRequest struct {
// contains filtered or unexported fields
}
func (*ClusterRequest) Descriptor
deprecated
func (*ClusterRequest) Descriptor() ([]byte, []int)
Deprecated: Use ClusterRequest.ProtoReflect.Descriptor instead.
func (*ClusterRequest) ProtoMessage ¶
func (*ClusterRequest) ProtoMessage()
func (*ClusterRequest) ProtoReflect ¶
func (x *ClusterRequest) ProtoReflect() protoreflect.Message
func (*ClusterRequest) Reset ¶
func (x *ClusterRequest) Reset()
func (*ClusterRequest) String ¶
func (x *ClusterRequest) String() string
type ClusterResponse ¶
type ClusterResponse struct {
// contains filtered or unexported fields
}
func (*ClusterResponse) Descriptor
deprecated
func (*ClusterResponse) Descriptor() ([]byte, []int)
Deprecated: Use ClusterResponse.ProtoReflect.Descriptor instead.
func (*ClusterResponse) ProtoMessage ¶
func (*ClusterResponse) ProtoMessage()
func (*ClusterResponse) ProtoReflect ¶
func (x *ClusterResponse) ProtoReflect() protoreflect.Message
func (*ClusterResponse) Reset ¶
func (x *ClusterResponse) Reset()
func (*ClusterResponse) String ¶
func (x *ClusterResponse) String() string
type CtiServiceClient ¶
type CtiServiceClient interface { Join(ctx context.Context, in *JoinRequest, opts ...grpc.CallOption) (*JoinResponse, error) Leave(ctx context.Context, in *LeaveRequest, opts ...grpc.CallOption) (*LeaveResponse, error) List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error) Info(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error) }
CtiServiceClient is the client API for CtiService 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 NewCtiServiceClient ¶
func NewCtiServiceClient(cc grpc.ClientConnInterface) CtiServiceClient
type CtiServiceServer ¶
type CtiServiceServer interface { Join(context.Context, *JoinRequest) (*JoinResponse, error) Leave(context.Context, *LeaveRequest) (*LeaveResponse, error) List(context.Context, *ListRequest) (*ListResponse, error) Info(context.Context, *InfoRequest) (*InfoResponse, error) // contains filtered or unexported methods }
CtiServiceServer is the server API for CtiService service. All implementations must embed UnimplementedCtiServiceServer for forward compatibility
type EnvConfig ¶
type EnvConfig struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*EnvConfig) Descriptor
deprecated
func (*EnvConfig) ProtoMessage ¶
func (*EnvConfig) ProtoMessage()
func (*EnvConfig) ProtoReflect ¶
func (x *EnvConfig) ProtoReflect() protoreflect.Message
type Error ¶
type Error struct { Code int64 `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"` Error string `protobuf:"bytes,2,opt,name=Error,proto3" json:"Error,omitempty"` // contains filtered or unexported fields }
func (*Error) Descriptor
deprecated
func (*Error) ProtoMessage ¶
func (*Error) ProtoMessage()
func (*Error) ProtoReflect ¶
func (x *Error) ProtoReflect() protoreflect.Message
type HelloRequest ¶
type HelloRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*HelloRequest) Descriptor
deprecated
func (*HelloRequest) Descriptor() ([]byte, []int)
Deprecated: Use HelloRequest.ProtoReflect.Descriptor instead.
func (*HelloRequest) GetName ¶
func (x *HelloRequest) GetName() string
func (*HelloRequest) ProtoMessage ¶
func (*HelloRequest) ProtoMessage()
func (*HelloRequest) ProtoReflect ¶
func (x *HelloRequest) ProtoReflect() protoreflect.Message
func (*HelloRequest) Reset ¶
func (x *HelloRequest) Reset()
func (*HelloRequest) String ¶
func (x *HelloRequest) String() string
type HelloResponse ¶
type HelloResponse struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*HelloResponse) Descriptor
deprecated
func (*HelloResponse) Descriptor() ([]byte, []int)
Deprecated: Use HelloResponse.ProtoReflect.Descriptor instead.
func (*HelloResponse) GetName ¶
func (x *HelloResponse) GetName() string
func (*HelloResponse) ProtoMessage ¶
func (*HelloResponse) ProtoMessage()
func (*HelloResponse) ProtoReflect ¶
func (x *HelloResponse) ProtoReflect() protoreflect.Message
func (*HelloResponse) Reset ¶
func (x *HelloResponse) Reset()
func (*HelloResponse) String ¶
func (x *HelloResponse) String() string
type InfoRequest ¶
type InfoRequest struct { Secret *NodeSecret `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"` // contains filtered or unexported fields }
func (*InfoRequest) Descriptor
deprecated
func (*InfoRequest) Descriptor() ([]byte, []int)
Deprecated: Use InfoRequest.ProtoReflect.Descriptor instead.
func (*InfoRequest) GetSecret ¶
func (x *InfoRequest) GetSecret() *NodeSecret
func (*InfoRequest) ProtoMessage ¶
func (*InfoRequest) ProtoMessage()
func (*InfoRequest) ProtoReflect ¶
func (x *InfoRequest) ProtoReflect() protoreflect.Message
func (*InfoRequest) Reset ¶
func (x *InfoRequest) Reset()
func (*InfoRequest) String ¶
func (x *InfoRequest) String() string
type InfoResponse ¶
type InfoResponse struct { Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"` Code string `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"` Info *NodeInfo `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"` // contains filtered or unexported fields }
func (*InfoResponse) Descriptor
deprecated
func (*InfoResponse) Descriptor() ([]byte, []int)
Deprecated: Use InfoResponse.ProtoReflect.Descriptor instead.
func (*InfoResponse) GetCode ¶
func (x *InfoResponse) GetCode() string
func (*InfoResponse) GetInfo ¶
func (x *InfoResponse) GetInfo() *NodeInfo
func (*InfoResponse) GetMsg ¶
func (x *InfoResponse) GetMsg() string
func (*InfoResponse) ProtoMessage ¶
func (*InfoResponse) ProtoMessage()
func (*InfoResponse) ProtoReflect ¶
func (x *InfoResponse) ProtoReflect() protoreflect.Message
func (*InfoResponse) Reset ¶
func (x *InfoResponse) Reset()
func (*InfoResponse) String ¶
func (x *InfoResponse) String() string
type JoinRequest ¶
type JoinRequest struct { BroadcastIP string `protobuf:"bytes,1,opt,name=broadcastIP,proto3" json:"broadcastIP,omitempty"` BroadcastPort int32 `protobuf:"varint,2,opt,name=broadcastPort,proto3" json:"broadcastPort,omitempty"` Protocol string `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol,omitempty"` ClusterAddress []string `protobuf:"bytes,4,rep,name=clusterAddress,proto3" json:"clusterAddress,omitempty"` Secret *NodeSecret `protobuf:"bytes,5,opt,name=secret,proto3" json:"secret,omitempty"` // contains filtered or unexported fields }
func (*JoinRequest) Descriptor
deprecated
func (*JoinRequest) Descriptor() ([]byte, []int)
Deprecated: Use JoinRequest.ProtoReflect.Descriptor instead.
func (*JoinRequest) GetBroadcastIP ¶
func (x *JoinRequest) GetBroadcastIP() string
func (*JoinRequest) GetBroadcastPort ¶
func (x *JoinRequest) GetBroadcastPort() int32
func (*JoinRequest) GetClusterAddress ¶
func (x *JoinRequest) GetClusterAddress() []string
func (*JoinRequest) GetProtocol ¶
func (x *JoinRequest) GetProtocol() string
func (*JoinRequest) GetSecret ¶
func (x *JoinRequest) GetSecret() *NodeSecret
func (*JoinRequest) ProtoMessage ¶
func (*JoinRequest) ProtoMessage()
func (*JoinRequest) ProtoReflect ¶
func (x *JoinRequest) ProtoReflect() protoreflect.Message
func (*JoinRequest) Reset ¶
func (x *JoinRequest) Reset()
func (*JoinRequest) String ¶
func (x *JoinRequest) String() string
type JoinResponse ¶
type JoinResponse struct { Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"` Code string `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"` Info *NodeSecret `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"` // contains filtered or unexported fields }
func (*JoinResponse) Descriptor
deprecated
func (*JoinResponse) Descriptor() ([]byte, []int)
Deprecated: Use JoinResponse.ProtoReflect.Descriptor instead.
func (*JoinResponse) GetCode ¶
func (x *JoinResponse) GetCode() string
func (*JoinResponse) GetInfo ¶
func (x *JoinResponse) GetInfo() *NodeSecret
func (*JoinResponse) GetMsg ¶
func (x *JoinResponse) GetMsg() string
func (*JoinResponse) ProtoMessage ¶
func (*JoinResponse) ProtoMessage()
func (*JoinResponse) ProtoReflect ¶
func (x *JoinResponse) ProtoReflect() protoreflect.Message
func (*JoinResponse) Reset ¶
func (x *JoinResponse) Reset()
func (*JoinResponse) String ¶
func (x *JoinResponse) String() string
type LeaveRequest ¶
type LeaveRequest struct {
// contains filtered or unexported fields
}
func (*LeaveRequest) Descriptor
deprecated
func (*LeaveRequest) Descriptor() ([]byte, []int)
Deprecated: Use LeaveRequest.ProtoReflect.Descriptor instead.
func (*LeaveRequest) ProtoMessage ¶
func (*LeaveRequest) ProtoMessage()
func (*LeaveRequest) ProtoReflect ¶
func (x *LeaveRequest) ProtoReflect() protoreflect.Message
func (*LeaveRequest) Reset ¶
func (x *LeaveRequest) Reset()
func (*LeaveRequest) String ¶
func (x *LeaveRequest) String() string
type LeaveResponse ¶
type LeaveResponse struct { Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"` Code string `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"` Secret *NodeSecret `protobuf:"bytes,3,opt,name=secret,proto3" json:"secret,omitempty"` // contains filtered or unexported fields }
func (*LeaveResponse) Descriptor
deprecated
func (*LeaveResponse) Descriptor() ([]byte, []int)
Deprecated: Use LeaveResponse.ProtoReflect.Descriptor instead.
func (*LeaveResponse) GetCode ¶
func (x *LeaveResponse) GetCode() string
func (*LeaveResponse) GetMsg ¶
func (x *LeaveResponse) GetMsg() string
func (*LeaveResponse) GetSecret ¶
func (x *LeaveResponse) GetSecret() *NodeSecret
func (*LeaveResponse) ProtoMessage ¶
func (*LeaveResponse) ProtoMessage()
func (*LeaveResponse) ProtoReflect ¶
func (x *LeaveResponse) ProtoReflect() protoreflect.Message
func (*LeaveResponse) Reset ¶
func (x *LeaveResponse) Reset()
func (*LeaveResponse) String ¶
func (x *LeaveResponse) String() string
type ListRequest ¶
type ListRequest struct { Secret *NodeSecret `protobuf:"bytes,1,opt,name=secret,proto3" json:"secret,omitempty"` // contains filtered or unexported fields }
func (*ListRequest) Descriptor
deprecated
func (*ListRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.
func (*ListRequest) GetSecret ¶
func (x *ListRequest) GetSecret() *NodeSecret
func (*ListRequest) ProtoMessage ¶
func (*ListRequest) ProtoMessage()
func (*ListRequest) ProtoReflect ¶
func (x *ListRequest) ProtoReflect() protoreflect.Message
func (*ListRequest) Reset ¶
func (x *ListRequest) Reset()
func (*ListRequest) String ¶
func (x *ListRequest) String() string
type ListResponse ¶
type ListResponse struct { Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"` Code string `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"` Info []*NodeInfo `protobuf:"bytes,3,rep,name=info,proto3" json:"info,omitempty"` // contains filtered or unexported fields }
func (*ListResponse) Descriptor
deprecated
func (*ListResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.
func (*ListResponse) GetCode ¶
func (x *ListResponse) GetCode() string
func (*ListResponse) GetInfo ¶
func (x *ListResponse) GetInfo() []*NodeInfo
func (*ListResponse) GetMsg ¶
func (x *ListResponse) GetMsg() string
func (*ListResponse) ProtoMessage ¶
func (*ListResponse) ProtoMessage()
func (*ListResponse) ProtoReflect ¶
func (x *ListResponse) ProtoReflect() protoreflect.Message
func (*ListResponse) Reset ¶
func (x *ListResponse) Reset()
func (*ListResponse) String ¶
func (x *ListResponse) String() string
type MasterClient ¶
type MasterClient interface {
Hello(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (*HelloResponse, error)
}
MasterClient is the client API for Master 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 NewMasterClient ¶
func NewMasterClient(cc grpc.ClientConnInterface) MasterClient
type MasterServer ¶
type MasterServer interface { Hello(context.Context, *HelloRequest) (*HelloResponse, error) // contains filtered or unexported methods }
MasterServer is the server API for Master service. All implementations must embed UnimplementedMasterServer for forward compatibility
type NodeInfo ¶
type NodeInfo struct { NodeKey string `protobuf:"bytes,1,opt,name=nodeKey,proto3" json:"nodeKey,omitempty"` NodeID int32 `protobuf:"varint,2,opt,name=nodeID,proto3" json:"nodeID,omitempty"` Term int32 `protobuf:"varint,3,opt,name=term,proto3" json:"term,omitempty"` LeaderID int32 `protobuf:"varint,4,opt,name=leaderID,proto3" json:"leaderID,omitempty"` // status 状态:running | leave | stop | timeout Status string `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"` // role 角色 RaftState string `protobuf:"bytes,6,opt,name=raftState,proto3" json:"raftState,omitempty"` Addr string `protobuf:"bytes,7,opt,name=addr,proto3" json:"addr,omitempty"` // contains filtered or unexported fields }
func (*NodeInfo) Descriptor
deprecated
func (*NodeInfo) GetLeaderID ¶
func (*NodeInfo) GetNodeKey ¶
func (*NodeInfo) GetRaftState ¶
func (*NodeInfo) ProtoMessage ¶
func (*NodeInfo) ProtoMessage()
func (*NodeInfo) ProtoReflect ¶
func (x *NodeInfo) ProtoReflect() protoreflect.Message
type NodeSecret ¶
type NodeSecret struct { NodeKey string `protobuf:"bytes,1,opt,name=nodeKey,proto3" json:"nodeKey,omitempty"` NodeID int32 `protobuf:"varint,2,opt,name=nodeID,proto3" json:"nodeID,omitempty"` // contains filtered or unexported fields }
func (*NodeSecret) Descriptor
deprecated
func (*NodeSecret) Descriptor() ([]byte, []int)
Deprecated: Use NodeSecret.ProtoReflect.Descriptor instead.
func (*NodeSecret) GetNodeID ¶
func (x *NodeSecret) GetNodeID() int32
func (*NodeSecret) GetNodeKey ¶
func (x *NodeSecret) GetNodeKey() string
func (*NodeSecret) ProtoMessage ¶
func (*NodeSecret) ProtoMessage()
func (*NodeSecret) ProtoReflect ¶
func (x *NodeSecret) ProtoReflect() protoreflect.Message
func (*NodeSecret) Reset ¶
func (x *NodeSecret) Reset()
func (*NodeSecret) String ¶
func (x *NodeSecret) String() string
type Traffic ¶
type Traffic struct { FD uint64 `protobuf:"varint,1,opt,name=FD,proto3" json:"FD,omitempty"` Addr string `protobuf:"bytes,2,opt,name=Addr,proto3" json:"Addr,omitempty"` Network string `protobuf:"bytes,3,opt,name=Network,proto3" json:"Network,omitempty"` // contains filtered or unexported fields }
func (*Traffic) Descriptor
deprecated
func (*Traffic) GetNetwork ¶
func (*Traffic) ProtoMessage ¶
func (*Traffic) ProtoMessage()
func (*Traffic) ProtoReflect ¶
func (x *Traffic) ProtoReflect() protoreflect.Message
type UnimplementedCtiServiceServer ¶
type UnimplementedCtiServiceServer struct { }
UnimplementedCtiServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedCtiServiceServer) Info ¶
func (UnimplementedCtiServiceServer) Info(context.Context, *InfoRequest) (*InfoResponse, error)
func (UnimplementedCtiServiceServer) Join ¶
func (UnimplementedCtiServiceServer) Join(context.Context, *JoinRequest) (*JoinResponse, error)
func (UnimplementedCtiServiceServer) Leave ¶
func (UnimplementedCtiServiceServer) Leave(context.Context, *LeaveRequest) (*LeaveResponse, error)
func (UnimplementedCtiServiceServer) List ¶
func (UnimplementedCtiServiceServer) List(context.Context, *ListRequest) (*ListResponse, error)
type UnimplementedMasterServer ¶
type UnimplementedMasterServer struct { }
UnimplementedMasterServer must be embedded to have forward compatible implementations.
func (UnimplementedMasterServer) Hello ¶
func (UnimplementedMasterServer) Hello(context.Context, *HelloRequest) (*HelloResponse, error)
type UnimplementedWorkerServiceServer ¶
type UnimplementedWorkerServiceServer struct { }
UnimplementedWorkerServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedWorkerServiceServer) Delete ¶
func (UnimplementedWorkerServiceServer) Delete(context.Context, *WorkerDeleteRequest) (*WorkerDeleteResponse, error)
func (UnimplementedWorkerServiceServer) DeleteCheck ¶
func (UnimplementedWorkerServiceServer) DeleteCheck(context.Context, *WorkerDeleteRequest) (*WorkerDeleteResponse, error)
func (UnimplementedWorkerServiceServer) Ping ¶
func (UnimplementedWorkerServiceServer) Ping(context.Context, *WorkerHelloRequest) (*WorkerHelloResponse, error)
func (UnimplementedWorkerServiceServer) Refresh ¶ added in v0.1.1
func (UnimplementedWorkerServiceServer) Refresh(context.Context, *WorkerRefreshRequest) (*WorkerRefreshResponse, error)
func (UnimplementedWorkerServiceServer) Set ¶
func (UnimplementedWorkerServiceServer) Set(context.Context, *WorkerSetRequest) (*WorkerSetResponse, error)
func (UnimplementedWorkerServiceServer) SetCheck ¶
func (UnimplementedWorkerServiceServer) SetCheck(context.Context, *WorkerSetRequest) (*WorkerSetResponse, error)
type UnsafeCtiServiceServer ¶
type UnsafeCtiServiceServer interface {
// contains filtered or unexported methods
}
UnsafeCtiServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CtiServiceServer will result in compilation errors.
type UnsafeMasterServer ¶
type UnsafeMasterServer interface {
// contains filtered or unexported methods
}
UnsafeMasterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MasterServer will result in compilation errors.
type UnsafeWorkerServiceServer ¶
type UnsafeWorkerServiceServer interface {
// contains filtered or unexported methods
}
UnsafeWorkerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to WorkerServiceServer will result in compilation errors.
type WorkerConfig ¶
type WorkerConfig struct { Traffic *Traffic `protobuf:"bytes,1,opt,name=traffic,proto3" json:"traffic,omitempty"` Store []byte `protobuf:"bytes,2,opt,name=store,proto3" json:"store,omitempty"` // contains filtered or unexported fields }
func (*WorkerConfig) Descriptor
deprecated
func (*WorkerConfig) Descriptor() ([]byte, []int)
Deprecated: Use WorkerConfig.ProtoReflect.Descriptor instead.
func (*WorkerConfig) GetStore ¶
func (x *WorkerConfig) GetStore() []byte
func (*WorkerConfig) GetTraffic ¶
func (x *WorkerConfig) GetTraffic() *Traffic
func (*WorkerConfig) ProtoMessage ¶
func (*WorkerConfig) ProtoMessage()
func (*WorkerConfig) ProtoReflect ¶
func (x *WorkerConfig) ProtoReflect() protoreflect.Message
func (*WorkerConfig) Reset ¶
func (x *WorkerConfig) Reset()
func (*WorkerConfig) String ¶
func (x *WorkerConfig) String() string
type WorkerDeleteRequest ¶
type WorkerDeleteRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*WorkerDeleteRequest) Descriptor
deprecated
func (*WorkerDeleteRequest) Descriptor() ([]byte, []int)
Deprecated: Use WorkerDeleteRequest.ProtoReflect.Descriptor instead.
func (*WorkerDeleteRequest) GetId ¶
func (x *WorkerDeleteRequest) GetId() string
func (*WorkerDeleteRequest) ProtoMessage ¶
func (*WorkerDeleteRequest) ProtoMessage()
func (*WorkerDeleteRequest) ProtoReflect ¶
func (x *WorkerDeleteRequest) ProtoReflect() protoreflect.Message
func (*WorkerDeleteRequest) Reset ¶
func (x *WorkerDeleteRequest) Reset()
func (*WorkerDeleteRequest) String ¶
func (x *WorkerDeleteRequest) String() string
type WorkerDeleteResponse ¶
type WorkerDeleteResponse struct { Status WorkerStatusCode `protobuf:"varint,1,opt,name=status,proto3,enum=service.WorkerStatusCode" json:"status,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` Resource *WorkerResource `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"` // contains filtered or unexported fields }
func (*WorkerDeleteResponse) Descriptor
deprecated
func (*WorkerDeleteResponse) Descriptor() ([]byte, []int)
Deprecated: Use WorkerDeleteResponse.ProtoReflect.Descriptor instead.
func (*WorkerDeleteResponse) GetMessage ¶
func (x *WorkerDeleteResponse) GetMessage() string
func (*WorkerDeleteResponse) GetResource ¶
func (x *WorkerDeleteResponse) GetResource() *WorkerResource
func (*WorkerDeleteResponse) GetStatus ¶
func (x *WorkerDeleteResponse) GetStatus() WorkerStatusCode
func (*WorkerDeleteResponse) ProtoMessage ¶
func (*WorkerDeleteResponse) ProtoMessage()
func (*WorkerDeleteResponse) ProtoReflect ¶
func (x *WorkerDeleteResponse) ProtoReflect() protoreflect.Message
func (*WorkerDeleteResponse) Reset ¶
func (x *WorkerDeleteResponse) Reset()
func (*WorkerDeleteResponse) String ¶
func (x *WorkerDeleteResponse) String() string
type WorkerHelloRequest ¶
type WorkerHelloRequest struct { Hello string `protobuf:"bytes,1,opt,name=hello,proto3" json:"hello,omitempty"` // contains filtered or unexported fields }
func (*WorkerHelloRequest) Descriptor
deprecated
func (*WorkerHelloRequest) Descriptor() ([]byte, []int)
Deprecated: Use WorkerHelloRequest.ProtoReflect.Descriptor instead.
func (*WorkerHelloRequest) GetHello ¶
func (x *WorkerHelloRequest) GetHello() string
func (*WorkerHelloRequest) ProtoMessage ¶
func (*WorkerHelloRequest) ProtoMessage()
func (*WorkerHelloRequest) ProtoReflect ¶
func (x *WorkerHelloRequest) ProtoReflect() protoreflect.Message
func (*WorkerHelloRequest) Reset ¶
func (x *WorkerHelloRequest) Reset()
func (*WorkerHelloRequest) String ¶
func (x *WorkerHelloRequest) String() string
type WorkerHelloResponse ¶
type WorkerHelloResponse struct { Hello string `protobuf:"bytes,1,opt,name=hello,proto3" json:"hello,omitempty"` Resource *WorkerResource `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"` // contains filtered or unexported fields }
func (*WorkerHelloResponse) Descriptor
deprecated
func (*WorkerHelloResponse) Descriptor() ([]byte, []int)
Deprecated: Use WorkerHelloResponse.ProtoReflect.Descriptor instead.
func (*WorkerHelloResponse) GetHello ¶
func (x *WorkerHelloResponse) GetHello() string
func (*WorkerHelloResponse) GetResource ¶
func (x *WorkerHelloResponse) GetResource() *WorkerResource
func (*WorkerHelloResponse) ProtoMessage ¶
func (*WorkerHelloResponse) ProtoMessage()
func (*WorkerHelloResponse) ProtoReflect ¶
func (x *WorkerHelloResponse) ProtoReflect() protoreflect.Message
func (*WorkerHelloResponse) Reset ¶
func (x *WorkerHelloResponse) Reset()
func (*WorkerHelloResponse) String ¶
func (x *WorkerHelloResponse) String() string
type WorkerRefreshRequest ¶ added in v0.1.1
type WorkerRefreshRequest struct { Ports []int32 `protobuf:"varint,1,rep,packed,name=ports,proto3" json:"ports,omitempty"` // contains filtered or unexported fields }
func (*WorkerRefreshRequest) Descriptor
deprecated
added in
v0.1.1
func (*WorkerRefreshRequest) Descriptor() ([]byte, []int)
Deprecated: Use WorkerRefreshRequest.ProtoReflect.Descriptor instead.
func (*WorkerRefreshRequest) GetPorts ¶ added in v0.1.1
func (x *WorkerRefreshRequest) GetPorts() []int32
func (*WorkerRefreshRequest) ProtoMessage ¶ added in v0.1.1
func (*WorkerRefreshRequest) ProtoMessage()
func (*WorkerRefreshRequest) ProtoReflect ¶ added in v0.1.1
func (x *WorkerRefreshRequest) ProtoReflect() protoreflect.Message
func (*WorkerRefreshRequest) Reset ¶ added in v0.1.1
func (x *WorkerRefreshRequest) Reset()
func (*WorkerRefreshRequest) String ¶ added in v0.1.1
func (x *WorkerRefreshRequest) String() string
type WorkerRefreshResponse ¶ added in v0.1.1
type WorkerRefreshResponse struct { Status WorkerStatusCode `protobuf:"varint,1,opt,name=status,proto3,enum=service.WorkerStatusCode" json:"status,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*WorkerRefreshResponse) Descriptor
deprecated
added in
v0.1.1
func (*WorkerRefreshResponse) Descriptor() ([]byte, []int)
Deprecated: Use WorkerRefreshResponse.ProtoReflect.Descriptor instead.
func (*WorkerRefreshResponse) GetMessage ¶ added in v0.1.1
func (x *WorkerRefreshResponse) GetMessage() string
func (*WorkerRefreshResponse) GetStatus ¶ added in v0.1.1
func (x *WorkerRefreshResponse) GetStatus() WorkerStatusCode
func (*WorkerRefreshResponse) ProtoMessage ¶ added in v0.1.1
func (*WorkerRefreshResponse) ProtoMessage()
func (*WorkerRefreshResponse) ProtoReflect ¶ added in v0.1.1
func (x *WorkerRefreshResponse) ProtoReflect() protoreflect.Message
func (*WorkerRefreshResponse) Reset ¶ added in v0.1.1
func (x *WorkerRefreshResponse) Reset()
func (*WorkerRefreshResponse) String ¶ added in v0.1.1
func (x *WorkerRefreshResponse) String() string
type WorkerResource ¶
type WorkerResource struct { Port []int32 `protobuf:"varint,1,rep,packed,name=port,proto3" json:"port,omitempty"` // contains filtered or unexported fields }
func (*WorkerResource) Descriptor
deprecated
func (*WorkerResource) Descriptor() ([]byte, []int)
Deprecated: Use WorkerResource.ProtoReflect.Descriptor instead.
func (*WorkerResource) GetPort ¶
func (x *WorkerResource) GetPort() []int32
func (*WorkerResource) ProtoMessage ¶
func (*WorkerResource) ProtoMessage()
func (*WorkerResource) ProtoReflect ¶
func (x *WorkerResource) ProtoReflect() protoreflect.Message
func (*WorkerResource) Reset ¶
func (x *WorkerResource) Reset()
func (*WorkerResource) String ¶
func (x *WorkerResource) String() string
type WorkerServiceClient ¶
type WorkerServiceClient interface { DeleteCheck(ctx context.Context, in *WorkerDeleteRequest, opts ...grpc.CallOption) (*WorkerDeleteResponse, error) SetCheck(ctx context.Context, in *WorkerSetRequest, opts ...grpc.CallOption) (*WorkerSetResponse, error) Delete(ctx context.Context, in *WorkerDeleteRequest, opts ...grpc.CallOption) (*WorkerDeleteResponse, error) Set(ctx context.Context, in *WorkerSetRequest, opts ...grpc.CallOption) (*WorkerSetResponse, error) Ping(ctx context.Context, in *WorkerHelloRequest, opts ...grpc.CallOption) (*WorkerHelloResponse, error) Refresh(ctx context.Context, in *WorkerRefreshRequest, opts ...grpc.CallOption) (*WorkerRefreshResponse, error) }
WorkerServiceClient is the client API for WorkerService 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 NewWorkerServiceClient ¶
func NewWorkerServiceClient(cc grpc.ClientConnInterface) WorkerServiceClient
type WorkerServiceServer ¶
type WorkerServiceServer interface { DeleteCheck(context.Context, *WorkerDeleteRequest) (*WorkerDeleteResponse, error) SetCheck(context.Context, *WorkerSetRequest) (*WorkerSetResponse, error) Delete(context.Context, *WorkerDeleteRequest) (*WorkerDeleteResponse, error) Set(context.Context, *WorkerSetRequest) (*WorkerSetResponse, error) Ping(context.Context, *WorkerHelloRequest) (*WorkerHelloResponse, error) Refresh(context.Context, *WorkerRefreshRequest) (*WorkerRefreshResponse, error) // contains filtered or unexported methods }
WorkerServiceServer is the server API for WorkerService service. All implementations must embed UnimplementedWorkerServiceServer for forward compatibility
type WorkerSetRequest ¶
type WorkerSetRequest struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Profession string `protobuf:"bytes,2,opt,name=profession,proto3" json:"profession,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` Driver string `protobuf:"bytes,4,opt,name=driver,proto3" json:"driver,omitempty"` Body []byte `protobuf:"bytes,5,opt,name=body,proto3" json:"body,omitempty"` // contains filtered or unexported fields }
func (*WorkerSetRequest) Descriptor
deprecated
func (*WorkerSetRequest) Descriptor() ([]byte, []int)
Deprecated: Use WorkerSetRequest.ProtoReflect.Descriptor instead.
func (*WorkerSetRequest) GetBody ¶
func (x *WorkerSetRequest) GetBody() []byte
func (*WorkerSetRequest) GetDriver ¶
func (x *WorkerSetRequest) GetDriver() string
func (*WorkerSetRequest) GetId ¶
func (x *WorkerSetRequest) GetId() string
func (*WorkerSetRequest) GetName ¶
func (x *WorkerSetRequest) GetName() string
func (*WorkerSetRequest) GetProfession ¶
func (x *WorkerSetRequest) GetProfession() string
func (*WorkerSetRequest) ProtoMessage ¶
func (*WorkerSetRequest) ProtoMessage()
func (*WorkerSetRequest) ProtoReflect ¶
func (x *WorkerSetRequest) ProtoReflect() protoreflect.Message
func (*WorkerSetRequest) Reset ¶
func (x *WorkerSetRequest) Reset()
func (*WorkerSetRequest) String ¶
func (x *WorkerSetRequest) String() string
type WorkerSetResponse ¶
type WorkerSetResponse struct { Status WorkerStatusCode `protobuf:"varint,1,opt,name=status,proto3,enum=service.WorkerStatusCode" json:"status,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` Resource *WorkerResource `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"` // contains filtered or unexported fields }
func (*WorkerSetResponse) Descriptor
deprecated
func (*WorkerSetResponse) Descriptor() ([]byte, []int)
Deprecated: Use WorkerSetResponse.ProtoReflect.Descriptor instead.
func (*WorkerSetResponse) GetMessage ¶
func (x *WorkerSetResponse) GetMessage() string
func (*WorkerSetResponse) GetResource ¶
func (x *WorkerSetResponse) GetResource() *WorkerResource
func (*WorkerSetResponse) GetStatus ¶
func (x *WorkerSetResponse) GetStatus() WorkerStatusCode
func (*WorkerSetResponse) ProtoMessage ¶
func (*WorkerSetResponse) ProtoMessage()
func (*WorkerSetResponse) ProtoReflect ¶
func (x *WorkerSetResponse) ProtoReflect() protoreflect.Message
func (*WorkerSetResponse) Reset ¶
func (x *WorkerSetResponse) Reset()
func (*WorkerSetResponse) String ¶
func (x *WorkerSetResponse) String() string
type WorkerStatusCode ¶
type WorkerStatusCode int32
const ( WorkerStatusCode_SUCCESS WorkerStatusCode = 0 WorkerStatusCode_FAIL WorkerStatusCode = 1 WorkerStatusCode_SKILL WorkerStatusCode = 2 )
func (WorkerStatusCode) Descriptor ¶
func (WorkerStatusCode) Descriptor() protoreflect.EnumDescriptor
func (WorkerStatusCode) Enum ¶
func (x WorkerStatusCode) Enum() *WorkerStatusCode
func (WorkerStatusCode) EnumDescriptor
deprecated
func (WorkerStatusCode) EnumDescriptor() ([]byte, []int)
Deprecated: Use WorkerStatusCode.Descriptor instead.
func (WorkerStatusCode) Number ¶
func (x WorkerStatusCode) Number() protoreflect.EnumNumber
func (WorkerStatusCode) String ¶
func (x WorkerStatusCode) String() string
func (WorkerStatusCode) Type ¶
func (WorkerStatusCode) Type() protoreflect.EnumType