Documentation
¶
Index ¶
- Constants
- Variables
- func Fqdn(args ...string) string
- type AdvertiseImpl
- func (a *AdvertiseImpl) AddCommonTxtEntries(params BaseAdvertisingParams) []string
- func (a *AdvertiseImpl) AdvertiseCommission(params *CommissionAdvertisingParameters) error
- func (a *AdvertiseImpl) AdvertiseOperational(params *OperationalAdvertisingParameters) error
- func (a *AdvertiseImpl) AdvertiseRecords(typ int) error
- func (a *AdvertiseImpl) FinalizeServiceUpdate() error
- func (a *AdvertiseImpl) FindEmptyOperationalAllocator() *QueryResponderAllocator
- func (a *AdvertiseImpl) FindOperationalAllocator(name string) *QueryResponderAllocator
- func (a *AdvertiseImpl) GetCommissionableInstanceName() (string, error)
- func (a *AdvertiseImpl) GetCommissioningTxtEntries(params *CommissionAdvertisingParameters) []string
- func (a *AdvertiseImpl) GetOperationalTxtEntries(params *OperationalAdvertisingParameters) []string
- func (a *AdvertiseImpl) Init() error
- func (a *AdvertiseImpl) RemoveServices() error
- func (a *AdvertiseImpl) UpdateCommissionableInstanceName() error
- type Advertiser
- type AppDelegate
- type Base
- type BaseAdvertisingParams
- func (b *BaseAdvertisingParams) EnableIpV4(enable bool)
- func (b *BaseAdvertisingParams) GetMac() (string, error)
- func (b *BaseAdvertisingParams) GetPort() uint16
- func (b *BaseAdvertisingParams) GetTcpSupported() (bool, error)
- func (b *BaseAdvertisingParams) GetUUID() string
- func (b BaseAdvertisingParams) Init() BaseAdvertisingParams
- func (b *BaseAdvertisingParams) IsIPv4Enabled() bool
- func (b *BaseAdvertisingParams) LocalMRPConfig() *messageing.ReliableMessageProtocolConfig
- func (b *BaseAdvertisingParams) SetInterfaceId(id net.Interface)
- func (b *BaseAdvertisingParams) SetLocalMRPConfig(config *messageing.ReliableMessageProtocolConfig)
- func (b *BaseAdvertisingParams) SetMaC(mac string)
- func (b *BaseAdvertisingParams) SetPort(port uint16) *BaseAdvertisingParams
- func (b *BaseAdvertisingParams) SetTcpSupported(i int8)
- type CommissionAdvertisingParameters
- func (c *CommissionAdvertisingParameters) GetCommissionAdvertiseMode() uint16
- func (c *CommissionAdvertisingParameters) GetCommissioningMode() int
- func (c *CommissionAdvertisingParameters) GetDeviceName() string
- func (c *CommissionAdvertisingParameters) GetDeviceType() (t uint32, e error)
- func (c *CommissionAdvertisingParameters) GetLongDiscriminator() uint16
- func (c *CommissionAdvertisingParameters) GetPairingHint() uint16
- func (c *CommissionAdvertisingParameters) GetPairingInstruction() string
- func (c *CommissionAdvertisingParameters) GetProductId() (uint16, error)
- func (c *CommissionAdvertisingParameters) GetRotatingDeviceId() string
- func (c *CommissionAdvertisingParameters) GetShortDiscriminator() uint8
- func (c *CommissionAdvertisingParameters) GetVendorId() (uint16, error)
- func (c *CommissionAdvertisingParameters) SetCommissionAdvertiseMode(mode uint16)
- func (c *CommissionAdvertisingParameters) SetCommissioningMode(mode int)
- func (c *CommissionAdvertisingParameters) SetDeviceName(name string) *CommissionAdvertisingParameters
- func (c *CommissionAdvertisingParameters) SetDeviceType(t uint32) *CommissionAdvertisingParameters
- func (c *CommissionAdvertisingParameters) SetLocalMRPConfig(config *messageing.ReliableMessageProtocolConfig) *CommissionAdvertisingParameters
- func (c *CommissionAdvertisingParameters) SetLongDiscriminator(discriminator uint16) *CommissionAdvertisingParameters
- func (c *CommissionAdvertisingParameters) SetMRPConfig(config *messageing.ReliableMessageProtocolConfig)
- func (c *CommissionAdvertisingParameters) SetPairingHint(value uint16) *CommissionAdvertisingParameters
- func (c *CommissionAdvertisingParameters) SetPairingInstruction(ist string)
- func (c *CommissionAdvertisingParameters) SetProductId(id uint16) *CommissionAdvertisingParameters
- func (c *CommissionAdvertisingParameters) SetShortDiscriminator(discriminator uint8) *CommissionAdvertisingParameters
- func (c *CommissionAdvertisingParameters) SetVendorId(id uint16)
- type CommissioningModeProvider
- type CommissioningResolveDelegate
- type CommissioningWindowManager
- type CommissioningWindowManagerImpl
- func (m *CommissioningWindowManagerImpl) Cleanup()
- func (m *CommissioningWindowManagerImpl) GetCommissioningMode() int
- func (m *CommissioningWindowManagerImpl) Init(s ServerDelegate) error
- func (m *CommissioningWindowManagerImpl) OpenBasicCommissioningWindow() error
- func (m *CommissioningWindowManagerImpl) OpenCommissioningWindow() error
- func (m *CommissioningWindowManagerImpl) SetAppDelegate(delegate AppDelegate)
- type DiscoveryFilter
- type DnsResponseWriter
- type Dnssd
- func (d *Dnssd) Advertise(commissionableNode bool, mode int) error
- func (d *Dnssd) AdvertiseCommissionableNode(mode int) error
- func (d *Dnssd) AdvertiseCommissioner() error
- func (d *Dnssd) AdvertiseOperational() error
- func (d *Dnssd) SetCommissioningModeProvider(provider CommissioningModeProvider)
- func (d *Dnssd) SetFabricTable(fabrics *credentials.FabricTable)
- func (d *Dnssd) SetInterfaceId(n net.Interface)
- func (d *Dnssd) SetSecuredPort(port uint16)
- func (d *Dnssd) SetUnsecuredPort(port uint16)
- func (d *Dnssd) StartServer()
- type Mac
- type MdnsHandler
- type MdnsServer
- type MdnsServerImpl
- func (mdns *MdnsServerImpl) BroadcastSend(message dns.Msg, port uint16, id net.Interface, srcAddr netip.Addr) error
- func (mdns *MdnsServerImpl) GetCommissionableInstanceName() (string, error)
- func (mdns *MdnsServerImpl) Init() error
- func (mdns *MdnsServerImpl) RemoveServices() error
- func (mdns *MdnsServerImpl) SendTo(message *dns.Msg, addr netip.AddrPort, id net.Interface) error
- func (mdns *MdnsServerImpl) ServeDNS(w dns.ResponseWriter, r *dns.Msg)
- func (mdns *MdnsServerImpl) SetHandler(h MdnsHandler)
- func (mdns *MdnsServerImpl) Shutdown()
- func (mdns *MdnsServerImpl) StartServer(port uint16) error
- type MinMdnsResolver
- func (m MinMdnsResolver) DiscoverCommissionableNodes(filter DiscoveryFilter)
- func (m MinMdnsResolver) DiscoverCommissioners(filter DiscoveryFilter)
- func (m MinMdnsResolver) Init() error
- func (m MinMdnsResolver) ResolveNodeId(peerId PeerId, isIpV6 bool)
- func (m MinMdnsResolver) SetCommissioningDelegate(delegate CommissioningResolveDelegate)
- func (m MinMdnsResolver) SetOperationalDelegate(delegate OperationalResolveDelegate)
- func (m MinMdnsResolver) Shutdown()
- type OperationalAdvertisingParameters
- func (o *OperationalAdvertisingParameters) GetCompressedFabricId() lib.CompressedFabricId
- func (o *OperationalAdvertisingParameters) GetPeerId() *PeerId
- func (o *OperationalAdvertisingParameters) Init()
- func (o *OperationalAdvertisingParameters) SetPeerId(peerId PeerId) *OperationalAdvertisingParameters
- type OperationalQueryAllocator
- type OperationalResolveDelegate
- type PeerId
- type QueryData
- func (q *QueryData) GetClass() uint16
- func (q QueryData) GetDestAddr() netip.AddrPort
- func (q *QueryData) GetMessageId() uint16
- func (q *QueryData) GetName() string
- func (q QueryData) GetSrcAddr() netip.AddrPort
- func (q *QueryData) GetType() uint16
- func (q *QueryData) IsInternalBroadcast() bool
- func (q *QueryData) RequestedUnicastAnswer() bool
- func (d QueryData) SendUnicast() bool
- func (q *QueryData) SetDestAddr(addr netip.AddrPort) *QueryData
- func (q *QueryData) SetIsInternalBroadcast(isInternalBroadcast bool)
- func (q *QueryData) SetMessageId(id uint16)
- func (q *QueryData) SetSrcAddr(addr netip.AddrPort) *QueryData
- type QueryReplyFilter
- type QueryResponder
- type QueryResponderAllocator
- type QueryResponderInfo
- type QueryResponderRecordFilter
- func (f *QueryResponderRecordFilter) Accept(record *QueryResponderInfo) bool
- func (f *QueryResponderRecordFilter) SetIncludeAdditionalRepliesOnly(b bool) *QueryResponderRecordFilter
- func (f *QueryResponderRecordFilter) SetIncludeOnlyMulticastBeforeMS(t time.Time)
- func (f *QueryResponderRecordFilter) SetReplyFilter(filter responder.ReplyFilter) *QueryResponderRecordFilter
- type QueryResponderSettings
- type Resolver
- type ResponseSender
- func (rs *ResponseSender) AddQueryResponder(queryResponder *QueryResponder)
- func (rs *ResponseSender) Int() *ResponseSender
- func (rs *ResponseSender) OnQuery(query *QueryData) (*dns.Msg, error)
- func (rs *ResponseSender) Respond(query *QueryData, interfaceId net.Interface) error
- func (rs *ResponseSender) ServeMdns(writer ResponseWriter, data *QueryData) error
- func (rs *ResponseSender) SetServer(server MdnsServer)
- type ResponseSendingState
- func (s *ResponseSendingState) GetError() error
- func (s *ResponseSendingState) GetMessageId() uint16
- func (s *ResponseSendingState) GetQuery() *QueryData
- func (s *ResponseSendingState) GetResourceType() int
- func (s *ResponseSendingState) GetSourceAddress() netip.Addr
- func (s *ResponseSendingState) IncludeQuery() bool
- func (s *ResponseSendingState) Reset(messageId uint16, query *QueryData, src, dest netip.AddrPort, ...)
- func (s *ResponseSendingState) SendUnicast() bool
- func (s *ResponseSendingState) SetError(err error)
- func (s *ResponseSendingState) SetResourceType(additional int)
- func (s *ResponseSendingState) SetSourceAddrPort(addr string, port uint16)
- type ResponseWriter
- type Server
- type ServerDelegate
- type Uint
Constants ¶
View Source
const ( KSubtypeServiceNamePart = "_sub" KCommissionableServiceName = "_matterc" KCommissionerServiceName = "_matterd" KOperationalServiceName = "_matter" KCommissionProtocol = "_udp" KLocalDomain = "local" KOperationalProtocol = "_tcp" )
View Source
const ( CommissioningModeDisabled = iota // Commissioning Mode is disabled, CM=0 in DNS-SD key/value pairs CommissioningModeEnableBasic // Basic Commissioning Mode, CM=1 in DNS-SD key/value pairs CommissioningModeEnabledEnhanced // Enhanced Commissioning Mode, CM=2 in DNS-SD key/value pairs AdvertiseModeCommissionableNode = 0 AdvertiseModeCommissioner = 1 AdvertiseTypeRemovingAll = 0 AdvertiseTypeStarted = 1 )
The mode of a Node in which it allows Commissioning.
View Source
const ( Subtype_None filterType = iota Subtype_ShortDiscriminator Subtype_LongDiscriminator Subtype_VendorId Subtype_DeviceType Subtype_CommissioningMode Subtype_InstanceName Subtype_Commissioner Subtype_CompressedFabricId )
View Source
const ( ResourceType_Answer = iota ResourceType_Authority ResourceType_Additional )
View Source
const MaxCommissionRecords = 20 // 11
View Source
const MdnsPort uint16 = 5353
Variables ¶
View Source
var IPv4LinkLocalMulticast = netip.AddrFrom4([4]byte{224, 0, 0, 251})
View Source
var IPv6LinkLocalMulticast = netip.AddrFrom16([16]byte{0xFF, 0x02, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0xFB})
Functions ¶
Types ¶
type AdvertiseImpl ¶
type AdvertiseImpl struct {
// contains filtered or unexported fields
}
func NewAdvertise ¶
func NewAdvertise() *AdvertiseImpl
func (*AdvertiseImpl) AddCommonTxtEntries ¶
func (a *AdvertiseImpl) AddCommonTxtEntries(params BaseAdvertisingParams) []string
func (*AdvertiseImpl) AdvertiseCommission ¶
func (a *AdvertiseImpl) AdvertiseCommission(params *CommissionAdvertisingParameters) error
func (*AdvertiseImpl) AdvertiseOperational ¶
func (a *AdvertiseImpl) AdvertiseOperational(params *OperationalAdvertisingParameters) error
func (*AdvertiseImpl) AdvertiseRecords ¶
func (a *AdvertiseImpl) AdvertiseRecords(typ int) error
func (*AdvertiseImpl) FinalizeServiceUpdate ¶
func (a *AdvertiseImpl) FinalizeServiceUpdate() error
func (*AdvertiseImpl) FindEmptyOperationalAllocator ¶
func (a *AdvertiseImpl) FindEmptyOperationalAllocator() *QueryResponderAllocator
func (*AdvertiseImpl) FindOperationalAllocator ¶
func (a *AdvertiseImpl) FindOperationalAllocator(name string) *QueryResponderAllocator
func (*AdvertiseImpl) GetCommissionableInstanceName ¶
func (a *AdvertiseImpl) GetCommissionableInstanceName() (string, error)
func (*AdvertiseImpl) GetCommissioningTxtEntries ¶
func (a *AdvertiseImpl) GetCommissioningTxtEntries(params *CommissionAdvertisingParameters) []string
func (*AdvertiseImpl) GetOperationalTxtEntries ¶
func (a *AdvertiseImpl) GetOperationalTxtEntries(params *OperationalAdvertisingParameters) []string
func (*AdvertiseImpl) Init ¶
func (a *AdvertiseImpl) Init() error
func (*AdvertiseImpl) RemoveServices ¶
func (a *AdvertiseImpl) RemoveServices() error
func (*AdvertiseImpl) UpdateCommissionableInstanceName ¶
func (a *AdvertiseImpl) UpdateCommissionableInstanceName() error
type Advertiser ¶
type Advertiser interface { Init() error RemoveServices() error GetCommissionableInstanceName() (string, error) UpdateCommissionableInstanceName() error AdvertiseOperational(params *OperationalAdvertisingParameters) error AdvertiseCommission(params *CommissionAdvertisingParameters) error FinalizeServiceUpdate() error }
type AppDelegate ¶
type AppDelegate interface { OnCommissioningSessionStarted() OnCommissioningSessionStopped() OnCommissioningWindowOpened() OnCommissioningWindowClosed() }
type Base ¶
type Base interface { SetFabricTable(fabrics *credentials.FabricTable) SetCommissioningModeProvider(provider CommissioningModeProvider) SetSecuredPort(port uint16) SetUnsecuredPort(port uint16) SetInterfaceId(net.Interface) StartServer() }
type BaseAdvertisingParams ¶
type BaseAdvertisingParams struct {
// contains filtered or unexported fields
}
func NewBaseAdvertisingParams ¶
func NewBaseAdvertisingParams() BaseAdvertisingParams
func (*BaseAdvertisingParams) EnableIpV4 ¶
func (b *BaseAdvertisingParams) EnableIpV4(enable bool)
func (*BaseAdvertisingParams) GetMac ¶
func (b *BaseAdvertisingParams) GetMac() (string, error)
func (*BaseAdvertisingParams) GetPort ¶
func (b *BaseAdvertisingParams) GetPort() uint16
func (*BaseAdvertisingParams) GetTcpSupported ¶
func (b *BaseAdvertisingParams) GetTcpSupported() (bool, error)
func (*BaseAdvertisingParams) GetUUID ¶
func (b *BaseAdvertisingParams) GetUUID() string
func (BaseAdvertisingParams) Init ¶
func (b BaseAdvertisingParams) Init() BaseAdvertisingParams
func (*BaseAdvertisingParams) IsIPv4Enabled ¶
func (b *BaseAdvertisingParams) IsIPv4Enabled() bool
func (*BaseAdvertisingParams) LocalMRPConfig ¶
func (b *BaseAdvertisingParams) LocalMRPConfig() *messageing.ReliableMessageProtocolConfig
func (*BaseAdvertisingParams) SetInterfaceId ¶
func (b *BaseAdvertisingParams) SetInterfaceId(id net.Interface)
func (*BaseAdvertisingParams) SetLocalMRPConfig ¶
func (b *BaseAdvertisingParams) SetLocalMRPConfig(config *messageing.ReliableMessageProtocolConfig)
func (*BaseAdvertisingParams) SetMaC ¶
func (b *BaseAdvertisingParams) SetMaC(mac string)
func (*BaseAdvertisingParams) SetPort ¶
func (b *BaseAdvertisingParams) SetPort(port uint16) *BaseAdvertisingParams
func (*BaseAdvertisingParams) SetTcpSupported ¶
func (b *BaseAdvertisingParams) SetTcpSupported(i int8)
type CommissionAdvertisingParameters ¶
type CommissionAdvertisingParameters struct { BaseAdvertisingParams // contains filtered or unexported fields }
func NewCommissionAdvertisingParameters ¶
func NewCommissionAdvertisingParameters() *CommissionAdvertisingParameters
func (*CommissionAdvertisingParameters) GetCommissionAdvertiseMode ¶
func (c *CommissionAdvertisingParameters) GetCommissionAdvertiseMode() uint16
func (*CommissionAdvertisingParameters) GetCommissioningMode ¶
func (c *CommissionAdvertisingParameters) GetCommissioningMode() int
func (*CommissionAdvertisingParameters) GetDeviceName ¶
func (c *CommissionAdvertisingParameters) GetDeviceName() string
func (*CommissionAdvertisingParameters) GetDeviceType ¶
func (c *CommissionAdvertisingParameters) GetDeviceType() (t uint32, e error)
func (*CommissionAdvertisingParameters) GetLongDiscriminator ¶
func (c *CommissionAdvertisingParameters) GetLongDiscriminator() uint16
func (*CommissionAdvertisingParameters) GetPairingHint ¶
func (c *CommissionAdvertisingParameters) GetPairingHint() uint16
func (*CommissionAdvertisingParameters) GetPairingInstruction ¶
func (c *CommissionAdvertisingParameters) GetPairingInstruction() string
func (*CommissionAdvertisingParameters) GetProductId ¶
func (c *CommissionAdvertisingParameters) GetProductId() (uint16, error)
func (*CommissionAdvertisingParameters) GetRotatingDeviceId ¶
func (c *CommissionAdvertisingParameters) GetRotatingDeviceId() string
func (*CommissionAdvertisingParameters) GetShortDiscriminator ¶
func (c *CommissionAdvertisingParameters) GetShortDiscriminator() uint8
func (*CommissionAdvertisingParameters) GetVendorId ¶
func (c *CommissionAdvertisingParameters) GetVendorId() (uint16, error)
func (*CommissionAdvertisingParameters) SetCommissionAdvertiseMode ¶
func (c *CommissionAdvertisingParameters) SetCommissionAdvertiseMode(mode uint16)
func (*CommissionAdvertisingParameters) SetCommissioningMode ¶
func (c *CommissionAdvertisingParameters) SetCommissioningMode(mode int)
func (*CommissionAdvertisingParameters) SetDeviceName ¶
func (c *CommissionAdvertisingParameters) SetDeviceName(name string) *CommissionAdvertisingParameters
func (*CommissionAdvertisingParameters) SetDeviceType ¶
func (c *CommissionAdvertisingParameters) SetDeviceType(t uint32) *CommissionAdvertisingParameters
func (*CommissionAdvertisingParameters) SetLocalMRPConfig ¶
func (c *CommissionAdvertisingParameters) SetLocalMRPConfig(config *messageing.ReliableMessageProtocolConfig) *CommissionAdvertisingParameters
func (*CommissionAdvertisingParameters) SetLongDiscriminator ¶
func (c *CommissionAdvertisingParameters) SetLongDiscriminator(discriminator uint16) *CommissionAdvertisingParameters
func (*CommissionAdvertisingParameters) SetMRPConfig ¶
func (c *CommissionAdvertisingParameters) SetMRPConfig(config *messageing.ReliableMessageProtocolConfig)
func (*CommissionAdvertisingParameters) SetPairingHint ¶
func (c *CommissionAdvertisingParameters) SetPairingHint(value uint16) *CommissionAdvertisingParameters
func (*CommissionAdvertisingParameters) SetPairingInstruction ¶
func (c *CommissionAdvertisingParameters) SetPairingInstruction(ist string)
func (*CommissionAdvertisingParameters) SetProductId ¶
func (c *CommissionAdvertisingParameters) SetProductId(id uint16) *CommissionAdvertisingParameters
func (*CommissionAdvertisingParameters) SetShortDiscriminator ¶
func (c *CommissionAdvertisingParameters) SetShortDiscriminator(discriminator uint8) *CommissionAdvertisingParameters
func (*CommissionAdvertisingParameters) SetVendorId ¶
func (c *CommissionAdvertisingParameters) SetVendorId(id uint16)
type CommissioningModeProvider ¶
type CommissioningModeProvider interface {
GetCommissioningMode() int
}
type CommissioningResolveDelegate ¶
type CommissioningResolveDelegate interface { }
type CommissioningWindowManager ¶
type CommissioningWindowManager interface { Init(s ServerDelegate) error SetAppDelegate(delegate AppDelegate) OpenBasicCommissioningWindow() error GetCommissioningMode() int }
type CommissioningWindowManagerImpl ¶
type CommissioningWindowManagerImpl struct {
// contains filtered or unexported fields
}
func NewCommissioningWindowManagerImpl ¶
func NewCommissioningWindowManagerImpl() *CommissioningWindowManagerImpl
func (*CommissioningWindowManagerImpl) Cleanup ¶
func (m *CommissioningWindowManagerImpl) Cleanup()
func (*CommissioningWindowManagerImpl) GetCommissioningMode ¶
func (m *CommissioningWindowManagerImpl) GetCommissioningMode() int
func (*CommissioningWindowManagerImpl) Init ¶
func (m *CommissioningWindowManagerImpl) Init(s ServerDelegate) error
func (*CommissioningWindowManagerImpl) OpenBasicCommissioningWindow ¶
func (m *CommissioningWindowManagerImpl) OpenBasicCommissioningWindow() error
func (*CommissioningWindowManagerImpl) OpenCommissioningWindow ¶
func (m *CommissioningWindowManagerImpl) OpenCommissioningWindow() error
func (*CommissioningWindowManagerImpl) SetAppDelegate ¶
func (m *CommissioningWindowManagerImpl) SetAppDelegate(delegate AppDelegate)
type DiscoveryFilter ¶
type DiscoveryFilter interface { }
type DnsResponseWriter ¶
type DnsResponseWriter struct {
// contains filtered or unexported fields
}
func (*DnsResponseWriter) NewDnsResponseWriter ¶
func (d *DnsResponseWriter) NewDnsResponseWriter(addr, net string) *DnsResponseWriter
type Dnssd ¶
type Dnssd struct {
// contains filtered or unexported fields
}
func (*Dnssd) AdvertiseCommissionableNode ¶
func (*Dnssd) AdvertiseCommissioner ¶
func (*Dnssd) AdvertiseOperational ¶
func (*Dnssd) SetCommissioningModeProvider ¶
func (d *Dnssd) SetCommissioningModeProvider(provider CommissioningModeProvider)
func (*Dnssd) SetFabricTable ¶
func (d *Dnssd) SetFabricTable(fabrics *credentials.FabricTable)
func (*Dnssd) SetInterfaceId ¶
func (*Dnssd) SetSecuredPort ¶
func (*Dnssd) SetUnsecuredPort ¶
func (*Dnssd) StartServer ¶
func (d *Dnssd) StartServer()
type MdnsHandler ¶
type MdnsHandler interface {
ServeMdns(ResponseWriter, *QueryData) error
}
type MdnsServer ¶
type MdnsServer interface { StartServer(port uint16) error SetHandler(h MdnsHandler) Shutdown() SendTo(message *dns.Msg, port netip.AddrPort, id net.Interface) error BroadcastSend(message dns.Msg, port uint16, id net.Interface, addr netip.Addr) error Init() error GetCommissionableInstanceName() (string, error) RemoveServices() error }
type MdnsServerImpl ¶
type MdnsServerImpl struct {
// contains filtered or unexported fields
}
func GetMdnsInstance ¶
func GetMdnsInstance() *MdnsServerImpl
func NewMdnsServerImpl ¶
func NewMdnsServerImpl() *MdnsServerImpl
func (*MdnsServerImpl) BroadcastSend ¶
func (*MdnsServerImpl) GetCommissionableInstanceName ¶
func (mdns *MdnsServerImpl) GetCommissionableInstanceName() (string, error)
func (*MdnsServerImpl) Init ¶
func (mdns *MdnsServerImpl) Init() error
func (*MdnsServerImpl) RemoveServices ¶
func (mdns *MdnsServerImpl) RemoveServices() error
func (*MdnsServerImpl) ServeDNS ¶
func (mdns *MdnsServerImpl) ServeDNS(w dns.ResponseWriter, r *dns.Msg)
func (*MdnsServerImpl) SetHandler ¶
func (mdns *MdnsServerImpl) SetHandler(h MdnsHandler)
func (*MdnsServerImpl) Shutdown ¶
func (mdns *MdnsServerImpl) Shutdown()
func (*MdnsServerImpl) StartServer ¶
func (mdns *MdnsServerImpl) StartServer(port uint16) error
type MinMdnsResolver ¶
type MinMdnsResolver struct {
// contains filtered or unexported fields
}
func (MinMdnsResolver) DiscoverCommissionableNodes ¶
func (m MinMdnsResolver) DiscoverCommissionableNodes(filter DiscoveryFilter)
func (MinMdnsResolver) DiscoverCommissioners ¶
func (m MinMdnsResolver) DiscoverCommissioners(filter DiscoveryFilter)
func (MinMdnsResolver) Init ¶
func (m MinMdnsResolver) Init() error
func (MinMdnsResolver) ResolveNodeId ¶
func (m MinMdnsResolver) ResolveNodeId(peerId PeerId, isIpV6 bool)
func (MinMdnsResolver) SetCommissioningDelegate ¶
func (m MinMdnsResolver) SetCommissioningDelegate(delegate CommissioningResolveDelegate)
func (MinMdnsResolver) SetOperationalDelegate ¶
func (m MinMdnsResolver) SetOperationalDelegate(delegate OperationalResolveDelegate)
func (MinMdnsResolver) Shutdown ¶
func (m MinMdnsResolver) Shutdown()
type OperationalAdvertisingParameters ¶
type OperationalAdvertisingParameters struct { BaseAdvertisingParams // contains filtered or unexported fields }
func NewOperationalAdvertisingParameters ¶
func NewOperationalAdvertisingParameters() *OperationalAdvertisingParameters
func (*OperationalAdvertisingParameters) GetCompressedFabricId ¶
func (o *OperationalAdvertisingParameters) GetCompressedFabricId() lib.CompressedFabricId
func (*OperationalAdvertisingParameters) GetPeerId ¶
func (o *OperationalAdvertisingParameters) GetPeerId() *PeerId
func (*OperationalAdvertisingParameters) Init ¶
func (o *OperationalAdvertisingParameters) Init()
func (*OperationalAdvertisingParameters) SetPeerId ¶
func (o *OperationalAdvertisingParameters) SetPeerId(peerId PeerId) *OperationalAdvertisingParameters
type OperationalQueryAllocator ¶
type OperationalQueryAllocator struct {
// contains filtered or unexported fields
}
func (*OperationalQueryAllocator) GetAllocator ¶
func (a *OperationalQueryAllocator) GetAllocator() QueryResponderAllocator
type OperationalResolveDelegate ¶
type OperationalResolveDelegate interface { }
type PeerId ¶
type PeerId struct {
// contains filtered or unexported fields
}
func NewPeerId ¶
func NewPeerId(mNodeId lib.NodeId, mCompressedFabricId lib.CompressedFabricId) *PeerId
func (*PeerId) GetCompressedFabricId ¶
func (p *PeerId) GetCompressedFabricId() lib.CompressedFabricId
type QueryData ¶
func NewQueryData ¶
func (QueryData) GetDestAddr ¶
func (*QueryData) GetMessageId ¶
func (QueryData) GetSrcAddr ¶
func (*QueryData) IsInternalBroadcast ¶
func (*QueryData) RequestedUnicastAnswer ¶
func (QueryData) SendUnicast ¶
func (*QueryData) SetIsInternalBroadcast ¶
func (*QueryData) SetMessageId ¶
type QueryReplyFilter ¶
type QueryReplyFilter struct { responder.ReplyFilter // contains filtered or unexported fields }
func NewQueryReplyFilter ¶
func NewQueryReplyFilter(q *QueryData) *QueryReplyFilter
func (*QueryReplyFilter) Accept ¶
func (f *QueryReplyFilter) Accept(qType, qClass uint16, fName string) bool
func (*QueryReplyFilter) SetIgnoreNameMatch ¶
func (f *QueryReplyFilter) SetIgnoreNameMatch(b bool) *QueryReplyFilter
func (*QueryReplyFilter) SetSendingAdditionalItems ¶
func (f *QueryReplyFilter) SetSendingAdditionalItems(b bool) *QueryReplyFilter
type QueryResponder ¶
type QueryResponder struct {
ResponderInfos []*QueryResponderInfo // TODO
}
func NewQueryResponder ¶
func NewQueryResponder() *QueryResponder
func (*QueryResponder) AddResponder ¶
func (r *QueryResponder) AddResponder(res responder.RecordResponder) *QueryResponderSettings
func (*QueryResponder) ClearBroadcastThrottle ¶
func (r *QueryResponder) ClearBroadcastThrottle()
func (*QueryResponder) ResetAdditionals ¶
func (r *QueryResponder) ResetAdditionals()
type QueryResponderAllocator ¶
type QueryResponderAllocator struct {
// contains filtered or unexported fields
}
func NewQueryResponderAllocator ¶
func NewQueryResponderAllocator() *QueryResponderAllocator
func (*QueryResponderAllocator) AddResponder ¶
func (a *QueryResponderAllocator) AddResponder(recordResponder responder.RecordResponder) *QueryResponderSettings
func (*QueryResponderAllocator) GetQueryResponder ¶
func (a *QueryResponderAllocator) GetQueryResponder() *QueryResponder
func (*QueryResponderAllocator) GetResponder ¶
func (a *QueryResponderAllocator) GetResponder(typ uint16, name string) responder.RecordResponder
type QueryResponderInfo ¶
type QueryResponderInfo struct { Responder responder.RecordResponder // contains filtered or unexported fields }
func NewQueryResponderInfo ¶
func NewQueryResponderInfo(r responder.RecordResponder) *QueryResponderInfo
type QueryResponderRecordFilter ¶
type QueryResponderRecordFilter struct {
// contains filtered or unexported fields
}
func NewQueryResponderRecordFilter ¶
func NewQueryResponderRecordFilter() *QueryResponderRecordFilter
func (*QueryResponderRecordFilter) Accept ¶
func (f *QueryResponderRecordFilter) Accept(record *QueryResponderInfo) bool
func (*QueryResponderRecordFilter) SetIncludeAdditionalRepliesOnly ¶
func (f *QueryResponderRecordFilter) SetIncludeAdditionalRepliesOnly(b bool) *QueryResponderRecordFilter
func (*QueryResponderRecordFilter) SetIncludeOnlyMulticastBeforeMS ¶
func (f *QueryResponderRecordFilter) SetIncludeOnlyMulticastBeforeMS(t time.Time)
func (*QueryResponderRecordFilter) SetReplyFilter ¶
func (f *QueryResponderRecordFilter) SetReplyFilter(filter responder.ReplyFilter) *QueryResponderRecordFilter
type QueryResponderSettings ¶
type QueryResponderSettings struct {
// contains filtered or unexported fields
}
func NewQueryResponderSettings ¶
func NewQueryResponderSettings(info *QueryResponderInfo) *QueryResponderSettings
func (*QueryResponderSettings) IsValid ¶
func (s *QueryResponderSettings) IsValid() bool
func (*QueryResponderSettings) SetReportAdditional ¶
func (s *QueryResponderSettings) SetReportAdditional(qName string) *QueryResponderSettings
func (*QueryResponderSettings) SetReportInServiceListing ¶
func (s *QueryResponderSettings) SetReportInServiceListing(reportService bool) *QueryResponderSettings
type Resolver ¶
type Resolver interface { Init() error Shutdown() ResolveNodeId(peerId PeerId, isIpV6 bool) SetOperationalDelegate(delegate OperationalResolveDelegate) SetCommissioningDelegate(delegate CommissioningResolveDelegate) DiscoverCommissionableNodes(filter DiscoveryFilter) DiscoverCommissioners(filter DiscoveryFilter) }
type ResponseSender ¶
type ResponseSender struct {
// contains filtered or unexported fields
}
ResponseSender 实现 ResponderDelegate接口
func NewResponseSender ¶
func NewResponseSender() *ResponseSender
func (*ResponseSender) AddQueryResponder ¶
func (rs *ResponseSender) AddQueryResponder(queryResponder *QueryResponder)
func (*ResponseSender) Int ¶
func (rs *ResponseSender) Int() *ResponseSender
func (*ResponseSender) OnQuery ¶
func (rs *ResponseSender) OnQuery(query *QueryData) (*dns.Msg, error)
func (*ResponseSender) Respond ¶
func (rs *ResponseSender) Respond(query *QueryData, interfaceId net.Interface) error
func (*ResponseSender) ServeMdns ¶
func (rs *ResponseSender) ServeMdns(writer ResponseWriter, data *QueryData) error
func (*ResponseSender) SetServer ¶
func (rs *ResponseSender) SetServer(server MdnsServer)
type ResponseSendingState ¶
type ResponseSendingState struct {
// contains filtered or unexported fields
}
func (*ResponseSendingState) GetError ¶
func (s *ResponseSendingState) GetError() error
func (*ResponseSendingState) GetMessageId ¶
func (s *ResponseSendingState) GetMessageId() uint16
func (*ResponseSendingState) GetQuery ¶
func (s *ResponseSendingState) GetQuery() *QueryData
func (*ResponseSendingState) GetResourceType ¶
func (s *ResponseSendingState) GetResourceType() int
func (*ResponseSendingState) GetSourceAddress ¶
func (s *ResponseSendingState) GetSourceAddress() netip.Addr
func (*ResponseSendingState) IncludeQuery ¶
func (s *ResponseSendingState) IncludeQuery() bool
func (*ResponseSendingState) SendUnicast ¶
func (s *ResponseSendingState) SendUnicast() bool
func (*ResponseSendingState) SetError ¶
func (s *ResponseSendingState) SetError(err error)
func (*ResponseSendingState) SetResourceType ¶
func (s *ResponseSendingState) SetResourceType(additional int)
func (*ResponseSendingState) SetSourceAddrPort ¶
func (s *ResponseSendingState) SetSourceAddrPort(addr string, port uint16)
type ResponseWriter ¶
type ServerDelegate ¶
type ServerDelegate interface { }
Source Files
¶
- advertise.go
- commission_params.go
- commissioning_window.go
- dns.go
- dnssd.go
- dnssd_util.go
- operational_params.go
- operational_query_allocator.go
- params.go
- peer_id.go
- query_data.go
- query_reply_filter.go
- query_responder.go
- query_responder_allocator.go
- query_responder_filter.go
- query_responder_info.go
- query_responder_setting.go
- resolver.go
- response_sender.go
- sending_state.go
Click to show internal directories.
Click to hide internal directories.