mqs

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

type AWSSQSConfig struct {
	Endpoint                  string // optional - dev-focused
	Region                    string
	ServiceAccountCredentials string
	Topic                     string
}

type AzureServiceBusConfig struct {
}

type GCPPubSubConfig struct {
}

type InMemoryConfig struct {
	Name string
}

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

type IncomingMessage interface {
	ToMessage() (*Message, error)
	FromMessage(msg *Message) error
}

type Message struct {
	QueueMessage
	LoggableID string
	Body       []byte
}

type Policy struct {
	VisibilityTimeout int // seconds
	RetryLimit        int
}

type Queue interface {
	Init(ctx context.Context) (func(), error)
	Publish(ctx context.Context, msg IncomingMessage) error
	Subscribe(ctx context.Context) (Subscription, error)
}

type QueueConfig struct {
	AWSSQS          *AWSSQSConfig
	AzureServiceBus *AzureServiceBusConfig
	GCPPubSub       *GCPPubSubConfig
	RabbitMQ        *RabbitMQConfig
	InMemory        *InMemoryConfig // mainly for testing purposes

	Policy Policy
}

type QueueMessage interface {
	Ack()
	Nack()
}

type RabbitMQConfig struct {
	ServerURL string
	Exchange  string // optional
	Queue     string
}

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

type Subscription interface {
	Receive(ctx context.Context) (*Message, error)
	Shutdown(ctx context.Context) error
}

type UnimplementedQueue struct{}

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