trigger

Documentation

Index

• Variables
• type TriggerWriter
  • func NewTriggerWriter(mq msgqueue.MessageQueue, repo v1.Repository, l *zerolog.Logger, ...) *TriggerWriter
  • func (tw *TriggerWriter) TriggerFromEvents(ctx context.Context, tenantId uuid.UUID, ...) error
  • func (tw *TriggerWriter) TriggerFromWorkflowNames(ctx context.Context, tenantId uuid.UUID, opts []*v1.WorkflowNameTriggerOpts) error

Variables

var ErrNoTriggerSlots = errors.New("no trigger slots available")

Types

type TriggerWriter

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

func NewTriggerWriter

func NewTriggerWriter(mq msgqueue.MessageQueue, repo v1.Repository, l *zerolog.Logger, pubBuffer *msgqueue.MQPubBuffer, slots int) *TriggerWriter

NewTriggerWriter creates a new TriggerWriter with the given number of slots for concurrency control. If the number of slots is 0, there is no limit to concurrency.

func (*TriggerWriter) TriggerFromEvents

func (tw *TriggerWriter) TriggerFromEvents(ctx context.Context, tenantId uuid.UUID, eventIdToOpts map[uuid.UUID]v1.EventTriggerOpts) error

func (*TriggerWriter) TriggerFromWorkflowNames

func (tw *TriggerWriter) TriggerFromWorkflowNames(ctx context.Context, tenantId uuid.UUID, opts []*v1.WorkflowNameTriggerOpts) error