service

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Oct 14, 2021 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

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

View Source 
var File_service_ctl_proto protoreflect.FileDescriptor
View Source 
var File_service_master_proto protoreflect.FileDescriptor
View Source 
var File_service_service_proto protoreflect.FileDescriptor
View Source 
var File_service_worker_proto protoreflect.FileDescriptor
View Source 
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)

View Source 
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 MasterServerAddr(app string, pid int) string

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 

func WorkerServerAddr(app string, pid int) string

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

Deprecated: Use EnvConfig.ProtoReflect.Descriptor instead.

func (*EnvConfig) GetKey 

func (x *EnvConfig) GetKey() string

func (*EnvConfig) GetValue 

func (x *EnvConfig) GetValue() string

func (*EnvConfig) ProtoMessage 

func (*EnvConfig) ProtoMessage()

func (*EnvConfig) ProtoReflect 

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

func (*EnvConfig) Reset 

func (x *EnvConfig) Reset()

func (*EnvConfig) String 

func (x *EnvConfig) String() string

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetCode 

func (x *Error) GetCode() int64

func (*Error) GetError 

func (x *Error) GetError() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect 

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

func (*Error) Reset 

func (x *Error) Reset()

func (*Error) String 

func (x *Error) String() string

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

Deprecated: Use NodeInfo.ProtoReflect.Descriptor instead.

func (*NodeInfo) GetAddr 

func (x *NodeInfo) GetAddr() string

func (*NodeInfo) GetLeaderID 

func (x *NodeInfo) GetLeaderID() int32

func (*NodeInfo) GetNodeID 

func (x *NodeInfo) GetNodeID() int32

func (*NodeInfo) GetNodeKey 

func (x *NodeInfo) GetNodeKey() string

func (*NodeInfo) GetRaftState 

func (x *NodeInfo) GetRaftState() string

func (*NodeInfo) GetStatus 

func (x *NodeInfo) GetStatus() string

func (*NodeInfo) GetTerm 

func (x *NodeInfo) GetTerm() int32

func (*NodeInfo) ProtoMessage 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) ProtoReflect 

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

func (*NodeInfo) Reset 

func (x *NodeInfo) Reset()

func (*NodeInfo) String 

func (x *NodeInfo) String() string

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

Deprecated: Use Traffic.ProtoReflect.Descriptor instead.

func (*Traffic) GetAddr 

func (x *Traffic) GetAddr() string

func (*Traffic) GetFD 

func (x *Traffic) GetFD() uint64

func (*Traffic) GetNetwork 

func (x *Traffic) GetNetwork() string

func (*Traffic) ProtoMessage 

func (*Traffic) ProtoMessage()

func (*Traffic) ProtoReflect 

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

func (*Traffic) Reset 

func (x *Traffic) Reset()

func (*Traffic) String 

func (x *Traffic) String() string

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.