scheduler

May 9, 2023

Changes in this version

+ const Scheduler_CreateSchedulingJob_FullMethodName

+ const Scheduler_DeleteSchedulingJob_FullMethodName

+ const Scheduler_GetSchedulingJobHistory_FullMethodName

+ const Scheduler_GetSchedulingJob_FullMethodName

+ const Scheduler_ListSchedulingJobHistories_FullMethodName

+ const Scheduler_PatchSchedulingJob_FullMethodName

+ const Scheduler_UpdateSchedulingJob_FullMethodName

Mar 23, 2022

Changes in this version

+ var File_io_scheduler_a_rpc_proto protoreflect.FileDescriptor

+ var File_io_scheduler_scheduler_proto protoreflect.FileDescriptor

+ var Scheduler_ServiceDesc = grpc.ServiceDesc

+ func RegisterSchedulerHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

+ func RegisterSchedulerHandlerClient(ctx context.Context, mux *runtime.ServeMux, client SchedulerClient) error

+ func RegisterSchedulerHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

+ func RegisterSchedulerHandlerServer(ctx context.Context, mux *runtime.ServeMux, server SchedulerServer) error

+ func RegisterSchedulerServer(s grpc.ServiceRegistrar, srv SchedulerServer)

+ type ListRequest struct

+ Filters *io.Filters

+ JobId string

+ func (*ListRequest) Descriptor() ([]byte, []int)

+ func (*ListRequest) ProtoMessage()

+ func (x *ListRequest) GetFilters() *io.Filters

+ func (x *ListRequest) GetJobId() string

+ func (x *ListRequest) ProtoReflect() protoreflect.Message

+ func (x *ListRequest) Reset()

+ func (x *ListRequest) String() string

+ type SchedulerClient interface

+ CreateSchedulingJob func(ctx context.Context, in *ct.SchedulingJob, opts ...grpc.CallOption) (*ct.SchedulingJobResponse, error)

+ DeleteSchedulingJob func(ctx context.Context, in *io.Id, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ GetSchedulingJob func(ctx context.Context, in *io.Id, opts ...grpc.CallOption) (*ct.SchedulingJob, error)

+ GetSchedulingJobHistory func(ctx context.Context, in *io.Id, opts ...grpc.CallOption) (*ct.JobHistory, error)

+ ListSchedulingJobHistories func(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (Scheduler_ListSchedulingJobHistoriesClient, error)

+ PatchSchedulingJob func(ctx context.Context, in *ct.SchedulingJob, opts ...grpc.CallOption) (*ct.SchedulingJobResponse, error)

+ UpdateSchedulingJob func(ctx context.Context, in *ct.SchedulingJob, opts ...grpc.CallOption) (*ct.SchedulingJobResponse, error)

+ func NewSchedulerClient(cc grpc.ClientConnInterface) SchedulerClient

+ type SchedulerServer interface

+ CreateSchedulingJob func(context.Context, *ct.SchedulingJob) (*ct.SchedulingJobResponse, error)

+ DeleteSchedulingJob func(context.Context, *io.Id) (*emptypb.Empty, error)

+ GetSchedulingJob func(context.Context, *io.Id) (*ct.SchedulingJob, error)

+ GetSchedulingJobHistory func(context.Context, *io.Id) (*ct.JobHistory, error)

+ ListSchedulingJobHistories func(*ListRequest, Scheduler_ListSchedulingJobHistoriesServer) error

+ PatchSchedulingJob func(context.Context, *ct.SchedulingJob) (*ct.SchedulingJobResponse, error)

+ UpdateSchedulingJob func(context.Context, *ct.SchedulingJob) (*ct.SchedulingJobResponse, error)

+ type Scheduler_ListSchedulingJobHistoriesClient interface

+ Recv func() (*ct.JobHistory, error)

+ type Scheduler_ListSchedulingJobHistoriesServer interface

+ Send func(*ct.JobHistory) error

+ type UnimplementedSchedulerServer struct

+ func (UnimplementedSchedulerServer) CreateSchedulingJob(context.Context, *ct.SchedulingJob) (*ct.SchedulingJobResponse, error)

+ func (UnimplementedSchedulerServer) DeleteSchedulingJob(context.Context, *io.Id) (*emptypb.Empty, error)

+ func (UnimplementedSchedulerServer) GetSchedulingJob(context.Context, *io.Id) (*ct.SchedulingJob, error)

+ func (UnimplementedSchedulerServer) GetSchedulingJobHistory(context.Context, *io.Id) (*ct.JobHistory, error)

+ func (UnimplementedSchedulerServer) ListSchedulingJobHistories(*ListRequest, Scheduler_ListSchedulingJobHistoriesServer) error

+ func (UnimplementedSchedulerServer) PatchSchedulingJob(context.Context, *ct.SchedulingJob) (*ct.SchedulingJobResponse, error)

+ func (UnimplementedSchedulerServer) UpdateSchedulingJob(context.Context, *ct.SchedulingJob) (*ct.SchedulingJobResponse, error)

+ type UnsafeSchedulerServer interface