saga

Documentation

Index

• type EventHandler
  • func NewEventHandler(saga Saga, commandHandler eh.CommandHandler) *EventHandler
  • func (h *EventHandler) HandleEvent(ctx context.Context, event eh.Event) error
  • func (h *EventHandler) HandlerType() eh.EventHandlerType
• type Saga
• type Type

Types

type EventHandler

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

EventHandler is a CQRS saga handler to run a Saga implementation.

func NewEventHandler

func NewEventHandler(saga Saga, commandHandler eh.CommandHandler) *EventHandler

NewEventHandler creates a new EventHandler.

func (*EventHandler) HandleEvent

func (h *EventHandler) HandleEvent(ctx context.Context, event eh.Event) error

HandleEvent implements the HandleEvent method of the eventhorizon.EventHandler interface.

func (*EventHandler) HandlerType

func (h *EventHandler) HandlerType() eh.EventHandlerType

HandlerType implements the HandlerType method of the eventhorizon.EventHandler interface.

type Saga

type Saga interface {
	// SagaType returns the type of the saga.
	SagaType() Type

	// RunSaga handles an event in the saga that can return commands.
	RunSaga(context.Context, eh.Event) []eh.Command
}

Saga is an interface for a CQRS saga that listens to events and generate commands. It is used for any long lived transaction and can be used to react on multiple events.

type Type

type Type string

Type is the type of a saga, used as its unique identifier.