flow

Documentation

Index

• Constants
• func FlowClearedEventMapper(event *repository.Event) (eventstore.Event, error)
• func TriggerActionsCascadeRemovedEventMapper(event *repository.Event) (eventstore.Event, error)
• func TriggerActionsSetEventMapper(event *repository.Event) (eventstore.Event, error)
• type FlowClearedEvent
  • func NewFlowClearedEvent(base *eventstore.BaseEvent, flowType domain.FlowType) *FlowClearedEvent
  • func (e *FlowClearedEvent) Data() interface{}
  • func (e *FlowClearedEvent) UniqueConstraints() []*eventstore.EventUniqueConstraint
• type TriggerActionsCascadeRemovedEvent
  • func NewTriggerActionsCascadeRemovedEvent(base *eventstore.BaseEvent, flowType domain.FlowType, actionID string) *TriggerActionsCascadeRemovedEvent
  • func (e *TriggerActionsCascadeRemovedEvent) Data() interface{}
  • func (e *TriggerActionsCascadeRemovedEvent) UniqueConstraints() []*eventstore.EventUniqueConstraint
• type TriggerActionsSetEvent
  • func NewTriggerActionsSetEvent(base *eventstore.BaseEvent, flowType domain.FlowType, ...) *TriggerActionsSetEvent
  • func (e *TriggerActionsSetEvent) Data() interface{}
  • func (e *TriggerActionsSetEvent) UniqueConstraints() []*eventstore.EventUniqueConstraint

Constants

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

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

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

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