rabbitgo

type BindingConfig struct {
	RoutingKey string
	NoWait     bool
	Args       amqp.Table
}

type Config struct {
	Host     string
	Port     int
	Username string
	Password string
	Vhost    string
}

type Connection struct {
	IsConnected bool
	IsBlocked   bool
	// contains filtered or unexported fields
}

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

type ConsumerConfig struct {
	Tag           string
	PrefetchCount int
	PrefetchSize  int
	MaxDeliveries int
	Timeout       time.Duration
	AutoAck       bool
	Exclusive     bool
	NoLocal       bool
	NoWait        bool
	Args          amqp.Table
}

type Delivery struct {
	amqp.Delivery

	Delegated bool
	AckError  error
	Response  *amqp.Publishing
	// contains filtered or unexported fields
}

type ErrorTimeout struct {
	Timeout time.Duration
	Queue   string
}

type Exchange struct {
	// Exchange name
	Name string
	// Exchange type
	Type string
	// Durable exchanges will survive server restarts
	Durable bool
	// Will remain declared when there are no remaining bindings.
	AutoDelete bool
	// Exchanges declared as `internal` do not accept accept publishings.Internal
	// exchanges are useful for when you wish to implement inter-exchange topologies
	// that should not be exposed to users of the broker.
	Internal bool
	// When noWait is true, declare without waiting for a confirmation from the server.
	NoWait bool
	// amqp.Table of arguments that are specific to the server's implementation of
	// the exchange can be sent for exchange types that require extra parameters.
	Args amqp.Table
}

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

type ProducerConfig struct {
	Exchange string
	// The key that when publishing a message to a exchange/queue will be only delivered to
	// given routing key listeners
	RoutingKey string
	// Publishing tagpackage
	Tag string
	// Maximum waiting time in miliseconds
	Timeout time.Duration
	// Maximum number of deliveries that will be received
	MaxDeliveries int
	// Queue should be on the server/broker
	Mandatory bool
	// Consumer should be bound to server
	Immediate bool
}

type Publishing struct {
	// Application or exchange specific fields,
	// the headers exchange will inspect this field.
	// TODO: convert to amqp.Table
	Headers map[string]interface{}
	// Properties
	ContentType     string    // MIME content type
	ContentEncoding string    // MIME content encoding
	DeliveryMode    uint8     // Transient (0 or 1) or Persistent (2)
	Priority        uint8     // 0 to 9
	CorrelationId   string    // correlation identifier
	ReplyTo         string    // address to to reply to (ex: RPC)
	Expiration      string    // message expiration spec
	MessageId       string    // message identifier
	Timestamp       time.Time // message timestamp
	Type            string    // message type name
	UserId          string    // creating user id - ex: "guest"
	AppId           string    // creating application id
	// The application specific payload of the message
	Body []byte
}

type Queue struct {
	Name       string
	Durable    bool
	AutoDelete bool
	Exclusive  bool
	NoWait     bool
	Args       amqp.Table
}