usecase

Documentation

Index

• func ValidateWarehousePutInAttempt(prefix string, attempt *entities.Attempt) error
• func ValidateWarehousePutInMessage(prefix string, message *entities.Message) error
• func ValidateWarehousePutInRequest(prefix string, request *entities.Request) error
• func ValidateWarehousePutInResponse(prefix string, response *entities.Response) error
• type Storage
  • func New(conf *config.Config, logger logging.Logger, ...) Storage
• type Warehouse
• type WarehousePutIn
  • func (in *WarehousePutIn) Count() int
  • func (in *WarehousePutIn) Validate() error
• type WarehousePutOut

Functions

func ValidateWarehousePutInAttempt

func ValidateWarehousePutInAttempt(prefix string, attempt *entities.Attempt) error

func ValidateWarehousePutInMessage

func ValidateWarehousePutInMessage(prefix string, message *entities.Message) error

func ValidateWarehousePutInRequest

func ValidateWarehousePutInRequest(prefix string, request *entities.Request) error

func ValidateWarehousePutInResponse

func ValidateWarehousePutInResponse(prefix string, response *entities.Response) error

Types

type Storage

type Storage interface {
	Warehouse() Warehouse
}

func New

func New(
	conf *config.Config,
	logger logging.Logger,
	infra *infrastructure.Infrastructure,
	repositories repositories.Repositories,
) Storage

type Warehouse

type Warehouse interface {
	Put(ctx context.Context, in *WarehousePutIn) (*WarehousePutOut, error)
}

type WarehousePutIn

type WarehousePutIn struct {
	BatchSize int
	Messages  map[string]*entities.Message
	Requests  map[string]*entities.Request
	Responses map[string]*entities.Response
	Attempts  map[string]*entities.Attempt
}

func (*WarehousePutIn) Count

func (in *WarehousePutIn) Count() int

func (*WarehousePutIn) Validate

func (in *WarehousePutIn) Validate() error

type WarehousePutOut

type WarehousePutOut struct {
	Success []string
	Error   map[string]error
}