scheduler

Documentation

Index

• Variables
• type Config
• type Scheduler
  • func New(l *zap.Logger, tc temporalclient.Client, cfg *Config) *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

Variables

var Configs = configset.Set[Config]{
	Default: &Config{},
}

Types

type Config

type Config struct {
	Worker   temporalclient.WorkerConfig   `koanf:"worker"`
	Workflow temporalclient.WorkflowConfig `koanf:"workflow"`
	Activity temporalclient.ActivityConfig `koanf:"activity"`
}

type Scheduler

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

func New

func New(l *zap.Logger, tc temporalclient.Client, cfg *Config) *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, triggers sdkservices.Triggers) error

func (*Scheduler) Update

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