mdns

Documentation

Index

• Constants
• Variables
• func NewMsgEvent(msg *dns.Msg, addr net.Addr, ifIndex int) gopi.Event
• func NewService(zone string) *service
• func NewServices(msg *dns.Msg, zone string) *services
• func NewTokenizer(src string) *tokenizer
• func Quote(src string) string
• func Unquote(src string) (string, error)
• type Discovery
  • func (this *Discovery) EnumerateServices(ctx context.Context) ([]string, error)
  • func (this *Discovery) Lookup(ctx context.Context, srv string) ([]gopi.ServiceRecord, error)
  • func (this *Discovery) ParseEmit(msg *dns.Msg) error
  • func (this *Discovery) Run(ctx context.Context) error
• type FuncRecordsForService
• type FuncServices
• type Listener
  • func (this *Listener) AddrForIface(ifIndex int, flags gopi.ServiceFlag) []net.IP
  • func (this *Listener) Define(cfg gopi.Config) error
  • func (this *Listener) Dispose() error
  • func (this *Listener) New(cfg gopi.Config) error
  • func (this *Listener) Run(ctx context.Context) error
  • func (this *Listener) Send(msg *dns.Msg, ifIndex int) error
  • func (this *Listener) String() string
  • func (this *Listener) Zone() string
• type Responder
  • func (this *Responder) NewServiceRecord(service string, name string, port uint16, txt []string, flags gopi.ServiceFlag) (gopi.ServiceRecord, error)
  • func (this *Responder) ProcessQuestion(msg *msgevent) error
  • func (this *Responder) Records(name string) []gopi.ServiceRecord
  • func (this *Responder) Run(ctx context.Context) error
  • func (this *Responder) SendAnswers(ifIndex int, msgs []*dns.Msg) error
  • func (this *Responder) Serve(ctx context.Context, r []gopi.ServiceRecord) error
  • func (this *Responder) Services() []string
  • func (this *Responder) SetServices(r []gopi.ServiceRecord) error

Constants

const (
	EOF rune = -(iota + 1)
)

Variables

var (
	MULTICAST_ADDR_IPV4 = &net.UDPAddr{IP: net.ParseIP("224.0.0.251"), Port: 5353}
	MULTICAST_ADDR_IPV6 = &net.UDPAddr{IP: net.ParseIP("ff02::fb"), Port: 5353}
)

var (
	ErrParseError = errors.New("Parse Error")
)

Functions

func NewMsgEvent

func NewMsgEvent(msg *dns.Msg, addr net.Addr, ifIndex int) gopi.Event

func NewService

func NewService(zone string) *service

func NewServices

func NewServices(msg *dns.Msg, zone string) *services

Parse DNS message and capture service records

func NewTokenizer

func NewTokenizer(src string) *tokenizer

func Quote

func Quote(src string) string

func Unquote

func Unquote(src string) (string, error)

Unquote returns a bare string without quoted characters. The following Coversions happen: \\ \n \f \t \r Happen as normal \xFF returns a byte from hex \123 returns a byte from decimal \0123 returns a bype from octal

Types

type Discovery

type Discovery struct {
	gopi.Unit
	gopi.Publisher
	sync.WaitGroup
	gopi.Logger
	*Listener
	*Responder
}

func (*Discovery) EnumerateServices

func (this *Discovery) EnumerateServices(ctx context.Context) ([]string, error)

func (*Discovery) Lookup

func (this *Discovery) Lookup(ctx context.Context, srv string) ([]gopi.ServiceRecord, error)

func (*Discovery) ParseEmit

func (this *Discovery) ParseEmit(msg *dns.Msg) error

func (*Discovery) Run

func (this *Discovery) Run(ctx context.Context) error

type FuncRecordsForService

type FuncRecordsForService func(string) []gopi.ServiceRecord

FuncRecordsForService returns service records for named service

type FuncServices

type FuncServices func() []string

FuncServices returns fully-qualified service names

type Listener

type Listener struct {
	sync.RWMutex
	sync.WaitGroup
	gopi.Unit
	gopi.Logger
	gopi.Publisher
	// contains filtered or unexported fields
}

func (*Listener) AddrForIface

func (this *Listener) AddrForIface(ifIndex int, flags gopi.ServiceFlag) []net.IP

func (*Listener) Define

func (this *Listener) Define(cfg gopi.Config) error

func (*Listener) Dispose

func (this *Listener) Dispose() error

func (*Listener) New

func (this *Listener) New(cfg gopi.Config) error

func (*Listener) Run

func (this *Listener) Run(ctx context.Context) error

func (*Listener) Send

func (this *Listener) Send(msg *dns.Msg, ifIndex int) error

Send a DNS message to a particular interface or all interfaces if 0

func (*Listener) String

func (this *Listener) String() string

func (*Listener) Zone

func (this *Listener) Zone() string

type Responder

type Responder struct {
	gopi.Unit
	gopi.Publisher
	gopi.Logger
	sync.WaitGroup
	sync.RWMutex
	*Listener
	// contains filtered or unexported fields
}

func (*Responder) NewServiceRecord

func (this *Responder) NewServiceRecord(service string, name string, port uint16, txt []string, flags gopi.ServiceFlag) (gopi.ServiceRecord, error)

func (*Responder) ProcessQuestion

func (this *Responder) ProcessQuestion(msg *msgevent) error

func (*Responder) Records

func (this *Responder) Records(name string) []gopi.ServiceRecord

func (*Responder) Run

func (this *Responder) Run(ctx context.Context) error

func (*Responder) SendAnswers

func (this *Responder) SendAnswers(ifIndex int, msgs []*dns.Msg) error

func (*Responder) Serve

func (this *Responder) Serve(ctx context.Context, r []gopi.ServiceRecord) error

func (*Responder) Services

func (this *Responder) Services() []string

func (*Responder) SetServices

func (this *Responder) SetServices(r []gopi.ServiceRecord) error