usecase

Documentation

Index

• func ValidateForwarderSendInRequest(prefix string, item *entities.Request) error
• type Dispatcher
  • func New(conf *config.Config, logger logging.Logger, ...) Dispatcher
• type Forwarder
• type ForwarderSendIn
  • func (in *ForwarderSendIn) Validate() error
• type ForwarderSendOut

Functions

func ValidateForwarderSendInRequest

func ValidateForwarderSendInRequest(prefix string, item *entities.Request) error

Types

type Dispatcher

type Dispatcher interface {
	Forwarder() Forwarder
}

func New

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

type Forwarder

type Forwarder interface {
	Send(ctx context.Context, in *ForwarderSendIn) (*ForwarderSendOut, error)
}

type ForwarderSendIn

type ForwarderSendIn struct {
	Concurrency int
	Requests    map[string]*entities.Request
}

func (*ForwarderSendIn) Validate

func (in *ForwarderSendIn) Validate() error

type ForwarderSendOut

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