mqinfra

Documentation

Index

• Variables
• type AWSSQSInfraConfig
• type AzureServiceBusInfraConfig
• type GCPPubSubInfraConfig
• type MQInfra
  • func New(cfg *MQInfraConfig) MQInfra
• type MQInfraConfig
• type Policy
• type RabbitMQInfraConfig

Variables

var (
	ErrInvalidConfig      = fmt.Errorf("invalid config")
	ErrInfraUnimplemented = fmt.Errorf("unimplemented infra")
)

Types

type AWSSQSInfraConfig

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

type AzureServiceBusInfraConfig

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

type GCPPubSubInfraConfig struct {
	ProjectID                 string
	TopicID                   string
	SubscriptionID            string
	ServiceAccountCredentials string
}

type MQInfra

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

func New

func New(cfg *MQInfraConfig) MQInfra

type MQInfraConfig

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

	Policy Policy
}

type Policy

type Policy struct {
	VisibilityTimeout int
	RetryLimit        int
}

type RabbitMQInfraConfig

type RabbitMQInfraConfig struct {
	ServerURL string
	Exchange  string
	Queue     string
}