redis

Documentation

Index

• type Broker
  • func NewBroker(conn *Connection) *Broker
  • func (b *Broker) Publish(ctx context.Context, message *model.Message) error
  • func (b *Broker) Subscribe(ctx context.Context, roomId string) <-chan *model.Message
• type Connection
  • func Connect(url string) *Connection

Types

type Broker

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

func NewBroker

func NewBroker(conn *Connection) *Broker

func (*Broker) Publish

func (b *Broker) Publish(ctx context.Context, message *model.Message) error

func (*Broker) Subscribe

func (b *Broker) Subscribe(ctx context.Context, roomId string) <-chan *model.Message

type Connection

type Connection struct {
	Rdb *redis.Client
}

func Connect

func Connect(url string) *Connection