flow

package
v1.87.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 20, 2022 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source
const (
	TriggerActionsSetEventType            = triggerActionsPrefix + "set"
	TriggerActionsCascadeRemovedEventType = triggerActionsPrefix + "cascade.removed"
	FlowClearedEventType                  = eventTypePrefix + "cleared"
)

Variables

This section is empty.

Functions

func FlowClearedEventMapper

func FlowClearedEventMapper(event *repository.Event) (eventstore.Event, error)

func TriggerActionsCascadeRemovedEventMapper

func TriggerActionsCascadeRemovedEventMapper(event *repository.Event) (eventstore.Event, error)

func TriggerActionsSetEventMapper

func TriggerActionsSetEventMapper(event *repository.Event) (eventstore.Event, error)

Types

type FlowClearedEvent

type FlowClearedEvent struct {
	eventstore.BaseEvent

	FlowType domain.FlowType `json:"flowType"`
}

func NewFlowClearedEvent

func NewFlowClearedEvent(
	base *eventstore.BaseEvent,
	flowType domain.FlowType,
) *FlowClearedEvent

func (*FlowClearedEvent) Data

func (e *FlowClearedEvent) Data() interface{}

func (*FlowClearedEvent) UniqueConstraints

func (e *FlowClearedEvent) UniqueConstraints() []*eventstore.EventUniqueConstraint

type TriggerActionsCascadeRemovedEvent

type TriggerActionsCascadeRemovedEvent struct {
	eventstore.BaseEvent

	FlowType    domain.FlowType    `json:"flowType"`
	TriggerType domain.TriggerType `json:"triggerType"`
	ActionID    string             `json:"actionID"`
}

func NewTriggerActionsCascadeRemovedEvent

func NewTriggerActionsCascadeRemovedEvent(
	base *eventstore.BaseEvent,
	flowType domain.FlowType,
	actionID string,
) *TriggerActionsCascadeRemovedEvent

func (*TriggerActionsCascadeRemovedEvent) Data

func (e *TriggerActionsCascadeRemovedEvent) Data() interface{}

func (*TriggerActionsCascadeRemovedEvent) UniqueConstraints

type TriggerActionsSetEvent

type TriggerActionsSetEvent struct {
	eventstore.BaseEvent

	FlowType    domain.FlowType    `json:"flowType"`
	TriggerType domain.TriggerType `json:"triggerType"`
	ActionIDs   []string           `json:"actionIDs"`
}

func NewTriggerActionsSetEvent

func NewTriggerActionsSetEvent(
	base *eventstore.BaseEvent,
	flowType domain.FlowType,
	triggerType domain.TriggerType,
	actionIDs []string,
) *TriggerActionsSetEvent

func (*TriggerActionsSetEvent) Data

func (e *TriggerActionsSetEvent) Data() interface{}

func (*TriggerActionsSetEvent) UniqueConstraints

func (e *TriggerActionsSetEvent) UniqueConstraints() []*eventstore.EventUniqueConstraint

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL