scheduler

Documentation

Index

• type Scheduler
  • func New(l *zap.Logger, tc temporalclient.Client) *Scheduler
  • func (sch *Scheduler) Create(ctx context.Context, tid sdktypes.TriggerID, schedule string) error
  • func (sch *Scheduler) Delete(ctx context.Context, tid sdktypes.TriggerID) error
  • func (sch *Scheduler) Start(ctx context.Context, dispatcher sdkservices.Dispatcher) error
  • func (sch *Scheduler) Update(ctx context.Context, tid sdktypes.TriggerID, schedule string) error

Types

type Scheduler

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

func New

func New(l *zap.Logger, tc temporalclient.Client) *Scheduler

func (*Scheduler) Create

func (sch *Scheduler) Create(ctx context.Context, tid sdktypes.TriggerID, schedule string) error

func (*Scheduler) Delete

func (sch *Scheduler) Delete(ctx context.Context, tid sdktypes.TriggerID) error

func (*Scheduler) Start

func (sch *Scheduler) Start(ctx context.Context, dispatcher sdkservices.Dispatcher) error

func (*Scheduler) Update

func (sch *Scheduler) Update(ctx context.Context, tid sdktypes.TriggerID, schedule string) error