pubsub

Documentation

Index

• type PubSub
  • func NewInternalChannelPubSub() PubSub
  • func NewRedisPubSub(redisAddr string) (PubSub, error)
• type Publisher
• type Subscriber

Types

type PubSub

type PubSub interface {
	Publisher
	Subscriber
	Close() error
}

PubSub is an interface that combines the Publisher and Subscriber interface.

func NewInternalChannelPubSub

func NewInternalChannelPubSub() PubSub

NewInternalChannelPubSub creates a new PubSub instance using in-memory channels.

func NewRedisPubSub

func NewRedisPubSub(redisAddr string) (PubSub, error)

NewRedisPubSub creates a new PubSub instance using Redis Streams.

type Publisher

type Publisher interface {
	Publish(ctx context.Context, topic string, msg []byte) error
}

Publisher is an interface that defines the method to publish messages to a topic.

type Subscriber

type Subscriber interface {
	Subscribe(ctx context.Context, topic string) (<-chan []byte, error)
}

Subscriber is an interface that defines the method to subscribe to a topic and consume messages.