status

Documentation

Index

• type SagaEvent
• type StatusHandler
  • func NewStatusHandler(logger log.Logger, service StatusService) *StatusHandler
  • func (h *StatusHandler) GetFilteredBy(resp http.ResponseWriter, r *http.Request)
  • func (h *StatusHandler) GetStatus(resp http.ResponseWriter, r *http.Request)
• type StatusResponse
• type StatusService
  • func NewStatusService(store saga.Store) StatusService

Types

type SagaEvent

type SagaEvent struct {
	saga.HistoryEvent
}

type StatusHandler

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

func NewStatusHandler

func NewStatusHandler(logger log.Logger, service StatusService) *StatusHandler

func (*StatusHandler) GetFilteredBy

func (h *StatusHandler) GetFilteredBy(resp http.ResponseWriter, r *http.Request)

func (*StatusHandler) GetStatus

func (h *StatusHandler) GetStatus(resp http.ResponseWriter, r *http.Request)

type StatusResponse

type StatusResponse struct {
	SagaUID string      `json:"saga_uid"`
	Status  string      `json:"status"`
	Payload interface{} `json:"payload"`
	Events  []SagaEvent `json:"events"`
}

type StatusService

type StatusService interface {
	GetStatus(ctx context.Context, sagaId string) (*StatusResponse, error)
	GetFilteredBy(ctx context.Context, sagaId, status, sagaType string) ([]*StatusResponse, error)
}

func NewStatusService

func NewStatusService(store saga.Store) StatusService