broker

package
v0.2.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 6, 2022 License: GPL-3.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Broker added in v0.2.5

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

func NewBroker added in v0.2.5

func NewBroker(debug bool) *Broker

type Client

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

func NewClient

func NewClient(conn net.Conn, id string, session bool, broker chan packet.Packet, debug bool) *Client

func (*Client) Contains

func (c *Client) Contains(topic string) bool

func (*Client) Start

func (c *Client) Start()

func (*Client) Stop

func (c *Client) Stop()

func (*Client) String

func (c *Client) String() string

type Server

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

func NewServer added in v0.2.5

func NewServer(debug bool) *Server

func (*Server) Accept

func (s *Server) Accept() (net.Conn, error)

func (*Server) Addr

func (s *Server) Addr() net.Addr

func (*Server) Close

func (s *Server) Close() error

func (*Server) Manage added in v0.2.5

func (s *Server) Manage(broker *Broker)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL