mdns

package
v1.0.47 Latest Latest
Warning

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

 Go to latest Published: Oct 27, 2021 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ServicesQuery = "_services._dns-sd._udp"
	DefaultTTL    = 60 * 5 // In seconds (5 mins)

)
View Source 
const (
	DefaultServiceDatabase = "https://www.iana.org/assignments/service-names-port-numbers/service-names-port-numbers.xml"
)
View Source 
const (
	EOF rune = -(iota + 1)
)

Variables

View Source 
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}
)
View Source 
var (
	ErrParseError = errors.New("Parse Error")
)

Functions

func NewDiscovery 

func NewDiscovery(c <-chan message, e chan<- event) (*discovery, error)

func NewListener 

func NewListener(domain, iface string, c chan<- message) (*listener, error)

func NewServiceDatabase 

func NewServiceDatabase() *servicedb

func NewTokenizer 

func NewTokenizer(src string) *tokenizer

func Quote 

func Quote(src string) string

func ReadServiceDatabase 

func ReadServiceDatabase(v string) (*servicedb, error)

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 Config 

type Config struct {
	Interface       string   `yaml:"interface"`
	Domain          string   `yaml:"domain"`
	TTL             int      `yaml:"ttl"`
	ServiceDatabase []string `yaml:"services"`
}

type EventType 

type EventType int
const (
	EVENT_TYPE_ADDED EventType = (1 << iota)
	EVENT_TYPE_REMOVED
	EVENT_TYPE_EXPIRED
	EVENT_TYPE_CHANGED
	EVENT_TYPE_SERVICE
	EVENT_TYPE_NONE EventType = 0
	EVENT_TYPE_MIN            = EVENT_TYPE_ADDED
	EVENT_TYPE_MAX            = EVENT_TYPE_SERVICE
)

func (EventType) FlagString 

func (v EventType) FlagString() string

func (EventType) String 

func (f EventType) String() string

type Server 

type Server struct {
	C chan Event // Channel for emitting events
	// contains filtered or unexported fields
}

func New 

func New(cfg Config) (*Server, error)

func (Server) Changed 

func (this Server) Changed(v *Service) bool

Check if service has changed, returns false if service does not yet exist

func (Server) Delete 

func (this Server) Delete(v *Service)

Delete a service

func (*Server) EnumerateInstances 

func (this *Server) EnumerateInstances(ctx context.Context, services ...string) ([]*Service, error)

func (*Server) EnumerateServices 

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

func (Server) Exists 

func (this Server) Exists(v *Service) *Service

Check if service already exists

func (Server) Get 

func (this Server) Get(name string) *Service

Get returns a service by name, or nil if service not found

func (Server) Instances 

func (this Server) Instances() []*Service

Instances returns service instances

func (Server) Lookup 

func (this Server) Lookup(service string) ServiceDescription

Lookup a record

func (*Server) LookupServiceDescription 

func (this *Server) LookupServiceDescription(v string) ServiceDescription

Return a service description for the given service name

func (Server) Query 

func (this Server) Query(ctx context.Context, msg *dns.Msg, iface int) error

Query by sending multiple messages to interfaces

func (Server) Read 

func (this Server) Read(v string) error

Read records into database

func (*Server) Run 

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

func (Server) Send 

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

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

func (Server) Set 

func (this Server) Set(v *Service)

Set a service and update expiration

func (*Server) String 

func (this *Server) String() string

type Service added in v1.0.46 

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

func NewService 

func NewService(zone string) *Service

func (*Service) Addrs added in v1.0.46 

func (this *Service) Addrs() []net.IP

Addrs returns associated addresses for the service

func (*Service) Equals added in v1.0.46 

func (this *Service) Equals(other *Service) bool

func (*Service) Host added in v1.0.46 

func (this *Service) Host() string

Host returns the host of the service

func (*Service) Instance added in v1.0.46 

func (this *Service) Instance() string

Instance returns the full instance name of the service

func (*Service) Keys added in v1.0.46 

func (this *Service) Keys() []string

Keys returns the keys in the TXT record

func (*Service) MarshalJSON added in v1.0.46 

func (s *Service) MarshalJSON() ([]byte, error)

func (*Service) Name added in v1.0.46 

func (this *Service) Name() string

Name returns the name of the service

func (*Service) Port added in v1.0.46 

func (this *Service) Port() uint16

Port returns the port of the service

func (*Service) Service added in v1.0.46 

func (this *Service) Service() string

Service returns the short service identifier

func (*Service) Txt added in v1.0.46 

func (this *Service) Txt() []string

Txt returns the txt records for the service

func (*Service) ValueForKey added in v1.0.46 

func (this *Service) ValueForKey(key string) string

ValueForKey return value for a key in the TXT record, or empty string if not found

func (*Service) Zone added in v1.0.46 

func (this *Service) Zone() string

Zone returns the fully qualified zone (usually local.) of the service

type ServiceDescription 

type ServiceDescription interface {
	Name() string
	Service() string
	Protocol() string
	Description() string
	Note() string
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.