rabbitmq

type Client interface {
	SetHandler(eventName string, handler EventHandler)
	HandleChannel(ctx context.Context, channelName string, consumerName string, args amqp.Table) error
}

type Config struct {
	Addr     string    `mapstructure:"addr"`
	Username string    `mapstructure:"username"`
	Password string    `mapstructure:"password"`
	VHost    string    `mapstructure:"vhost"`
	Exchange *Exchange `mapstructure:"exchange"`
}

type Connection struct {
	Connection *amqp.Connection
	Channel    *amqp.Channel
	// contains filtered or unexported fields
}

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

type ConsumerHandler func(data []byte) (success bool)

type Credentials struct {
	Protocol string
	Username string
	Password string
	Addr     string
	VHost    string
	Exchange *Exchange
}

type Event struct {
	Name       string `json:"name"`
	ID         string `json:"id"`
	SequenceID string `json:"seq"`
	TimeStamp  string `json:"ts"`
	Content    string `json:"content"`
	Persist    string `json:"store"`
	Channel    string `json:"channel"`
}

type EventHandler func(event Event) error

type Exchange struct {
	Name       string `mapstructure:"name"`
	Type       string `mapstructure:"type"`
	Durable    bool   `mapstructure:"durable"`
	Queue      string `mapstructure:"queue"`
	RoutingKey string `mapstructure:"routing_key"`
}

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

type Publisher struct {
	Connection *Connection
	Exchange   *Exchange
}