pool

Documentation

Index

• type Response
• type WorkersPool
  • func NewWorkersPool(pubsubs map[string]pubsub.PubSub, connections *sync.Map, log logger.Logger) *WorkersPool
  • func (wp *WorkersPool) Queue(msg *websocketsv1.Message)
  • func (wp *WorkersPool) Stop()

Types

type Response

type Response struct {
	Topic   string `json:"topic"`
	Payload string `json:"payload"`
}

Response from the server

type WorkersPool

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

func NewWorkersPool

func NewWorkersPool(pubsubs map[string]pubsub.PubSub, connections *sync.Map, log logger.Logger) *WorkersPool

NewWorkersPool constructs worker pool for the websocket connections

func (*WorkersPool) Queue

func (wp *WorkersPool) Queue(msg *websocketsv1.Message)

func (*WorkersPool) Stop

func (wp *WorkersPool) Stop()