Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrNoTriggerSlots = errors.New("no trigger slots available")
Functions ¶
This section is empty.
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
Source Files
Click to show internal directories.
Click to hide internal directories.