pika

Jan 23, 2023

Changes in this version

type AMQPChannel

+ func (c *AMQPChannel) Close() error

Oct 13, 2022

Changes in this version

type AMQPChannel

+ func (c *AMQPChannel) Logger() Logger

type Channel

+ Logger func() Logger

type Connector

+ Logger func() Logger

type PubSub

+ func (p *PubSub) Logger() Logger

type PubSubChannel

+ func (p *PubSubChannel) Logger() Logger

type RabbitConnector

+ func (rc *RabbitConnector) Logger() Logger

Oct 13, 2022

Changes in this version

+ type Logger interface

+ Debug func(...any)

+ Error func(...any)

+ Info func(...any)

+ Warn func(...any)

Sep 1, 2022

Changes in this version

+ type AMQPChannel struct

+ func NewAMQPChannel(conn *RabbitConnector) (*AMQPChannel, error)

+ func (c *AMQPChannel) Ack(tag uint64, multiple bool)

+ func (c *AMQPChannel) Consume(opts ConsumerOptions, outMsgs chan any) error

+ func (c *AMQPChannel) Log(msg string)

+ func (c *AMQPChannel) Publish(opts PublisherOptions, msg []byte) error

+ func (c *AMQPChannel) Reject(tag uint64, requeue bool)

type Channel

+ Ack func(uint64, bool)

+ Consume func(ConsumerOptions, chan any) error

+ Log func(string)

+ Publish func(PublisherOptions, []byte) error

+ Reject func(uint64, bool)

+ type Connector interface

+ Channel func() (Channel, error)

+ Connect func(string) error

+ Disconnect func() error

+ Log func(string)

+ SetLogger func(LogFunc)

+ func NewPubSub() Connector

+ type LogFunc func(string)

+ type PubSub struct

+ func (p *PubSub) Channel() (Channel, error)

+ func (p *PubSub) Connect(string) error

+ func (p *PubSub) Disconnect() error

+ func (p *PubSub) Log(msg string)

+ func (p *PubSub) SetLogger(f LogFunc)

+ type PubSubChannel struct

+ func (p *PubSubChannel) Ack(uint64, bool)

+ func (p *PubSubChannel) Consume(o ConsumerOptions, out chan any) error

+ func (p *PubSubChannel) Log(s string)

+ func (p *PubSubChannel) Publish(o PublisherOptions, data []byte) error

+ func (p *PubSubChannel) Reject(uint64, bool)

type RabbitConnector

+ func (rc *RabbitConnector) Log(msg string)

+ func (rc *RabbitConnector) SetLogger(logFunc LogFunc)

Aug 10, 2022

Changes in this version

+ type Channel struct

Jun 11, 2022

Changes in this version

type ConsumerOptions

+ func (co ConsumerOptions) SetName(name string) ConsumerOptions

type Msg

+ func (msg Msg[T]) Retry(backoff time.Duration, msgs chan Msg[T])

+ func (msg Msg[T]) ShouldRetry(retries int) bool

Jun 3, 2022

Changes in this version

+ type Msg struct

Jun 2, 2022

Changes in this version

type ConsumerOptions

+ func (co ConsumerOptions) SetDurable() ConsumerOptions

May 15, 2022

Changes in this version

+ func StartNotifier(r *RabbitConnector, notifier Notifier[T]) error

type Publisher

+ func CreatePublisher(r *RabbitConnector, options PublisherOptions) (*Publisher[T], error)

Apr 28, 2022

Changes in this version

+ func StartConsumer(consumer Consumer[T], r *RabbitConnector) error

+ type ConsumerRetry struct

Mar 25, 2022

Changes in this version

type ConsumerOptions

+ func NewConsumerOptions(exchange, topic, queue string) ConsumerOptions

Mar 25, 2022

Changes in this version

type Queue

+ func (q *Queue[T]) DequeueNoWait() *T

Mar 25, 2022

Changes in this version

type ConsumerOptions

+ func (co *ConsumerOptions) WithRetry(retries int, interval time.Duration)

+ func (co ConsumerOptions) HasRetry() bool

+ type Entry struct

Mar 24, 2022

Changes in this version

type ConsumerOptions

+ Retries int

+ RetryInterval time.Duration

+ type Retrier struct

+ func NewRetrier(c *amqp.Channel) *Retrier

+ func (r *Retrier) Retry(rm *RetryMessage)

+ type RetryMessage struct

+ Exchange string

+ Interval time.Duration

+ Message string

+ Retries int

+ Topic string

Mar 22, 2022

Changes in this version

+ func AppendToTopic(key, str string) string

+ type Consumer interface

+ HandleMessage func([]byte) error

+ Options func() ConsumerOptions

+ type ConsumerOptions struct

+ Exchange string

+ QueueName string

+ Topic string

+ type NotificationOptions struct

+ Exchange string

+ Interval time.Duration

+ Topic string

+ type Notifier interface

+ Notify func() (string, error)

+ Options func() NotificationOptions

+ Stop func() bool

+ type Publisher struct

+ func (p Publisher) Publish(message string) error

+ type PublisherOptions struct

+ Exchange string

+ Topic string

+ type Queue struct

+ func NewQueue() *Queue[T]

+ func (q *Queue[T]) Dequeue() (*T, error)

+ func (q *Queue[T]) Length() int

+ func (q *Queue[T]) PeakAt(i int) (*T, error)

+ func (q *Queue[T]) Peek() (*T, error)

+ func (q *Queue[T]) Queue(e *T)

+ type RabbitConnector struct

+ func NewConnector(url string) (*RabbitConnector, error)

+ func (r *RabbitConnector) CreatePublisher(options PublisherOptions) (*Publisher, error)

+ func (r *RabbitConnector) StartConsumer(consumer Consumer) error

+ func (r *RabbitConnector) StartNotifier(notifier Notifier) error

+ func (rc *RabbitConnector) Connect(url string) error

+ func (rc RabbitConnector) Channel() (*amqp.Channel, error)

+ func (rc RabbitConnector) Disconnect() error