service

Documentation

Index

• type Device
• type Mesher
  • func (msh *Mesher) GetChan() chan proto.Message
  • func (msh *Mesher) Serve()
  • func (msh *Mesher) Stop()
• type Messenger
  • func (m *Messenger) Register(opCode byte, listener message.Receiver)
  • func (m *Messenger) RegisterSome(opCodes []byte, receiver message.Receiver)
  • func (m *Messenger) Serve()
  • func (m *Messenger) Stop()
• type Peer
• type Player
  • func (p *Player) Err() error
  • func (p *Player) GetChan() chan proto.Message
  • func (p *Player) Serve()
  • func (p *Player) Stop()
  • func (p *Player) Stream(samples [][2]float64) (n int, ok bool)
• type Server
  • func (srv *Server) GetChan() chan proto.Message
  • func (srv *Server) Serve()
  • func (srv *Server) Stop()
• type Streamer
  • func (s *Streamer) Serve()
  • func (s *Streamer) Stop()

Types

type Device

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

Device mesh device

type Mesher

type Mesher struct {
	Messenger *Messenger
	// contains filtered or unexported fields
}

Mesher mesher service

func (*Mesher) GetChan

func (msh *Mesher) GetChan() chan proto.Message

GetChan returns messaging chan

func (*Mesher) Serve

func (msh *Mesher) Serve()

Serve main service code

func (*Mesher) Stop

func (msh *Mesher) Stop()

Stop clean service when stopped by supervisor

type Messenger

type Messenger struct {
	Message chan proto.Message
	// contains filtered or unexported fields
}

Messenger internal messenger service

func (*Messenger) Register

func (m *Messenger) Register(opCode byte, listener message.Receiver)

Register add message listener to listener map for one opCode

func (*Messenger) RegisterSome

func (m *Messenger) RegisterSome(opCodes []byte, receiver message.Receiver)

RegisterSome add message listener to listener map for multiple opCode

func (*Messenger) Serve

func (m *Messenger) Serve()

Serve main service code

func (*Messenger) Stop

func (m *Messenger) Stop()

Stop clean service when stopped by supervisor

type Peer

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

Peer structure represents discovered peer on mesh network

type Player

type Player struct {
	Message chan proto.Message

	Messenger *Messenger
	// contains filtered or unexported fields
}

Player audio player service

func (*Player) Err

func (p *Player) Err() error

Err return streaming error (never)

func (*Player) GetChan

func (p *Player) GetChan() chan proto.Message

GetChan returns messaging chan

func (*Player) Serve

func (p *Player) Serve()

Serve main service code

func (*Player) Stop

func (p *Player) Stop()

Stop clean service when stopped by supervisor

func (*Player) Stream

func (p *Player) Stream(samples [][2]float64) (n int, ok bool)

Stream stream audio samples from received data

type Server

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

Server UDP server service

func (*Server) GetChan

func (srv *Server) GetChan() chan proto.Message

GetChan returns messaging chan

func (*Server) Serve

func (srv *Server) Serve()

Serve main service code

func (*Server) Stop

func (srv *Server) Stop()

Stop clean service when stopped by supervisor

type Streamer

type Streamer struct {
	Message chan proto.Message

	Messenger *Messenger
	// contains filtered or unexported fields
}

Streamer audio streamer service

func (*Streamer) Serve

func (s *Streamer) Serve()

Serve main service code

func (*Streamer) Stop

func (s *Streamer) Stop()

Stop clean service when stopped by supervisor