rabbitmq

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

type Credentials struct {
	Host     string `mapstructure:"host"`
	Username string `mapstructure:"username"`
	Password string `mapstructure:"password"`
}

type RabbitDelivery interface {
	// Ack acknowledges processing of a Delivery.
	Ack(multiple bool) error
	// Nack negatively acknowledges a Delivery.
	Nack(multiple bool, requeue bool) error
	// Reject rejects a delivery.
	Reject(requeue bool) error

	// Body returns the message body.
	Body() []byte

	// Acknowledger provides acknowledgement information.
	Acknowledger() amqp.Acknowledger
	// Header returns the message header.
	Header() amqp.Table
	// ContentType returns the message content type.
	ContentType() string
	// ContentEncoding returns the message content encoding.
	ContentEncoding() string
	// DeliveryMode returns the delivery mode.
	DeliveryMode() uint8
	// Priority returns the message priority.
	Priority() uint8
	// CorelationId returns the correlation id.
	CorelationId() string
	// ReplyTo returns the reply to value.
	ReplyTo() string
	// Expiration returns the message expiration.
	Expiration() string
	// MessageId returns the message id.
	MessageId() string
	// Timestamp returns the message timestamp.
	Timestamp() time.Time
	// Type returns the message type.
	Type() string
	// UserId returns the creating user id.
	UserId() string
	// AppId returns the creating application id.
	AppId() string
	// ConsumerTag returns the consumer tag.
	ConsumerTag() string
	// MessageCount returns the number of messages pending acknowledgement.
	MessageCount() uint32
	// DeliveryTag returns the delivery tag.
	DeliveryTag() uint64
	// Redelivered returns true if this message is being redelivered.
	Redelivered() bool
	// Exchange returns the exchange this message was published to.
	Exchange() string
	// RoutingKey returns the routing key used when publishing this message.
	RoutingKey() string
}

type RabbitMQClient interface {
	Check(ctx context.Context) error
	ReadMsgs(ctx context.Context, maxAmount int, wait time.Duration, callback ReadMsgCallback)
	Push(ctx context.Context, data []byte) error
	UnsafePush(ctx context.Context, data []byte) error
	Consume() (<-chan amqp.Delivery, error)
	Close() error
}

type ReadMsgCallback func(ctx context.Context, d RabbitDelivery) error