service

package
v0.3.5 Latest Latest
Warning

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

 Go to latest Published: Nov 30, 2021 License: Apache-2.0 Imports: 12 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,
		},
		{
			MethodName: "ExtendsInstall",
			Handler:    _CtiService_ExtendsInstall_Handler,
		},
		{
			MethodName: "ExtendsUpdate",
			Handler:    _CtiService_ExtendsUpdate_Handler,
		},
		{
			MethodName: "ExtendsUninstall",
			Handler:    _CtiService_ExtendsUninstall_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "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_ctl_proto protoreflect.FileDescriptor
View Source 
var File_extender_proto protoreflect.FileDescriptor
View Source 
var File_master_proto protoreflect.FileDescriptor
View Source 
var File_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: "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: "reset",
			Handler:    _WorkerService_Reset_Handler,
		},
		{
			MethodName: "status",
			Handler:    _WorkerService_Status_Handler,
		},
		{
			MethodName: "addExtender",
			Handler:    _WorkerService_AddExtender_Handler,
		},
		{
			MethodName: "delExtenderCheck",
			Handler:    _WorkerService_DelExtenderCheck_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "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(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(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)
	ExtendsInstall(ctx context.Context, in *ExtendsRequest, opts ...grpc.CallOption) (*ExtendsResponse, error)
	ExtendsUpdate(ctx context.Context, in *ExtendsRequest, opts ...grpc.CallOption) (*ExtendsResponse, error)
	ExtendsUninstall(ctx context.Context, in *ExtendsRequest, opts ...grpc.CallOption) (*ExtendsUninstallResponse, 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)
	ExtendsInstall(context.Context, *ExtendsRequest) (*ExtendsResponse, error)
	ExtendsUpdate(context.Context, *ExtendsRequest) (*ExtendsResponse, error)
	ExtendsUninstall(context.Context, *ExtendsRequest) (*ExtendsUninstallResponse, 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 ExtendsBasicInfo added in v0.3.0 

type ExtendsBasicInfo struct {
	Group   string `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	Project string `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	Msg     string `protobuf:"bytes,4,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*ExtendsBasicInfo) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use ExtendsBasicInfo.ProtoReflect.Descriptor instead.

func (*ExtendsBasicInfo) GetGroup added in v0.3.0 

func (x *ExtendsBasicInfo) GetGroup() string

func (*ExtendsBasicInfo) GetMsg added in v0.3.3 

func (x *ExtendsBasicInfo) GetMsg() string

func (*ExtendsBasicInfo) GetProject added in v0.3.0 

func (x *ExtendsBasicInfo) GetProject() string

func (*ExtendsBasicInfo) GetVersion added in v0.3.0 

func (x *ExtendsBasicInfo) GetVersion() string

func (*ExtendsBasicInfo) ProtoMessage added in v0.3.0 

func (*ExtendsBasicInfo) ProtoMessage()

func (*ExtendsBasicInfo) ProtoReflect added in v0.3.0 

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

func (*ExtendsBasicInfo) Reset added in v0.3.0 

func (x *ExtendsBasicInfo) Reset()

func (*ExtendsBasicInfo) String added in v0.3.0 

func (x *ExtendsBasicInfo) String() string

type ExtendsInfo added in v0.3.0 

type ExtendsInfo struct {
	Id      string    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name    string    `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Group   string    `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"`
	Project string    `protobuf:"bytes,4,opt,name=project,proto3" json:"project,omitempty"`
	Version string    `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	Plugins []*Plugin `protobuf:"bytes,6,rep,name=plugins,proto3" json:"plugins,omitempty"`
	// contains filtered or unexported fields
}

func (*ExtendsInfo) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use ExtendsInfo.ProtoReflect.Descriptor instead.

func (*ExtendsInfo) GetGroup added in v0.3.0 

func (x *ExtendsInfo) GetGroup() string

func (*ExtendsInfo) GetId added in v0.3.0 

func (x *ExtendsInfo) GetId() string

func (*ExtendsInfo) GetName added in v0.3.0 

func (x *ExtendsInfo) GetName() string

func (*ExtendsInfo) GetPlugins added in v0.3.0 

func (x *ExtendsInfo) GetPlugins() []*Plugin

func (*ExtendsInfo) GetProject added in v0.3.0 

func (x *ExtendsInfo) GetProject() string

func (*ExtendsInfo) GetVersion added in v0.3.0 

func (x *ExtendsInfo) GetVersion() string

func (*ExtendsInfo) ProtoMessage added in v0.3.0 

func (*ExtendsInfo) ProtoMessage()

func (*ExtendsInfo) ProtoReflect added in v0.3.0 

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

func (*ExtendsInfo) Reset added in v0.3.0 

func (x *ExtendsInfo) Reset()

func (*ExtendsInfo) String added in v0.3.0 

func (x *ExtendsInfo) String() string

type ExtendsInstallRequest added in v0.3.0 

type ExtendsInstallRequest struct {
	Extends []*ExtendsBasicInfo `protobuf:"bytes,1,rep,name=extends,proto3" json:"extends,omitempty"`
	// contains filtered or unexported fields
}

func (*ExtendsInstallRequest) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use ExtendsInstallRequest.ProtoReflect.Descriptor instead.

func (*ExtendsInstallRequest) GetExtends added in v0.3.0 

func (x *ExtendsInstallRequest) GetExtends() []*ExtendsBasicInfo

func (*ExtendsInstallRequest) ProtoMessage added in v0.3.0 

func (*ExtendsInstallRequest) ProtoMessage()

func (*ExtendsInstallRequest) ProtoReflect added in v0.3.0 

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

func (*ExtendsInstallRequest) Reset added in v0.3.0 

func (x *ExtendsInstallRequest) Reset()

func (*ExtendsInstallRequest) String added in v0.3.0 

func (x *ExtendsInstallRequest) String() string

type ExtendsRequest added in v0.3.0 

type ExtendsRequest struct {
	Extends []*ExtendsBasicInfo `protobuf:"bytes,1,rep,name=extends,proto3" json:"extends,omitempty"`
	// contains filtered or unexported fields
}

func (*ExtendsRequest) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use ExtendsRequest.ProtoReflect.Descriptor instead.

func (*ExtendsRequest) GetExtends added in v0.3.0 

func (x *ExtendsRequest) GetExtends() []*ExtendsBasicInfo

func (*ExtendsRequest) ProtoMessage added in v0.3.0 

func (*ExtendsRequest) ProtoMessage()

func (*ExtendsRequest) ProtoReflect added in v0.3.0 

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

func (*ExtendsRequest) Reset added in v0.3.0 

func (x *ExtendsRequest) Reset()

func (*ExtendsRequest) String added in v0.3.0 

func (x *ExtendsRequest) String() string

type ExtendsResponse added in v0.3.0 

type ExtendsResponse 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"`
	Extends     []*ExtendsInfo      `protobuf:"bytes,3,rep,name=extends,proto3" json:"extends,omitempty"`
	FailExtends []*ExtendsBasicInfo `protobuf:"bytes,4,rep,name=failExtends,proto3" json:"failExtends,omitempty"`
	// contains filtered or unexported fields
}

func (*ExtendsResponse) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use ExtendsResponse.ProtoReflect.Descriptor instead.

func (*ExtendsResponse) GetCode added in v0.3.0 

func (x *ExtendsResponse) GetCode() string

func (*ExtendsResponse) GetExtends added in v0.3.0 

func (x *ExtendsResponse) GetExtends() []*ExtendsInfo

func (*ExtendsResponse) GetFailExtends added in v0.3.3 

func (x *ExtendsResponse) GetFailExtends() []*ExtendsBasicInfo

func (*ExtendsResponse) GetMsg added in v0.3.0 

func (x *ExtendsResponse) GetMsg() string

func (*ExtendsResponse) ProtoMessage added in v0.3.0 

func (*ExtendsResponse) ProtoMessage()

func (*ExtendsResponse) ProtoReflect added in v0.3.0 

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

func (*ExtendsResponse) Reset added in v0.3.0 

func (x *ExtendsResponse) Reset()

func (*ExtendsResponse) String added in v0.3.0 

func (x *ExtendsResponse) String() string

type ExtendsUninstallResponse added in v0.3.0 

type ExtendsUninstallResponse 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"`
	Extends     []*ExtendsBasicInfo `protobuf:"bytes,3,rep,name=extends,proto3" json:"extends,omitempty"`
	FailExtends []*ExtendsBasicInfo `protobuf:"bytes,4,rep,name=failExtends,proto3" json:"failExtends,omitempty"`
	// contains filtered or unexported fields
}

func (*ExtendsUninstallResponse) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use ExtendsUninstallResponse.ProtoReflect.Descriptor instead.

func (*ExtendsUninstallResponse) GetCode added in v0.3.0 

func (x *ExtendsUninstallResponse) GetCode() string

func (*ExtendsUninstallResponse) GetExtends added in v0.3.0 

func (x *ExtendsUninstallResponse) GetExtends() []*ExtendsBasicInfo

func (*ExtendsUninstallResponse) GetFailExtends added in v0.3.3 

func (x *ExtendsUninstallResponse) GetFailExtends() []*ExtendsBasicInfo

func (*ExtendsUninstallResponse) GetMsg added in v0.3.0 

func (x *ExtendsUninstallResponse) GetMsg() string

func (*ExtendsUninstallResponse) ProtoMessage added in v0.3.0 

func (*ExtendsUninstallResponse) ProtoMessage()

func (*ExtendsUninstallResponse) ProtoReflect added in v0.3.0 

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

func (*ExtendsUninstallResponse) Reset added in v0.3.0 

func (x *ExtendsUninstallResponse) Reset()

func (*ExtendsUninstallResponse) String added in v0.3.0 

func (x *ExtendsUninstallResponse) String() string

type ExtendsUpdateRequest added in v0.3.0 

type ExtendsUpdateRequest struct {
	Extends []*ExtendsBasicInfo `protobuf:"bytes,1,rep,name=extends,proto3" json:"extends,omitempty"`
	// contains filtered or unexported fields
}

func (*ExtendsUpdateRequest) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use ExtendsUpdateRequest.ProtoReflect.Descriptor instead.

func (*ExtendsUpdateRequest) GetExtends added in v0.3.0 

func (x *ExtendsUpdateRequest) GetExtends() []*ExtendsBasicInfo

func (*ExtendsUpdateRequest) ProtoMessage added in v0.3.0 

func (*ExtendsUpdateRequest) ProtoMessage()

func (*ExtendsUpdateRequest) ProtoReflect added in v0.3.0 

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

func (*ExtendsUpdateRequest) Reset added in v0.3.0 

func (x *ExtendsUpdateRequest) Reset()

func (*ExtendsUpdateRequest) String added in v0.3.0 

func (x *ExtendsUpdateRequest) 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 Plugin added in v0.3.0 

type Plugin struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // {group}:{project}:{name}
	Name    string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Group   string `protobuf:"bytes,3,opt,name=group,proto3" json:"group,omitempty"`
	Project string `protobuf:"bytes,4,opt,name=project,proto3" json:"project,omitempty"`
	// contains filtered or unexported fields
}

func (*Plugin) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use Plugin.ProtoReflect.Descriptor instead.

func (*Plugin) GetGroup added in v0.3.0 

func (x *Plugin) GetGroup() string

func (*Plugin) GetId added in v0.3.0 

func (x *Plugin) GetId() string

func (*Plugin) GetName added in v0.3.0 

func (x *Plugin) GetName() string

func (*Plugin) GetProject added in v0.3.0 

func (x *Plugin) GetProject() string

func (*Plugin) ProtoMessage added in v0.3.0 

func (*Plugin) ProtoMessage()

func (*Plugin) ProtoReflect added in v0.3.0 

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

func (*Plugin) Reset added in v0.3.0 

func (x *Plugin) Reset()

func (*Plugin) String added in v0.3.0 

func (x *Plugin) String() string

type ResetRequest added in v0.3.0 

type ResetRequest struct {
	Professions []*eosc.ProfessionConfig `protobuf:"bytes,2,rep,name=professions,proto3" json:"professions,omitempty"`
	Workers     []*eosc.WorkerConfig     `protobuf:"bytes,3,rep,name=workers,proto3" json:"workers,omitempty"`
	// contains filtered or unexported fields
}

func (*ResetRequest) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use ResetRequest.ProtoReflect.Descriptor instead.

func (*ResetRequest) GetProfessions added in v0.3.0 

func (x *ResetRequest) GetProfessions() []*eosc.ProfessionConfig

func (*ResetRequest) GetWorkers added in v0.3.0 

func (x *ResetRequest) GetWorkers() []*eosc.WorkerConfig

func (*ResetRequest) ProtoMessage added in v0.3.0 

func (*ResetRequest) ProtoMessage()

func (*ResetRequest) ProtoReflect added in v0.3.0 

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

func (*ResetRequest) Reset added in v0.3.0 

func (x *ResetRequest) Reset()

func (*ResetRequest) String added in v0.3.0 

func (x *ResetRequest) String() string

type StatusRequest added in v0.3.0 

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

func (*StatusRequest) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.

func (*StatusRequest) ProtoMessage added in v0.3.0 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) ProtoReflect added in v0.3.0 

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

func (*StatusRequest) Reset added in v0.3.0 

func (x *StatusRequest) Reset()

func (*StatusRequest) String added in v0.3.0 

func (x *StatusRequest) String() string

type StatusResponse added in v0.3.0 

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

func (*StatusResponse) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) ProtoMessage added in v0.3.0 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) ProtoReflect added in v0.3.0 

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

func (*StatusResponse) Reset added in v0.3.0 

func (x *StatusResponse) Reset()

func (*StatusResponse) String added in v0.3.0 

func (x *StatusResponse) String() string

type UnimplementedCtiServiceServer 

type UnimplementedCtiServiceServer struct {
}

UnimplementedCtiServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedCtiServiceServer) ExtendsInstall added in v0.3.0 

func (UnimplementedCtiServiceServer) ExtendsInstall(context.Context, *ExtendsRequest) (*ExtendsResponse, error)

func (UnimplementedCtiServiceServer) ExtendsUninstall added in v0.3.0 

func (UnimplementedCtiServiceServer) ExtendsUninstall(context.Context, *ExtendsRequest) (*ExtendsUninstallResponse, error)

func (UnimplementedCtiServiceServer) ExtendsUpdate added in v0.3.0 

func (UnimplementedCtiServiceServer) ExtendsUpdate(context.Context, *ExtendsRequest) (*ExtendsResponse, error)

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) AddExtender added in v0.3.0 

func (UnimplementedWorkerServiceServer) AddExtender(context.Context, *WorkerAddExtender) (*WorkerResponse, error)

func (UnimplementedWorkerServiceServer) DelExtenderCheck added in v0.3.0 

func (UnimplementedWorkerServiceServer) DelExtenderCheck(context.Context, *WorkerDelExtender) (*WorkerResponse, error)

func (UnimplementedWorkerServiceServer) Delete 

func (UnimplementedWorkerServiceServer) Delete(context.Context, *WorkerDeleteRequest) (*WorkerResponse, error)

func (UnimplementedWorkerServiceServer) DeleteCheck 

func (UnimplementedWorkerServiceServer) DeleteCheck(context.Context, *WorkerDeleteRequest) (*WorkerResponse, error)

func (UnimplementedWorkerServiceServer) Ping 

func (UnimplementedWorkerServiceServer) Ping(context.Context, *WorkerHelloRequest) (*WorkerResponse, error)

func (UnimplementedWorkerServiceServer) Reset added in v0.3.0 

func (UnimplementedWorkerServiceServer) Reset(context.Context, *ResetRequest) (*WorkerResponse, error)

func (UnimplementedWorkerServiceServer) Set 

func (UnimplementedWorkerServiceServer) Set(context.Context, *WorkerSetRequest) (*WorkerResponse, error)

func (UnimplementedWorkerServiceServer) SetCheck 

func (UnimplementedWorkerServiceServer) SetCheck(context.Context, *WorkerSetRequest) (*WorkerResponse, error)

func (UnimplementedWorkerServiceServer) Status added in v0.3.0 

func (UnimplementedWorkerServiceServer) Status(context.Context, *StatusRequest) (*StatusResponse, 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 WorkerAddExtender added in v0.3.0 

type WorkerAddExtender struct {
	Extenders map[string]string `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*WorkerAddExtender) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use WorkerAddExtender.ProtoReflect.Descriptor instead.

func (*WorkerAddExtender) GetExtenders added in v0.3.0 

func (x *WorkerAddExtender) GetExtenders() map[string]string

func (*WorkerAddExtender) ProtoMessage added in v0.3.0 

func (*WorkerAddExtender) ProtoMessage()

func (*WorkerAddExtender) ProtoReflect added in v0.3.0 

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

func (*WorkerAddExtender) Reset added in v0.3.0 

func (x *WorkerAddExtender) Reset()

func (*WorkerAddExtender) String added in v0.3.0 

func (x *WorkerAddExtender) String() string

type WorkerDelExtender added in v0.3.0 

type WorkerDelExtender struct {
	Extenders []string `protobuf:"bytes,1,rep,name=extenders,proto3" json:"extenders,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerDelExtender) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use WorkerDelExtender.ProtoReflect.Descriptor instead.

func (*WorkerDelExtender) GetExtenders added in v0.3.0 

func (x *WorkerDelExtender) GetExtenders() []string

func (*WorkerDelExtender) ProtoMessage added in v0.3.0 

func (*WorkerDelExtender) ProtoMessage()

func (*WorkerDelExtender) ProtoReflect added in v0.3.0 

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

func (*WorkerDelExtender) Reset added in v0.3.0 

func (x *WorkerDelExtender) Reset()

func (*WorkerDelExtender) String added in v0.3.0 

func (x *WorkerDelExtender) 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 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 WorkerLoadArg added in v0.3.0 

type WorkerLoadArg struct {
	Traffic         []*traffic.PbTraffic     `protobuf:"bytes,1,rep,name=traffic,proto3" json:"traffic,omitempty"`
	ListensMsg      *config.ListensMsg       `protobuf:"bytes,2,opt,name=listensMsg,proto3" json:"listensMsg,omitempty"`
	ExtenderSetting map[string]string        `` /* 171-byte string literal not displayed */
	Professions     []*eosc.ProfessionConfig `protobuf:"bytes,4,rep,name=professions,proto3" json:"professions,omitempty"`
	Workers         []*eosc.WorkerConfig     `protobuf:"bytes,5,rep,name=workers,proto3" json:"workers,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerLoadArg) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use WorkerLoadArg.ProtoReflect.Descriptor instead.

func (*WorkerLoadArg) GetExtenderSetting added in v0.3.0 

func (x *WorkerLoadArg) GetExtenderSetting() map[string]string

func (*WorkerLoadArg) GetListensMsg added in v0.3.0 

func (x *WorkerLoadArg) GetListensMsg() *config.ListensMsg

func (*WorkerLoadArg) GetProfessions added in v0.3.0 

func (x *WorkerLoadArg) GetProfessions() []*eosc.ProfessionConfig

func (*WorkerLoadArg) GetTraffic added in v0.3.0 

func (x *WorkerLoadArg) GetTraffic() []*traffic.PbTraffic

func (*WorkerLoadArg) GetWorkers added in v0.3.0 

func (x *WorkerLoadArg) GetWorkers() []*eosc.WorkerConfig

func (*WorkerLoadArg) ProtoMessage added in v0.3.0 

func (*WorkerLoadArg) ProtoMessage()

func (*WorkerLoadArg) ProtoReflect added in v0.3.0 

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

func (*WorkerLoadArg) Reset added in v0.3.0 

func (x *WorkerLoadArg) Reset()

func (*WorkerLoadArg) String added in v0.3.0 

func (x *WorkerLoadArg) String() string

type WorkerResponse added in v0.3.0 

type WorkerResponse 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 (*WorkerResponse) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use WorkerResponse.ProtoReflect.Descriptor instead.

func (*WorkerResponse) GetMessage added in v0.3.0 

func (x *WorkerResponse) GetMessage() string

func (*WorkerResponse) GetStatus added in v0.3.0 

func (x *WorkerResponse) GetStatus() WorkerStatusCode

func (*WorkerResponse) ProtoMessage added in v0.3.0 

func (*WorkerResponse) ProtoMessage()

func (*WorkerResponse) ProtoReflect added in v0.3.0 

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

func (*WorkerResponse) Reset added in v0.3.0 

func (x *WorkerResponse) Reset()

func (*WorkerResponse) String added in v0.3.0 

func (x *WorkerResponse) String() string

type WorkerServiceClient 

type WorkerServiceClient interface {
	DeleteCheck(ctx context.Context, in *WorkerDeleteRequest, opts ...grpc.CallOption) (*WorkerResponse, error)
	SetCheck(ctx context.Context, in *WorkerSetRequest, opts ...grpc.CallOption) (*WorkerResponse, error)
	Delete(ctx context.Context, in *WorkerDeleteRequest, opts ...grpc.CallOption) (*WorkerResponse, error)
	Set(ctx context.Context, in *WorkerSetRequest, opts ...grpc.CallOption) (*WorkerResponse, error)
	Ping(ctx context.Context, in *WorkerHelloRequest, opts ...grpc.CallOption) (*WorkerResponse, error)
	Reset(ctx context.Context, in *ResetRequest, opts ...grpc.CallOption) (*WorkerResponse, error)
	Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	AddExtender(ctx context.Context, in *WorkerAddExtender, opts ...grpc.CallOption) (*WorkerResponse, error)
	DelExtenderCheck(ctx context.Context, in *WorkerDelExtender, opts ...grpc.CallOption) (*WorkerResponse, 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) (*WorkerResponse, error)
	SetCheck(context.Context, *WorkerSetRequest) (*WorkerResponse, error)
	Delete(context.Context, *WorkerDeleteRequest) (*WorkerResponse, error)
	Set(context.Context, *WorkerSetRequest) (*WorkerResponse, error)
	Ping(context.Context, *WorkerHelloRequest) (*WorkerResponse, error)
	Reset(context.Context, *ResetRequest) (*WorkerResponse, error)
	Status(context.Context, *StatusRequest) (*StatusResponse, error)
	AddExtender(context.Context, *WorkerAddExtender) (*WorkerResponse, error)
	DelExtenderCheck(context.Context, *WorkerDelExtender) (*WorkerResponse, 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 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.