listener

Documentation

Index

• Variables
• func New(handler Handler, inflightSize int) (io.Closer, chan<- Transport)
• type Handler
• type Session
  • func (s *Session) Close() error
  • func (s *Session) ConnAck(returnCode int32) error
  • func (s *Session) Connect() *packet.Connect
  • func (s *Session) ID() string
  • func (s *Session) OnClosed(f func()) func()
  • func (s *Session) OnLost(f func()) func()
  • func (s *Session) OnPublish(f func(packet *packet.Publish)) func()
  • func (s *Session) OnSubscribe(f func(packet *packet.Subscribe)) func()
  • func (s *Session) OnUnsubscribe(f func(packet *packet.Unsubscribe)) func()
  • func (s *Session) PubAck(mid int32) error
  • func (s *Session) Publish(p *packet.Publish) error
  • func (s *Session) RemoteAddress() string
  • func (s *Session) SubAck(mid int32, grantedQoS []int32) error
  • func (s *Session) Tenant() string
  • func (s *Session) TransportName() string
• type TimeoutReadWriteCloser
• type Transport

Variables

var (
	ErrSessionDisconnected = errors.New("session disconnected")
)

Functions

func New

func New(handler Handler, inflightSize int) (io.Closer, chan<- Transport)

Types

type Handler

type Handler interface {
	Authenticate(transport Transport, sessionID, username string, password string) (tenant string, id string, err error)
	OnConnect(sess *Session)
}

type Session

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

func (*Session) Close

func (s *Session) Close() error

func (*Session) ConnAck

func (s *Session) ConnAck(returnCode int32) error

func (*Session) Connect

func (s *Session) Connect() *packet.Connect

func (*Session) ID

func (s *Session) ID() string

func (*Session) OnClosed

func (s *Session) OnClosed(f func()) func()

func (*Session) OnLost

func (s *Session) OnLost(f func()) func()

func (*Session) OnPublish

func (s *Session) OnPublish(f func(packet *packet.Publish)) func()

func (*Session) OnSubscribe

func (s *Session) OnSubscribe(f func(packet *packet.Subscribe)) func()

func (*Session) OnUnsubscribe

func (s *Session) OnUnsubscribe(f func(packet *packet.Unsubscribe)) func()

func (*Session) PubAck

func (s *Session) PubAck(mid int32) error

func (*Session) Publish

func (s *Session) Publish(p *packet.Publish) error

func (*Session) RemoteAddress

func (s *Session) RemoteAddress() string

func (*Session) SubAck

func (s *Session) SubAck(mid int32, grantedQoS []int32) error

func (*Session) Tenant

func (s *Session) Tenant() string

func (*Session) TransportName

func (s *Session) TransportName() string

type TimeoutReadWriteCloser

type TimeoutReadWriteCloser interface {
	SetDeadline(time.Time) error
	io.ReadWriteCloser
}

type Transport

type Transport interface {
	io.Closer
	Name() string
	Encrypted() bool
	EncryptionState() *tls.ConnectionState
	Channel() TimeoutReadWriteCloser
	RemoteAddress() string
}