handlers

Documentation

Index

• type SagaControlHandler
  • func NewSagaControlHandler(sagaStore sagaPkg.Store, mutex mutex.Mutex, ...) *SagaControlHandler
  • func (h SagaControlHandler) Handle(execCtx execution.MessageExecutionCtx) error
• type SagaEventsHandler
  • func NewEventsHandler(sagaStore sagaPkg.Store, mutex sagaMutex.Mutex, ...) *SagaEventsHandler
  • func (e SagaEventsHandler) Handle(execCtx execution.MessageExecutionCtx) error

Types

type SagaControlHandler

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

func NewSagaControlHandler

func NewSagaControlHandler(sagaStore sagaPkg.Store, mutex mutex.Mutex, sagaRegistry scheme.KnownTypesRegistry, sagaUIDSvc sagaPkg.SagaUIDService) *SagaControlHandler

func (SagaControlHandler) Handle

func (h SagaControlHandler) Handle(execCtx execution.MessageExecutionCtx) error

type SagaEventsHandler

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

func NewEventsHandler

func NewEventsHandler(sagaStore sagaPkg.Store, mutex sagaMutex.Mutex, scheme scheme.KnownTypesRegistry, extractor sagaPkg.SagaUIDService) *SagaEventsHandler

func (SagaEventsHandler) Handle

func (e SagaEventsHandler) Handle(execCtx execution.MessageExecutionCtx) error