mqspooler

type Config struct {
	Fallback fallback.Config `yaml:"fallback" mapstructure:"fallback"`
	Mq       mq.Config       `yaml:"mq" mapstructure:"mq"`
}

type IBusiness interface {
	ProcessMessage(ctx context.Context, message string) *core.ApplicationError
}

type IFallbackHandler interface {
	Handle(ctx context.Context, payload string, err *core.ApplicationError) *core.ApplicationError
}

type Metrics struct {
	MessageLatency    metric.Int64Histogram
	MessageInFallback metric.Int64Counter
}

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