pubsub

Documentation

Overview

Package pubsub provides a publish/subscribe interface for sending messages.

Package pubsub provides a Redis client for publishing and subscribing messages.

Index

• type RabbitMQPubSub
  • func NewRabbitMQPubSub(conn *amqp.Connection) *RabbitMQPubSub
  • func (ps *RabbitMQPubSub) Publish(ctx context.Context, topic string, b []byte) error
  • func (ps *RabbitMQPubSub) Subscribe(ctx context.Context, topic string, eventStream chan []byte)
• type RedisPubSub
  • func NewRedisPubSub(conn *redis.Client) *RedisPubSub
  • func (ps *RedisPubSub) Publish(ctx context.Context, topic string, b []byte) error
  • func (ps *RedisPubSub) Subscribe(ctx context.Context, topic string, eventStream chan []byte)

Types

type RabbitMQPubSub

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

RabbitMQPubSub is a Redis client for publishing and subscribing messages.

func NewRabbitMQPubSub

func NewRabbitMQPubSub(conn *amqp.Connection) *RabbitMQPubSub

NewRabbitMQPubSub creates a new RabbitMQPubSub client.

func (*RabbitMQPubSub) Publish

func (ps *RabbitMQPubSub) Publish(ctx context.Context, topic string, b []byte) error

Publish publishes a message to a topic.

func (*RabbitMQPubSub) Subscribe

func (ps *RabbitMQPubSub) Subscribe(ctx context.Context, topic string, eventStream chan []byte)

Subscribe listens to a topic for incoming messages then adds them to the eventStream channel.

type RedisPubSub

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

RedisPubSub is a Redis client for publishing and subscribing messages.

func NewRedisPubSub

func NewRedisPubSub(conn *redis.Client) *RedisPubSub

NewRedisPubSub creates a new RedisPubSub client.

func (*RedisPubSub) Publish

func (ps *RedisPubSub) Publish(ctx context.Context, topic string, b []byte) error

Publish publishes a message to a topic.

func (*RedisPubSub) Subscribe

func (ps *RedisPubSub) Subscribe(ctx context.Context, topic string, eventStream chan []byte)

Subscribe listens to a topic for incoming messages then adds them to the eventStream channel.