messaging

type Config struct {
	// Kind selects the backend; empty means KindMemory.
	Kind client.Kind `yaml:"kind" mapstructure:"kind"`

	// SQS is KindSQS's connection: region, endpoint and credentials (env-bound).
	SQS infra.SQSConfig `yaml:"sqs" mapstructure:"sqs"`

	// Name labels the client in decoration overrides, metrics, spans and logs; empty
	// uses the family name ("messaging").
	Name string `yaml:"name" mapstructure:"name"`

	// Receive tunes the KindSQS consumer's long poll and failed-message backoff.
	Receive Receive `yaml:"receive" mapstructure:"receive"`
}

type Deps struct {
	// Decorations decorates the client from the decoration config (decoration.clients)
	// and supplies its observability.
	decorate.Decorations

	// Redis is the shared go-redis client KindRedis requires.
	Redis *goredis.Client

	// Broker connects a KindMemory publisher and consumer; nil gives each its own.
	Broker *memory.Broker

	// SQSAPI replaces the SQS SDK client KindSQS builds from Config.SQS.
	SQSAPI sqs.API

	// Ready gates every SQS receive: while it errors the consumer backs off.
	Ready func(ctx context.Context) error
}

type Receive struct {
	// NackDelay, when Max is positive, hides a message whose handler failed for a
	// jittered delay before redelivery.
	NackDelay sqs.NackDelay `yaml:"nack_delay" mapstructure:"nack_delay"`

	// BaseBackoff is the initial wait after a failed receive; 0 uses the default.
	BaseBackoff time.Duration `yaml:"base_backoff" mapstructure:"base_backoff"`

	// WaitTimeSeconds is the long-poll wait per receive, 0 to 20; 0 uses the default.
	WaitTimeSeconds int32 `yaml:"wait_time_seconds" mapstructure:"wait_time_seconds"`
}