dispatcher

Documentation

Index

• Variables
• type Config
• type Dispatcher
  • func New(l *zap.Logger, cfg *Config, svcs Svcs) *Dispatcher
  • func (d *Dispatcher) Dispatch(ctx context.Context, event sdktypes.Event, opts *sdkservices.DispatchOptions) (sdktypes.EventID, error)
  • func (d *Dispatcher) Redispatch(ctx context.Context, eventID sdktypes.EventID, ...) (sdktypes.EventID, error)
  • func (d *Dispatcher) Start(context.Context) error
• type Svcs

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 Dispatcher

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

func New

func New(l *zap.Logger, cfg *Config, svcs Svcs) *Dispatcher

func (*Dispatcher) Dispatch

func (d *Dispatcher) Dispatch(ctx context.Context, event sdktypes.Event, opts *sdkservices.DispatchOptions) (sdktypes.EventID, error)

func (*Dispatcher) Redispatch

func (d *Dispatcher) Redispatch(ctx context.Context, eventID sdktypes.EventID, opts *sdkservices.DispatchOptions) (sdktypes.EventID, error)

func (*Dispatcher) Start

func (d *Dispatcher) Start(context.Context) error

type Svcs

type Svcs struct {
	fx.In

	db.DB
	temporalclient.LazyTemporalClient

	sdkservices.Connections
	sdkservices.Deployments
	sdkservices.Events
	sdkservices.Projects
	sdkservices.Sessions
	sdkservices.Triggers
}