queuefx

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

type Broker interface {
	GetDialect() Dialect

	QueueDeclare(ctx context.Context, name string) (string, error)
	Publish(ctx context.Context, name string, body []byte) error
}

type Config struct {
	Brokers map[string]ConfigBroker `conf:"BROKERS"`
}

type ConfigBroker struct {
	Provider string `conf:"PROVIDER"`
	DSN      string `conf:"DSN"`
}

type Dialect string

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