Documentation ¶
Index ¶
- Variables
- func RegisterJobServiceServer(s grpc.ServiceRegistrar, srv JobServiceServer)
- type JobRequest
- func (*JobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *JobRequest) GetConfig() *JobRequest_ExecutorConfig
- func (x *JobRequest) GetCronSchedule() string
- func (x *JobRequest) GetExecutor() JobRequest_Executor
- func (x *JobRequest) GetFileBody() string
- func (x *JobRequest) GetName() string
- func (*JobRequest) ProtoMessage()
- func (x *JobRequest) ProtoReflect() protoreflect.Message
- func (x *JobRequest) Reset()
- func (x *JobRequest) String() string
- type JobRequest_Executor
- func (JobRequest_Executor) Descriptor() protoreflect.EnumDescriptor
- func (x JobRequest_Executor) Enum() *JobRequest_Executor
- func (JobRequest_Executor) EnumDescriptor() ([]byte, []int)deprecated
- func (x JobRequest_Executor) Number() protoreflect.EnumNumber
- func (x JobRequest_Executor) String() string
- func (JobRequest_Executor) Type() protoreflect.EnumType
- type JobRequest_ExecutorConfig
- func (*JobRequest_ExecutorConfig) Descriptor() ([]byte, []int)deprecated
- func (x *JobRequest_ExecutorConfig) GetCommand() string
- func (*JobRequest_ExecutorConfig) ProtoMessage()
- func (x *JobRequest_ExecutorConfig) ProtoReflect() protoreflect.Message
- func (x *JobRequest_ExecutorConfig) Reset()
- func (x *JobRequest_ExecutorConfig) String() string
- type JobResponse
- type JobServiceClient
- type JobServiceServer
- type UnimplementedJobServiceServer
- type UnsafeJobServiceServer
Constants ¶
This section is empty.
Variables ¶
var ( JobRequest_Executor_name = map[int32]string{ 0: "SHELL", 1: "PYTHON", 2: "JAVA", 3: "CPP", } JobRequest_Executor_value = map[string]int32{ "SHELL": 0, "PYTHON": 1, "JAVA": 2, "CPP": 3, } )
Enum value maps for JobRequest_Executor.
var File_service_proto protoreflect.FileDescriptor
var JobService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "proto.JobService", HandlerType: (*JobServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ScheduleJob", Handler: _JobService_ScheduleJob_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "service.proto", }
JobService_ServiceDesc is the grpc.ServiceDesc for JobService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterJobServiceServer ¶
func RegisterJobServiceServer(s grpc.ServiceRegistrar, srv JobServiceServer)
Types ¶
type JobRequest ¶
type JobRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` CronSchedule string `protobuf:"bytes,2,opt,name=cron_schedule,json=cronSchedule,proto3" json:"cron_schedule,omitempty"` Executor JobRequest_Executor `protobuf:"varint,3,opt,name=executor,proto3,enum=proto.JobRequest_Executor" json:"executor,omitempty"` Config *JobRequest_ExecutorConfig `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"` FileBody string `protobuf:"bytes,5,opt,name=file_body,json=fileBody,proto3" json:"file_body,omitempty"` // contains filtered or unexported fields }
func (*JobRequest) Descriptor
deprecated
func (*JobRequest) Descriptor() ([]byte, []int)
Deprecated: Use JobRequest.ProtoReflect.Descriptor instead.
func (*JobRequest) GetConfig ¶
func (x *JobRequest) GetConfig() *JobRequest_ExecutorConfig
func (*JobRequest) GetCronSchedule ¶
func (x *JobRequest) GetCronSchedule() string
func (*JobRequest) GetExecutor ¶
func (x *JobRequest) GetExecutor() JobRequest_Executor
func (*JobRequest) GetFileBody ¶
func (x *JobRequest) GetFileBody() string
func (*JobRequest) GetName ¶
func (x *JobRequest) GetName() string
func (*JobRequest) ProtoMessage ¶
func (*JobRequest) ProtoMessage()
func (*JobRequest) ProtoReflect ¶
func (x *JobRequest) ProtoReflect() protoreflect.Message
func (*JobRequest) Reset ¶
func (x *JobRequest) Reset()
func (*JobRequest) String ¶
func (x *JobRequest) String() string
type JobRequest_Executor ¶
type JobRequest_Executor int32
const ( JobRequest_SHELL JobRequest_Executor = 0 JobRequest_PYTHON JobRequest_Executor = 1 JobRequest_JAVA JobRequest_Executor = 2 JobRequest_CPP JobRequest_Executor = 3 )
func (JobRequest_Executor) Descriptor ¶
func (JobRequest_Executor) Descriptor() protoreflect.EnumDescriptor
func (JobRequest_Executor) Enum ¶
func (x JobRequest_Executor) Enum() *JobRequest_Executor
func (JobRequest_Executor) EnumDescriptor
deprecated
func (JobRequest_Executor) EnumDescriptor() ([]byte, []int)
Deprecated: Use JobRequest_Executor.Descriptor instead.
func (JobRequest_Executor) Number ¶
func (x JobRequest_Executor) Number() protoreflect.EnumNumber
func (JobRequest_Executor) String ¶
func (x JobRequest_Executor) String() string
func (JobRequest_Executor) Type ¶
func (JobRequest_Executor) Type() protoreflect.EnumType
type JobRequest_ExecutorConfig ¶
type JobRequest_ExecutorConfig struct { Command string `protobuf:"bytes,1,opt,name=command,proto3" json:"command,omitempty"` // contains filtered or unexported fields }
func (*JobRequest_ExecutorConfig) Descriptor
deprecated
func (*JobRequest_ExecutorConfig) Descriptor() ([]byte, []int)
Deprecated: Use JobRequest_ExecutorConfig.ProtoReflect.Descriptor instead.
func (*JobRequest_ExecutorConfig) GetCommand ¶
func (x *JobRequest_ExecutorConfig) GetCommand() string
func (*JobRequest_ExecutorConfig) ProtoMessage ¶
func (*JobRequest_ExecutorConfig) ProtoMessage()
func (*JobRequest_ExecutorConfig) ProtoReflect ¶
func (x *JobRequest_ExecutorConfig) ProtoReflect() protoreflect.Message
func (*JobRequest_ExecutorConfig) Reset ¶
func (x *JobRequest_ExecutorConfig) Reset()
func (*JobRequest_ExecutorConfig) String ¶
func (x *JobRequest_ExecutorConfig) String() string
type JobResponse ¶
type JobResponse struct { Body string `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"` // contains filtered or unexported fields }
func (*JobResponse) Descriptor
deprecated
func (*JobResponse) Descriptor() ([]byte, []int)
Deprecated: Use JobResponse.ProtoReflect.Descriptor instead.
func (*JobResponse) GetBody ¶
func (x *JobResponse) GetBody() string
func (*JobResponse) ProtoMessage ¶
func (*JobResponse) ProtoMessage()
func (*JobResponse) ProtoReflect ¶
func (x *JobResponse) ProtoReflect() protoreflect.Message
func (*JobResponse) Reset ¶
func (x *JobResponse) Reset()
func (*JobResponse) String ¶
func (x *JobResponse) String() string
type JobServiceClient ¶
type JobServiceClient interface {
ScheduleJob(ctx context.Context, in *JobRequest, opts ...grpc.CallOption) (*JobResponse, error)
}
JobServiceClient is the client API for JobService 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 NewJobServiceClient ¶
func NewJobServiceClient(cc grpc.ClientConnInterface) JobServiceClient
type JobServiceServer ¶
type JobServiceServer interface { ScheduleJob(context.Context, *JobRequest) (*JobResponse, error) // contains filtered or unexported methods }
JobServiceServer is the server API for JobService service. All implementations must embed UnimplementedJobServiceServer for forward compatibility
type UnimplementedJobServiceServer ¶
type UnimplementedJobServiceServer struct { }
UnimplementedJobServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedJobServiceServer) ScheduleJob ¶
func (UnimplementedJobServiceServer) ScheduleJob(context.Context, *JobRequest) (*JobResponse, error)
type UnsafeJobServiceServer ¶
type UnsafeJobServiceServer interface {
// contains filtered or unexported methods
}
UnsafeJobServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to JobServiceServer will result in compilation errors.