services

type BaseClient interface {
	GetInfo(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*InfoResp, error)
	GetFuncs(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*FuncsResp, error)
}

type BaseServer interface {
	GetInfo(context.Context, *emptypb.Empty) (*InfoResp, error)
	GetFuncs(context.Context, *emptypb.Empty) (*FuncsResp, error)
	// contains filtered or unexported methods
}

type ClusterClient interface {
	GetNodes(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*NodesResp, error)
}

type ClusterServer interface {
	GetNodes(context.Context, *emptypb.Empty) (*NodesResp, error)
	// contains filtered or unexported methods
}

type Func struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Info string `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

type FuncsResp struct {
	Funcs []*Func `protobuf:"bytes,1,rep,name=funcs,proto3" json:"funcs,omitempty"`
	// contains filtered or unexported fields
}

type InfoResp struct {
	Info *structpb.Struct `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

type Job 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"`
	Type        string                 `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	StartAt     string                 `protobuf:"bytes,4,opt,name=start_at,json=startAt,proto3" json:"start_at,omitempty"`
	EndAt       string                 `protobuf:"bytes,5,opt,name=end_at,json=endAt,proto3" json:"end_at,omitempty"`
	Interval    string                 `protobuf:"bytes,6,opt,name=interval,proto3" json:"interval,omitempty"`
	CronExpr    string                 `protobuf:"bytes,7,opt,name=cron_expr,json=cronExpr,proto3" json:"cron_expr,omitempty"`
	Timezone    string                 `protobuf:"bytes,8,opt,name=timezone,proto3" json:"timezone,omitempty"`
	FuncName    string                 `protobuf:"bytes,9,opt,name=func_name,json=funcName,proto3" json:"func_name,omitempty"`
	Args        *structpb.Struct       `protobuf:"bytes,10,opt,name=args,proto3" json:"args,omitempty"`
	Timeout     string                 `protobuf:"bytes,11,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Queues      []string               `protobuf:"bytes,12,rep,name=queues,proto3" json:"queues,omitempty"`
	LastRunTime *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=last_run_time,json=lastRunTime,proto3" json:"last_run_time,omitempty"`
	NextRunTime *timestamppb.Timestamp `protobuf:"bytes,14,opt,name=next_run_time,json=nextRunTime,proto3" json:"next_run_time,omitempty"`
	Status      string                 `protobuf:"bytes,15,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

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

type JobsResp struct {
	Jobs []*Job `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	// contains filtered or unexported fields
}

type Node struct {
	EndpointMain      string                 `protobuf:"bytes,1,opt,name=endpoint_main,json=endpointMain,proto3" json:"endpoint_main,omitempty"`
	Endpoint          string                 `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	EndpointGrpc      string                 `protobuf:"bytes,3,opt,name=endpoint_grpc,json=endpointGrpc,proto3" json:"endpoint_grpc,omitempty"`
	EndpointHttp      string                 `protobuf:"bytes,4,opt,name=endpoint_http,json=endpointHttp,proto3" json:"endpoint_http,omitempty"`
	Queue             string                 `protobuf:"bytes,5,opt,name=queue,proto3" json:"queue,omitempty"`
	Mode              string                 `protobuf:"bytes,6,opt,name=mode,proto3" json:"mode,omitempty"`
	Version           string                 `protobuf:"bytes,7,opt,name=version,proto3" json:"version,omitempty"`
	Health            bool                   `protobuf:"varint,8,opt,name=health,proto3" json:"health,omitempty"`
	RegisterTime      *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=register_time,json=registerTime,proto3" json:"register_time,omitempty"`
	LastHeartbeatTime *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=last_heartbeat_time,json=lastHeartbeatTime,proto3" json:"last_heartbeat_time,omitempty"`
	// contains filtered or unexported fields
}

type NodesResp struct {
	Nodes map[string]*Node `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

type Record struct {
	Id      uint64                 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	JobId   string                 `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	JobName string                 `protobuf:"bytes,3,opt,name=job_name,json=jobName,proto3" json:"job_name,omitempty"`
	Status  string                 `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
	Result  string                 `protobuf:"bytes,5,opt,name=result,proto3" json:"result,omitempty"`
	StartAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=start_at,json=startAt,proto3" json:"start_at,omitempty"`
	EndAt   *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=end_at,json=endAt,proto3" json:"end_at,omitempty"`
	// contains filtered or unexported fields
}

type RecorderClient interface {
	GetRecords(ctx context.Context, in *RecordsReq, opts ...grpc.CallOption) (*RecordsResp, error)
	GetAllRecords(ctx context.Context, in *RecordsAllReq, opts ...grpc.CallOption) (*RecordsResp, error)
	DeleteRecords(ctx context.Context, in *JobReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DeleteAllRecords(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

type RecorderServer interface {
	GetRecords(context.Context, *RecordsReq) (*RecordsResp, error)
	GetAllRecords(context.Context, *RecordsAllReq) (*RecordsResp, error)
	DeleteRecords(context.Context, *JobReq) (*emptypb.Empty, error)
	DeleteAllRecords(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

type RecordsAllReq struct {
	Page     int32 `protobuf:"varint,1,opt,name=page,proto3" json:"page,omitempty"`
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// contains filtered or unexported fields
}

type RecordsReq struct {
	JobId    string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Page     int32  `protobuf:"varint,2,opt,name=page,proto3" json:"page,omitempty"`
	PageSize int32  `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// contains filtered or unexported fields
}

type RecordsResp struct {
	Records  []*Record `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	Page     int32     `protobuf:"varint,2,opt,name=page,proto3" json:"page,omitempty"`
	PageSize int32     `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	Total    int64     `protobuf:"varint,4,opt,name=total,proto3" json:"total,omitempty"`
	// contains filtered or unexported fields
}

type SchedulerClient interface {
	AddJob(ctx context.Context, in *Job, opts ...grpc.CallOption) (*Job, error)
	GetJob(ctx context.Context, in *JobReq, opts ...grpc.CallOption) (*Job, error)
	GetAllJobs(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*JobsResp, error)
	UpdateJob(ctx context.Context, in *Job, opts ...grpc.CallOption) (*Job, error)
	DeleteJob(ctx context.Context, in *JobReq, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DeleteAllJobs(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	PauseJob(ctx context.Context, in *JobReq, opts ...grpc.CallOption) (*Job, error)
	ResumeJob(ctx context.Context, in *JobReq, opts ...grpc.CallOption) (*Job, error)
	RunJob(ctx context.Context, in *Job, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ScheduleJob(ctx context.Context, in *Job, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Start(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Stop(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

type SchedulerServer interface {
	AddJob(context.Context, *Job) (*Job, error)
	GetJob(context.Context, *JobReq) (*Job, error)
	GetAllJobs(context.Context, *emptypb.Empty) (*JobsResp, error)
	UpdateJob(context.Context, *Job) (*Job, error)
	DeleteJob(context.Context, *JobReq) (*emptypb.Empty, error)
	DeleteAllJobs(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	PauseJob(context.Context, *JobReq) (*Job, error)
	ResumeJob(context.Context, *JobReq) (*Job, error)
	RunJob(context.Context, *Job) (*emptypb.Empty, error)
	ScheduleJob(context.Context, *Job) (*emptypb.Empty, error)
	Start(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	Stop(context.Context, *emptypb.Empty) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

type UnimplementedBaseServer struct {
}

type UnimplementedClusterServer struct {
}

type UnimplementedRecorderServer struct {
}

type UnimplementedSchedulerServer struct {
}

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

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

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

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