component

Documentation

Index

• func WithSagaApiServer(mux *http.ServeMux) configOption
• func WithSagaUIDService(svc saga.SagaUIDService) configOption
• type Component
  • func NewSagaComponent(sagaStoreFactory StoreFactory, sagaMutex mutex.Mutex, opts ...configOption) *Component
  • func (c Component) Init(mBus *foreman.MessageBus) error
  • func (c *Component) RegisterContracts(contracts ...message.Object)
  • func (c *Component) RegisterSagaEndpoints(endpoints ...endpoint.Endpoint)
  • func (c *Component) RegisterSagas(sagas ...saga.Saga)
• type StoreFactory

Functions

func WithSagaApiServer

func WithSagaApiServer(mux *http.ServeMux) configOption

func WithSagaUIDService

func WithSagaUIDService(svc saga.SagaUIDService) configOption

Types

type Component

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

func NewSagaComponent

func NewSagaComponent(sagaStoreFactory StoreFactory, sagaMutex mutex.Mutex, opts ...configOption) *Component

func (Component) Init

func (c Component) Init(mBus *foreman.MessageBus) error

func (*Component) RegisterContracts

func (c *Component) RegisterContracts(contracts ...message.Object)

func (*Component) RegisterSagaEndpoints

func (c *Component) RegisterSagaEndpoints(endpoints ...endpoint.Endpoint)

func (*Component) RegisterSagas

func (c *Component) RegisterSagas(sagas ...saga.Saga)

type StoreFactory

type StoreFactory func(msgMarshaller message.Marshaller) (saga.Store, error)