stores

Documentation

Index

• func NewInMemoryStore() saga.Store
• type InMemorySagaStore
  • func (store *InMemorySagaStore) DeleteSaga(tx *sql.Tx, instance *saga.Instance) error
  • func (store *InMemorySagaStore) GetSagaByID(tx *sql.Tx, sagaID string) (*saga.Instance, error)
  • func (store *InMemorySagaStore) GetSagasByType(tx *sql.Tx, t reflect.Type) ([]*saga.Instance, error)
  • func (store *InMemorySagaStore) Purge() error
  • func (store *InMemorySagaStore) RegisterSagaType(saga gbus.Saga)
  • func (store *InMemorySagaStore) SaveNewSaga(tx *sql.Tx, sagaType reflect.Type, newInstance *saga.Instance) error
  • func (store *InMemorySagaStore) UpdateSaga(tx *sql.Tx, instance *saga.Instance) error

Functions

func NewInMemoryStore

func NewInMemoryStore() saga.Store

NewInMemoryStore is a factory method for the InMemorySagaStore

Types

type InMemorySagaStore

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

InMemorySagaStore stores the saga instances in-memory, not intended for production use

func (*InMemorySagaStore) DeleteSaga

func (store *InMemorySagaStore) DeleteSaga(tx *sql.Tx, instance *saga.Instance) error

DeleteSaga implements SagaStore.DeleteSaga

func (*InMemorySagaStore) GetSagaByID

func (store *InMemorySagaStore) GetSagaByID(tx *sql.Tx, sagaID string) (*saga.Instance, error)

GetSagaByID implements SagaStore.GetSagaByID

func (*InMemorySagaStore) GetSagasByType

func (store *InMemorySagaStore) GetSagasByType(tx *sql.Tx, t reflect.Type) ([]*saga.Instance, error)

GetSagasByType implements SagaStore.GetSagasByType

func (*InMemorySagaStore) Purge

func (store *InMemorySagaStore) Purge() error

Purge is used for nothing in this case since the store is not persisted use pgstore or mysqlstore

func (*InMemorySagaStore) RegisterSagaType

func (store *InMemorySagaStore) RegisterSagaType(saga gbus.Saga)

RegisterSagaType implements SagaStore.RegisterSagaType

func (*InMemorySagaStore) SaveNewSaga

func (store *InMemorySagaStore) SaveNewSaga(tx *sql.Tx, sagaType reflect.Type, newInstance *saga.Instance) error

SaveNewSaga implements SagaStore.SaveNewSaga

func (*InMemorySagaStore) UpdateSaga

func (store *InMemorySagaStore) UpdateSaga(tx *sql.Tx, instance *saga.Instance) error

UpdateSaga implements SagaStore.UpdateSaga