server

Documentation

Index

• Variables
• func RegisterJobExecutorRegisterServer(s grpc.ServiceRegistrar, srv JobExecutorRegisterServer)
• type JobExecutorRegisterClient
  • func NewJobExecutorRegisterClient(cc grpc.ClientConnInterface) JobExecutorRegisterClient
• type JobExecutorRegisterServer
• type RegistryReply
  • func (*RegistryReply) Descriptor() ([]byte, []int)
  • func (x *RegistryReply) GetMessage() string
  • func (*RegistryReply) ProtoMessage()
  • func (x *RegistryReply) ProtoReflect() protoreflect.Message
  • func (x *RegistryReply) Reset()
  • func (x *RegistryReply) String() string
• type RegistryRequest
  • func (*RegistryRequest) Descriptor() ([]byte, []int)
  • func (x *RegistryRequest) GetServerList() []string
  • func (x *RegistryRequest) GetServerName() string
  • func (*RegistryRequest) ProtoMessage()
  • func (x *RegistryRequest) ProtoReflect() protoreflect.Message
  • func (x *RegistryRequest) Reset()
  • func (x *RegistryRequest) String() string
• type RpcServer
  • func (s *RpcServer) ExecutorRegistry(_ context.Context, in *RegistryRequest) (*RegistryReply, error)
  • func (s *RpcServer) ExecutorUnRegistry(_ context.Context, in *RegistryRequest) (*RegistryReply, error)
• type UnimplementedJobExecutorRegisterServer
  • func (UnimplementedJobExecutorRegisterServer) ExecutorRegistry(context.Context, *RegistryRequest) (*RegistryReply, error)
  • func (UnimplementedJobExecutorRegisterServer) ExecutorUnRegistry(context.Context, *RegistryRequest) (*RegistryReply, error)
• type UnsafeJobExecutorRegisterServer

Variables

var File_server_proto_executor_registry_proto protoreflect.FileDescriptor

var JobExecutorRegister_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.registry.JobExecutorRegister",
	HandlerType: (*JobExecutorRegisterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ExecutorRegistry",
			Handler:    _JobExecutorRegister_ExecutorRegistry_Handler,
		},
		{
			MethodName: "ExecutorUnRegistry",
			Handler:    _JobExecutorRegister_ExecutorUnRegistry_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "server/proto/executor_registry.proto",
}

JobExecutorRegister_ServiceDesc is the grpc.ServiceDesc for JobExecutorRegister service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterJobExecutorRegisterServer

func RegisterJobExecutorRegisterServer(s grpc.ServiceRegistrar, srv JobExecutorRegisterServer)

Types

type JobExecutorRegisterClient

type JobExecutorRegisterClient interface {
	ExecutorRegistry(ctx context.Context, in *RegistryRequest, opts ...grpc.CallOption) (*RegistryReply, error)
	ExecutorUnRegistry(ctx context.Context, in *RegistryRequest, opts ...grpc.CallOption) (*RegistryReply, error)
}

JobExecutorRegisterClient is the client API for JobExecutorRegister 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 NewJobExecutorRegisterClient

func NewJobExecutorRegisterClient(cc grpc.ClientConnInterface) JobExecutorRegisterClient

type JobExecutorRegisterServer

type JobExecutorRegisterServer interface {
	ExecutorRegistry(context.Context, *RegistryRequest) (*RegistryReply, error)
	ExecutorUnRegistry(context.Context, *RegistryRequest) (*RegistryReply, error)
	// contains filtered or unexported methods
}

JobExecutorRegisterServer is the server API for JobExecutorRegister service. All implementations must embed UnimplementedJobExecutorRegisterServer for forward compatibility

type RegistryReply

type RegistryReply struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*RegistryReply) Descriptor

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

Deprecated: Use RegistryReply.ProtoReflect.Descriptor instead.

func (*RegistryReply) GetMessage

func (x *RegistryReply) GetMessage() string

func (*RegistryReply) ProtoMessage

func (*RegistryReply) ProtoMessage()

func (*RegistryReply) ProtoReflect

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

func (*RegistryReply) Reset

func (x *RegistryReply) Reset()

func (*RegistryReply) String

func (x *RegistryReply) String() string

type RegistryRequest

type RegistryRequest struct {
	ServerName string   `protobuf:"bytes,1,opt,name=serverName,proto3" json:"serverName,omitempty"`
	ServerList []string `protobuf:"bytes,2,rep,name=serverList,proto3" json:"serverList,omitempty"`
	// contains filtered or unexported fields
}

func (*RegistryRequest) Descriptor

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

Deprecated: Use RegistryRequest.ProtoReflect.Descriptor instead.

func (*RegistryRequest) GetServerList

func (x *RegistryRequest) GetServerList() []string

func (*RegistryRequest) GetServerName

func (x *RegistryRequest) GetServerName() string

func (*RegistryRequest) ProtoMessage

func (*RegistryRequest) ProtoMessage()

func (*RegistryRequest) ProtoReflect

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

func (*RegistryRequest) Reset

func (x *RegistryRequest) Reset()

func (*RegistryRequest) String

func (x *RegistryRequest) String() string

type RpcServer

type RpcServer struct {
	UnimplementedJobExecutorRegisterServer
}

func (*RpcServer) ExecutorRegistry

func (s *RpcServer) ExecutorRegistry(_ context.Context, in *RegistryRequest) (*RegistryReply, error)

func (*RpcServer) ExecutorUnRegistry

func (s *RpcServer) ExecutorUnRegistry(_ context.Context, in *RegistryRequest) (*RegistryReply, error)

type UnimplementedJobExecutorRegisterServer

type UnimplementedJobExecutorRegisterServer struct {
}

UnimplementedJobExecutorRegisterServer must be embedded to have forward compatible implementations.

func (UnimplementedJobExecutorRegisterServer) ExecutorRegistry

func (UnimplementedJobExecutorRegisterServer) ExecutorRegistry(context.Context, *RegistryRequest) (*RegistryReply, error)

func (UnimplementedJobExecutorRegisterServer) ExecutorUnRegistry

func (UnimplementedJobExecutorRegisterServer) ExecutorUnRegistry(context.Context, *RegistryRequest) (*RegistryReply, error)

type UnsafeJobExecutorRegisterServer

type UnsafeJobExecutorRegisterServer interface {
	// contains filtered or unexported methods
}

UnsafeJobExecutorRegisterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to JobExecutorRegisterServer will result in compilation errors.