scheduler

Documentation

Index

• type Options
• type Scheduler
  • func New(opts Options) *Scheduler
  • func (s *Scheduler) All(ctx context.Context) ([]schedulerv1pb.SchedulerClient, error)
  • func (s *Scheduler) Next(ctx context.Context) (schedulerv1pb.SchedulerClient, error)
  • func (s *Scheduler) Run(ctx context.Context) error
  • func (s *Scheduler) StartApp(ctx context.Context)
  • func (s *Scheduler) StopApp(ctx context.Context)

Types

type Options

type Options struct {
	Namespace string
	AppID     string
	Actors    actors.Interface
	Channels  *channels.Channels
	Addresses []string
	Security  security.Handler
	Healthz   healthz.Healthz
}

type Scheduler

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

Scheduler manages the connection to the cluster of schedulers.

func New

func New(opts Options) *Scheduler

func (*Scheduler) All

func (s *Scheduler) All(ctx context.Context) ([]schedulerv1pb.SchedulerClient, error)

func (*Scheduler) Next

func (s *Scheduler) Next(ctx context.Context) (schedulerv1pb.SchedulerClient, error)

func (*Scheduler) Run

func (s *Scheduler) Run(ctx context.Context) error

func (*Scheduler) StartApp

func (s *Scheduler) StartApp(ctx context.Context)

func (*Scheduler) StopApp

func (s *Scheduler) StopApp(ctx context.Context)