chat

Documentation

Index

• Variables
• type Broadcaster
  • func NewBroadcaster(rabbitBroker *rabbitmq.Broker, redisBroker *redis.Broker) *Broadcaster
  • func (b *Broadcaster) Start(ctx context.Context) error
• type Subscriber

Variables

var ErrBroadcasterAlreadyStarted = errors.New("broadcaster already started")

var ErrBroadcasterStopped = errors.New("broadcaster stopped")

Types

type Broadcaster

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

func NewBroadcaster

func NewBroadcaster(rabbitBroker *rabbitmq.Broker, redisBroker *redis.Broker) *Broadcaster

func (*Broadcaster) Start

func (b *Broadcaster) Start(ctx context.Context) error

type Subscriber

type Subscriber interface {
	Subscribe(ctx context.Context, roomId string) <-chan *model.Message
}