broker

Documentation

Index

• func ClosePrevConnection(clientID string)
• type Broker
  • func NewBroker(config *config.Config) (*Broker, error)
  • func (b *Broker) Start()
• type Client

Functions

func ClosePrevConnection

func ClosePrevConnection(clientID string)

Types

type Broker

type Broker struct {
	Config  *config.Config
	Clients sync.Map
}

Broker store broker info

var RunningBroker *Broker

func NewBroker

func NewBroker(config *config.Config) (*Broker, error)

NewBroker initialize broker

func (*Broker) Start

func (b *Broker) Start()

type Client

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