dispatcher

Documentation

Index

• type Dispatcher
  • func New(d Dispatcher) *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

Types

type Dispatcher

type Dispatcher struct {
	fx.In

	L *zap.Logger

	db.DB
	temporalclient.Client
	sdkservices.Events
	sdkservices.Triggers
	sdkservices.Deployments
	sdkservices.Sessions
	sdkservices.Projects
	sdkservices.Envs
}

func New

func New(d Dispatcher) *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