schedulers

Documentation

Overview

Package schedulers contains implementations of the scheduler interface.

Index

• Constants
• func NewDirectBBScheduler() interfaces.SchedulerInterface
• func NewDryRunScheduler() interfaces.SchedulerInterface
• func NewSchedukeScheduler() interfaces.SchedulerInterface
• type DirectBBScheduler
  • func (sc *DirectBBScheduler) CancelTask(requestID int64) error
  • func (sc *DirectBBScheduler) GetResult(requestID int64) error
  • func (sc *DirectBBScheduler) GetSchedulerType() interfaces.SchedulerType
  • func (sc *DirectBBScheduler) GetStatus(requestID int64) (*buildbucketpb.Build, error)
  • func (sc *DirectBBScheduler) ScheduleRequest(ctx context.Context, req *buildbucketpb.ScheduleBuildRequest, _ *build.Step) (*buildbucketpb.Build, string, error)
  • func (sc *DirectBBScheduler) Setup(_ string) error
• type DryRunScheduler
  • func (ds *DryRunScheduler) CancelTask(requestID int64) error
  • func (ds *DryRunScheduler) GetResult(requestID int64) error
  • func (ds *DryRunScheduler) GetSchedulerType() interfaces.SchedulerType
  • func (ds *DryRunScheduler) GetStatus(requestID int64) (*buildbucketpb.Build, error)
  • func (ds *DryRunScheduler) ScheduleRequest(_ context.Context, _ *buildbucketpb.ScheduleBuildRequest, _ *build.Step) (*buildbucketpb.Build, string, error)
  • func (ds *DryRunScheduler) Setup(_ string) error
• type SchedukeScheduler
  • func (s *SchedukeScheduler) CancelTask(requestID int64) error
  • func (s *SchedukeScheduler) GetResult(requestID int64) error
  • func (s *SchedukeScheduler) GetSchedulerType() interfaces.SchedulerType
  • func (s *SchedukeScheduler) GetStatus(requestID int64) (*buildbucketpb.Build, error)
  • func (s *SchedukeScheduler) ScheduleRequest(ctx context.Context, req *buildbucketpb.ScheduleBuildRequest, step *build.Step) (*buildbucketpb.Build, string, error)
  • func (s *SchedukeScheduler) Setup(pool string) error

Constants

const (
	// Unsupported scheduler type (For testing purposes only).
	UnsupportedSchedulerType interfaces.SchedulerType = "UnsupportedScheduler"
	// Direct bb scheduler schedules requests directly through buildbucket.
	DirectBBSchedulerType interfaces.SchedulerType = "DirectBBScheduler"
	// DryRunSchedulerType is a stubbed scheduler for dry run mode/debugging. It
	// will print out the request without scheduling anywhere.
	DryRunSchedulerType interfaces.SchedulerType = "DryRunScheduler"
	// Scheduke scheduler schedules requests through Scheduke.
	SchedukeSchedulerType interfaces.SchedulerType = "SchedukeScheduler"
)

All supported scheduler types.

Functions

func NewDirectBBScheduler

func NewDirectBBScheduler() interfaces.SchedulerInterface

func NewDryRunScheduler

func NewDryRunScheduler() interfaces.SchedulerInterface

func NewSchedukeScheduler

func NewSchedukeScheduler() interfaces.SchedulerInterface

Types

type DirectBBScheduler

type DirectBBScheduler struct {
	BBClient *buildbucketpb.BuildsClient
	// contains filtered or unexported fields
}

DirectBBScheduler defines scheduler that schedules request(s) directly through buildbucket.

func (*DirectBBScheduler) CancelTask

func (sc *DirectBBScheduler) CancelTask(requestID int64) error

func (*DirectBBScheduler) GetResult

func (sc *DirectBBScheduler) GetResult(requestID int64) error

func (*DirectBBScheduler) GetSchedulerType

func (sc *DirectBBScheduler) GetSchedulerType() interfaces.SchedulerType

func (*DirectBBScheduler) GetStatus

func (sc *DirectBBScheduler) GetStatus(requestID int64) (*buildbucketpb.Build, error)

func (*DirectBBScheduler) ScheduleRequest

func (sc *DirectBBScheduler) ScheduleRequest(ctx context.Context, req *buildbucketpb.ScheduleBuildRequest, _ *build.Step) (*buildbucketpb.Build, string, error)

func (*DirectBBScheduler) Setup

func (sc *DirectBBScheduler) Setup(_ string) error

type DryRunScheduler

type DryRunScheduler struct {
	// contains filtered or unexported fields
}

DryRunScheduler defines a scheduler that doesn't schedule request(s) anywhere. It is a dummy scheduler that prints out request(s) without scheduling them.

func (*DryRunScheduler) CancelTask

func (ds *DryRunScheduler) CancelTask(requestID int64) error

func (*DryRunScheduler) GetResult

func (ds *DryRunScheduler) GetResult(requestID int64) error

func (*DryRunScheduler) GetSchedulerType

func (ds *DryRunScheduler) GetSchedulerType() interfaces.SchedulerType

func (*DryRunScheduler) GetStatus

func (ds *DryRunScheduler) GetStatus(requestID int64) (*buildbucketpb.Build, error)

func (*DryRunScheduler) ScheduleRequest

func (ds *DryRunScheduler) ScheduleRequest(_ context.Context, _ *buildbucketpb.ScheduleBuildRequest, _ *build.Step) (*buildbucketpb.Build, string, error)

func (*DryRunScheduler) Setup

func (ds *DryRunScheduler) Setup(_ string) error

type SchedukeScheduler

type SchedukeScheduler struct {
	// contains filtered or unexported fields
}

SchedukeScheduler defines a scheduler that schedules request(s) through Scheduke.

func (*SchedukeScheduler) CancelTask

func (s *SchedukeScheduler) CancelTask(requestID int64) error

func (*SchedukeScheduler) GetResult

func (s *SchedukeScheduler) GetResult(requestID int64) error

func (*SchedukeScheduler) GetSchedulerType

func (s *SchedukeScheduler) GetSchedulerType() interfaces.SchedulerType

func (*SchedukeScheduler) GetStatus

func (s *SchedukeScheduler) GetStatus(requestID int64) (*buildbucketpb.Build, error)

func (*SchedukeScheduler) ScheduleRequest

func (s *SchedukeScheduler) ScheduleRequest(ctx context.Context, req *buildbucketpb.ScheduleBuildRequest, step *build.Step) (*buildbucketpb.Build, string, error)

func (*SchedukeScheduler) Setup

func (s *SchedukeScheduler) Setup(pool string) error