The highest tagged major version is v2.

pika

package module

v0.4.0 Latest Latest Go to latest Published: Mar 22, 2022 License: MIT Imports: 5 Imported by: 1

Details

This section is empty.

This section is empty.

func AppendToTopic(key, str string) string

type Consumer interface {
	Options() ConsumerOptions
	HandleMessage([]byte) error
}

type ConsumerOptions struct {
	Exchange  string
	Topic     string
	QueueName string
}

type NotificationOptions struct {
	Exchange string
	Topic    string
	Interval time.Duration
}

type Notifier interface {
	Options() NotificationOptions
	Stop() bool
	Notify() (string, error)
}

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

func (p Publisher) Publish(message string) error

type PublisherOptions struct {
	Exchange string
	Topic    string
}

type Queue[T any] struct {
	// contains filtered or unexported fields
}

func NewQueue[T any]() *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 {
	// contains filtered or unexported fields
}

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

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

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

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

func (rc RabbitConnector) Disconnect() error

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

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