connection

Documentation

Index

• func HandleConnection(pool *Pool, conn net.Conn, callback func(message string))
• type Message
• type Pool
  • func NewPool(peers []string) *Pool
  • func (p *Pool) Add(conn net.Conn) error
  • func (p *Pool) Broadcast(msg Message)
  • func (p *Pool) ListConnections() []net.Conn
  • func (p *Pool) Remove(conn net.Conn)

Functions

func HandleConnection

func HandleConnection(pool *Pool, conn net.Conn, callback func(message string))

Types

type Message

type Message struct {
	Kind     string
	Version  string
	Data     string
	Datetime string
}

type Pool

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

func NewPool

func NewPool(peers []string) *Pool

func (*Pool) Add

func (p *Pool) Add(conn net.Conn) error

func (*Pool) Broadcast

func (p *Pool) Broadcast(msg Message)

func (*Pool) ListConnections

func (p *Pool) ListConnections() []net.Conn

func (*Pool) Remove

func (p *Pool) Remove(conn net.Conn)