saga

Documentation

Index

• type SagaCoordinator
  • func NewSagaCoordinator(logger *zap.Logger) *SagaCoordinator
  • func (s *SagaCoordinator) RunSaga(ctx context.Context, operationName string, steps ...*saga.Step) error

Types

type SagaCoordinator

type SagaCoordinator struct {
	Logger *zap.Logger
}

func NewSagaCoordinator

func NewSagaCoordinator(logger *zap.Logger) *SagaCoordinator

NewSagaCoordinator creates a new saga object

func (*SagaCoordinator) RunSaga

func (s *SagaCoordinator) RunSaga(ctx context.Context, operationName string, steps ...*saga.Step) error

RunSaga creates a new saga instance and runs the required steps