action

Documentation

Index

• Constants
• func AddedEventMapper(event *repository.Event) (eventstore.Event, error)
• func ChangeAllowedToFail(allowedToFail bool) func(event *ChangedEvent)
• func ChangeName(name, oldName string) func(event *ChangedEvent)
• func ChangeScript(script string) func(event *ChangedEvent)
• func ChangeTimeout(timeout time.Duration) func(event *ChangedEvent)
• func ChangedEventMapper(event *repository.Event) (eventstore.Event, error)
• func DeactivatedEventMapper(event *repository.Event) (eventstore.Event, error)
• func NewAddActionNameUniqueConstraint(actionName, resourceOwner string) *eventstore.EventUniqueConstraint
• func NewRemoveActionNameUniqueConstraint(actionName, resourceOwner string) *eventstore.EventUniqueConstraint
• func ReactivatedEventMapper(event *repository.Event) (eventstore.Event, error)
• func RegisterEventMappers(es *eventstore.Eventstore)
• func RemovedEventMapper(event *repository.Event) (eventstore.Event, error)
• type ActionChanges
• type AddedEvent
  • func NewAddedEvent(ctx context.Context, aggregate *eventstore.Aggregate, name, script string, ...) *AddedEvent
  • func (e *AddedEvent) Data() interface{}
  • func (e *AddedEvent) UniqueConstraints() []*eventstore.EventUniqueConstraint
• type Aggregate
  • func NewAggregate(id, resourceOwner string) *Aggregate
• type ChangedEvent
  • func NewChangedEvent(ctx context.Context, aggregate *eventstore.Aggregate, changes []ActionChanges) (*ChangedEvent, error)
  • func (e *ChangedEvent) Data() interface{}
  • func (e *ChangedEvent) UniqueConstraints() []*eventstore.EventUniqueConstraint
• type DeactivatedEvent
  • func NewDeactivatedEvent(ctx context.Context, aggregate *eventstore.Aggregate) *DeactivatedEvent
  • func (e *DeactivatedEvent) Data() interface{}
  • func (e *DeactivatedEvent) UniqueConstraints() []*eventstore.EventUniqueConstraint
• type ReactivatedEvent
  • func NewReactivatedEvent(ctx context.Context, aggregate *eventstore.Aggregate) *ReactivatedEvent
  • func (e *ReactivatedEvent) Data() interface{}
  • func (e *ReactivatedEvent) UniqueConstraints() []*eventstore.EventUniqueConstraint
• type RemovedEvent
  • func NewRemovedEvent(ctx context.Context, aggregate *eventstore.Aggregate, name string) *RemovedEvent
  • func (e *RemovedEvent) Data() interface{}
  • func (e *RemovedEvent) UniqueConstraints() []*eventstore.EventUniqueConstraint

Constants

const (
	UniqueActionNameType = "action_names"

	AddedEventType       = eventTypePrefix + "added"
	ChangedEventType     = eventTypePrefix + "changed"
	DeactivatedEventType = eventTypePrefix + "deactivated"
	ReactivatedEventType = eventTypePrefix + "reactivated"
	RemovedEventType     = eventTypePrefix + "removed"
)

const (
	AggregateType    = "action"
	AggregateVersion = "v1"
)

Functions

func AddedEventMapper

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

func ChangeAllowedToFail

func ChangeAllowedToFail(allowedToFail bool) func(event *ChangedEvent)

func ChangeName

func ChangeName(name, oldName string) func(event *ChangedEvent)

func ChangeScript

func ChangeScript(script string) func(event *ChangedEvent)

func ChangeTimeout

func ChangeTimeout(timeout time.Duration) func(event *ChangedEvent)

func ChangedEventMapper

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

func DeactivatedEventMapper

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

func NewAddActionNameUniqueConstraint

func NewAddActionNameUniqueConstraint(actionName, resourceOwner string) *eventstore.EventUniqueConstraint

func NewRemoveActionNameUniqueConstraint

func NewRemoveActionNameUniqueConstraint(actionName, resourceOwner string) *eventstore.EventUniqueConstraint

func ReactivatedEventMapper

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

func RegisterEventMappers

func RegisterEventMappers(es *eventstore.Eventstore)

func RemovedEventMapper

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

Types

type ActionChanges

type ActionChanges func(event *ChangedEvent)

type AddedEvent

type AddedEvent struct {
	eventstore.BaseEvent `json:"-"`

	Name          string        `json:"name"`
	Script        string        `json:"script,omitempty"`
	Timeout       time.Duration `json:"timeout,omitempty"`
	AllowedToFail bool          `json:"allowedToFail"`
}

func NewAddedEvent

func NewAddedEvent(
	ctx context.Context,
	aggregate *eventstore.Aggregate,
	name,
	script string,
	timeout time.Duration,
	allowedToFail bool,
) *AddedEvent

func (*AddedEvent) Data

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

func (*AddedEvent) UniqueConstraints

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

type Aggregate

type Aggregate struct {
	eventstore.Aggregate
}

func NewAggregate

func NewAggregate(id, resourceOwner string) *Aggregate

type ChangedEvent

type ChangedEvent struct {
	eventstore.BaseEvent `json:"-"`

	Name          *string        `json:"name,omitempty"`
	Script        *string        `json:"script,omitempty"`
	Timeout       *time.Duration `json:"timeout,omitempty"`
	AllowedToFail *bool          `json:"allowedToFail,omitempty"`
	// contains filtered or unexported fields
}

func NewChangedEvent

func NewChangedEvent(
	ctx context.Context,
	aggregate *eventstore.Aggregate,
	changes []ActionChanges,
) (*ChangedEvent, error)

func (*ChangedEvent) Data

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

func (*ChangedEvent) UniqueConstraints

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

type DeactivatedEvent

type DeactivatedEvent struct {
	eventstore.BaseEvent `json:"-"`
}

func NewDeactivatedEvent

func NewDeactivatedEvent(ctx context.Context, aggregate *eventstore.Aggregate) *DeactivatedEvent

func (*DeactivatedEvent) Data

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

func (*DeactivatedEvent) UniqueConstraints

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

type ReactivatedEvent

type ReactivatedEvent struct {
	eventstore.BaseEvent `json:"-"`
}

func NewReactivatedEvent

func NewReactivatedEvent(ctx context.Context, aggregate *eventstore.Aggregate) *ReactivatedEvent

func (*ReactivatedEvent) Data

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

func (*ReactivatedEvent) UniqueConstraints

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

type RemovedEvent

type RemovedEvent struct {
	eventstore.BaseEvent `json:"-"`
	// contains filtered or unexported fields
}

func NewRemovedEvent

func NewRemovedEvent(
	ctx context.Context,
	aggregate *eventstore.Aggregate,
	name string,
) *RemovedEvent

func (*RemovedEvent) Data

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

func (*RemovedEvent) UniqueConstraints

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