mqinfra

type AWSSQSInfraConfig struct {
	Endpoint                  string
	Region                    string
	ServiceAccountCredentials string
	Topic                     string
	DLQ                       string // optional
}

type AzureServiceBusInfraConfig struct {
	ConnectionString string // If set, skip infra management

	TenantID       string
	ClientID       string
	ClientSecret   string
	SubscriptionID string
	ResourceGroup  string
	Namespace      string
	Topic          string
	Subscription   string
}

type GCPPubSubInfraConfig struct {
	ProjectID                 string
	TopicID                   string
	SubscriptionID            string
	DLQTopicID                string // optional
	DLQSubscriptionID         string // optional
	ServiceAccountCredentials string
	MinRetryBackoff           int // seconds, for PubSub RetryPolicy (default: 10)
	MaxRetryBackoff           int // seconds, for PubSub RetryPolicy (default: 600)
}

type MQInfra interface {
	Exist(ctx context.Context) (bool, error)
	Declare(ctx context.Context) error
	TearDown(ctx context.Context) error
}

type MQInfraConfig struct {
	AWSSQS          *AWSSQSInfraConfig
	AzureServiceBus *AzureServiceBusInfraConfig
	GCPPubSub       *GCPPubSubInfraConfig
	RabbitMQ        *RabbitMQInfraConfig
	NATS            *NATSInfraConfig

	Policy Policy
}

type NATSInfraConfig struct {
	ServerURL string
	Stream    string
	Subject   string
	DLQ       string // optional
}

type Policy struct {
	VisibilityTimeout int
	RetryLimit        int
}

type RabbitMQInfraConfig struct {
	ServerURL string
	Exchange  string
	Queue     string
	DLQ       string // optional
}