grpc

Documentation

Index

• type JobService
  • func NewJobService(log logger.Logger, jobDB models.JobDB, jobsProducer models.JobsProducer, ...) *JobService
  • func (js *JobService) CreateJob(ctx context.Context, req *proto.CreateJobRequest) (*proto.CreateJobResponse, error)
  • func (js *JobService) DeleteJob(ctx context.Context, req *proto.DeleteJobRequest) (*proto.DeleteJobResponse, error)
  • func (js *JobService) GetJob(ctx context.Context, req *proto.GetJobRequest) (*proto.Job, error)
  • func (js *JobService) ListJobs(ctx context.Context, req *proto.ListJobsRequest) (*proto.ListJobsResponse, error)
  • func (js *JobService) LoadScheduledJobs()
  • func (js *JobService) UpdateJob(ctx context.Context, req *proto.UpdateJobRequest) (*proto.UpdateJobResponse, error)

Types

type JobService

type JobService struct {
	proto.JobsServiceServer
	// contains filtered or unexported fields
}

func NewJobService

func NewJobService(log logger.Logger, jobDB models.JobDB, jobsProducer models.JobsProducer, jobsScheduler scheduler.Scheduler) *JobService

func (*JobService) CreateJob

func (js *JobService) CreateJob(ctx context.Context, req *proto.CreateJobRequest) (*proto.CreateJobResponse, error)

func (*JobService) DeleteJob

func (js *JobService) DeleteJob(ctx context.Context, req *proto.DeleteJobRequest) (*proto.DeleteJobResponse, error)

func (*JobService) GetJob

func (js *JobService) GetJob(ctx context.Context, req *proto.GetJobRequest) (*proto.Job, error)

func (*JobService) ListJobs

func (js *JobService) ListJobs(ctx context.Context, req *proto.ListJobsRequest) (*proto.ListJobsResponse, error)

func (*JobService) LoadScheduledJobs

func (js *JobService) LoadScheduledJobs()

exported method (Started with uppercase)

func (*JobService) UpdateJob

func (js *JobService) UpdateJob(ctx context.Context, req *proto.UpdateJobRequest) (*proto.UpdateJobResponse, error)