ws

Documentation

Index

• func ServeWs(pool *Pool, userID primitive.ObjectID, msgUsecase domain.MessageUsecase, ...)
• type Client
• type Pool
  • func NewPool(logger *zap.Logger) *Pool
  • func (p *Pool) Run(brokerUsecase domain.BrokerUsecase)

Functions

func ServeWs

func ServeWs(pool *Pool, userID primitive.ObjectID, msgUsecase domain.MessageUsecase, wr http.ResponseWriter, r *http.Request)

Types

type Client

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

type Pool

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

func NewPool

func NewPool(logger *zap.Logger) *Pool

func (*Pool) Run

func (p *Pool) Run(brokerUsecase domain.BrokerUsecase)