mqinfra

type AWSSQSInfraConfig struct {
	Endpoint                  string
	Region                    string
	ServiceAccountCredentials string
	Topic                     string
}

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
	ServiceAccountCredentials string
}

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

	Policy Policy
}

type Policy struct {
	VisibilityTimeout int
	RetryLimit        int
}

type RabbitMQInfraConfig struct {
	ServerURL string
	Exchange  string
	Queue     string
}