amqpsubscriber

type ConnectionOption func(o *connectionOptions)

type Consume struct {
	Consumer  string
	Exclusive bool
	NoLocal   bool
	NoWait    bool
	Args      map[string]interface{}
}

type Exchange struct {
	NameFunc   func(topic string) string
	Kind       string
	Durable    bool
	AutoDelete bool
	Internal   bool
	NoWait     bool
	Args       map[string]interface{}
}

type Option func(o *options)

type QosConfig struct {
	PrefetchCount int
	PrefetchSize  int
	Global        bool
}

type Queue struct {
	NameFunc   func(topic string) string
	Durable    bool
	AutoDelete bool
	Exclusive  bool
	NoWait     bool
	Args       map[string]interface{}
}

type QueueBind struct {
	Key    string
	NoWait bool
	Args   map[string]interface{}
}

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

type UnmarshalMsgFunc func(ctx context.Context, topic string, amqpMsg *amqp.Delivery) (msg *easypubsub.Message, err error)