scheduler

Documentation

Index

• func WithDeleteJobFn(...) func(*options)
• func WithGRPCOptions(opts ...procgrpc.Option) func(*options)
• func WithGetJobFn(...) func(*options)
• func WithScheduleJobFn(...) func(*options)
• func WithSentry(sentry *sentry.Sentry) func(*options)
• func WithWatchJobsFn(fn func(schedulerv1pb.Scheduler_WatchJobsServer) error) func(*options)
• type Option
• type Scheduler
  • func New(t *testing.T, fopts ...Option) *Scheduler
  • func (s *Scheduler) Cleanup(t *testing.T)

Functions

func WithDeleteJobFn

func WithDeleteJobFn(fn func(ctx context.Context, request *schedulerv1pb.DeleteJobRequest) (*schedulerv1pb.DeleteJobResponse, error)) func(*options)

func WithGRPCOptions

func WithGRPCOptions(opts ...procgrpc.Option) func(*options)

func WithGetJobFn

func WithGetJobFn(fn func(ctx context.Context, request *schedulerv1pb.GetJobRequest) (*schedulerv1pb.GetJobResponse, error)) func(*options)

func WithScheduleJobFn

func WithScheduleJobFn(fn func(ctx context.Context, request *schedulerv1pb.ScheduleJobRequest) (*schedulerv1pb.ScheduleJobResponse, error)) func(*options)

func WithSentry

func WithSentry(sentry *sentry.Sentry) func(*options)

func WithWatchJobsFn

func WithWatchJobsFn(fn func(schedulerv1pb.Scheduler_WatchJobsServer) error) func(*options)

Types

type Option

type Option func(*options)

Option is a function that configures the process.

type Scheduler

type Scheduler struct {
	*procgrpc.GRPC
}

Scheduler is a wrapper around a grpc.Server that implements the Scheduler API.

func New

func New(t *testing.T, fopts ...Option) *Scheduler

func (*Scheduler) Cleanup

func (s *Scheduler) Cleanup(t *testing.T)