pubsub

Documentation

Index

• type Message
• type PubSub
  • func New(client *redis.Client) *PubSub
  • func (c *PubSub) Close() error
  • func (c *PubSub) Publish(ctx context.Context, channel, id string, payload []byte) error
  • func (c *PubSub) Subscribe(ctx context.Context, channel string) (<-chan *Message, error)

Types

type Message

type Message struct {
	ID      string
	Payload []byte
}

type PubSub

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

func New

func New(client *redis.Client) *PubSub

func (*PubSub) Close

func (c *PubSub) Close() error

func (*PubSub) Publish

func (c *PubSub) Publish(ctx context.Context, channel, id string, payload []byte) error

func (*PubSub) Subscribe

func (c *PubSub) Subscribe(ctx context.Context, channel string) (<-chan *Message, error)