stream

Documentation

Index

• type Pubsub
  • func (r *Pubsub) Publish(ctx context.Context, topic string, data []byte) error
  • func (r *Pubsub) Subscribe(ctx context.Context, topic string) chan []byte

Types

type Pubsub

type Pubsub struct {
	Redis  *redis.Client
	Logger log.Logger
}

func (*Pubsub) Publish

func (r *Pubsub) Publish(ctx context.Context, topic string, data []byte) error

func (*Pubsub) Subscribe

func (r *Pubsub) Subscribe(ctx context.Context, topic string) chan []byte