status

Documentation

Index

• func NewResponseWriter(body interface{}, status int) *responseWriter
• func NewResponseWriterFromErrMsg(errMsg string, status int) *responseWriter
• func NewResponseWriterFromError(err error) *responseWriter
• type Filters
• type Pagination
• type ResponseError
  • func NewResponseError(status int, err error) ResponseError
  • func (e ResponseError) Status() int
• type SagaBatch
• type SagaEvent
• type SagaStatus
• 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 StatusService
  • func NewStatusService(store saga.Store) StatusService

Functions

func NewResponseWriter

func NewResponseWriter(body interface{}, status int) *responseWriter

func NewResponseWriterFromErrMsg

func NewResponseWriterFromErrMsg(errMsg string, status int) *responseWriter

func NewResponseWriterFromError

func NewResponseWriterFromError(err error) *responseWriter

Types

type Filters

type Filters struct {
	SagaID   string
	SagaName string
	Status   string
}

type Pagination

type Pagination struct {
	Offset int
	Limit  int
}

type ResponseError

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

func NewResponseError

func NewResponseError(status int, err error) ResponseError

func (ResponseError) Status

func (e ResponseError) Status() int

Status returns http status code

type SagaBatch

type SagaBatch struct {
	Total int          `json:"total"`
	Items []SagaStatus `json:"items"`
}

type SagaEvent

type SagaEvent struct {
	saga.HistoryEvent
}

type SagaStatus

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

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 StatusService

type StatusService interface {
	GetStatus(ctx context.Context, sagaId string) (*SagaStatus, error)
	GetFilteredBy(ctx context.Context, filters *Filters, pagination *Pagination) (*SagaBatch, error)
}

func NewStatusService

func NewStatusService(store saga.Store) StatusService