mqsar

Documentation

Index

• func RunFront(config *conf.Config, impl Server) (err error)
• type Broker
  • func Run(config *conf.Config, impl Server) (b *Broker, err error)
  • func (b *Broker) Close()
  • func (b *Broker) DisConnClient()
  • func (b *Broker) DisConnClientByClientId(clientId string)
  • func (b *Broker) IsClosing() bool
• type PulsarBridgeMq
  • func (p *PulsarBridgeMq) Close()
  • func (p *PulsarBridgeMq) PreClose()
  • func (p *PulsarBridgeMq) Publish(e *bridge.Elements) (bool, error)
• type Server

Functions

func RunFront

func RunFront(config *conf.Config, impl Server) (err error)

Types

type Broker

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

func Run

func Run(config *conf.Config, impl Server) (b *Broker, err error)

func (*Broker) Close

func (b *Broker) Close()

func (*Broker) DisConnClient

func (b *Broker) DisConnClient()

func (*Broker) DisConnClientByClientId

func (b *Broker) DisConnClientByClientId(clientId string)

func (*Broker) IsClosing

func (b *Broker) IsClosing() bool

type PulsarBridgeMq

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

func (*PulsarBridgeMq) Close

func (p *PulsarBridgeMq) Close()

func (*PulsarBridgeMq) PreClose

func (p *PulsarBridgeMq) PreClose()

func (*PulsarBridgeMq) Publish

func (p *PulsarBridgeMq) Publish(e *bridge.Elements) (bool, error)

type Server

type Server interface {
	MqttAuth(username, password, clientId string) (bool, error)
	MqttProduceTopic(username, clientId, topic string) (string, error)
	MqttConsumeTopic(username, clientId, topic string) (string, error)
}