iprd

Aug 19, 2026

Changes in this version

+ func GetKnownMinerPorts() []int

+ func ParseIPAddress(address string) string

type InterfaceConfig

+ FilterKnownPorts bool

type ListenerConfig

+ FilterKnownPorts bool

Aug 17, 2026

Changes in this version

+ const TCPCommandStatus

+ const TCPCommandSubscribe

type IPRBroadcast

+ func (b *IPRBroadcast) SetStatusProvider(provider StatusProvider)

type ListenerManager

+ func (m *ListenerManager) Status() ManagerStatus

+ type ListenerState string

+ const ListenerStateActive

+ const ListenerStateIdle

+ const ListenerStateReconnecting

+ const ListenerStateStarting

+ const ListenerStateStopped

+ type ListenerStatus struct

+ ActivationFailures uint64

+ CaptureErrors uint64

+ Interface string

+ LastError string

+ LastErrorAt time.Time

+ Reconnects uint64

+ State ListenerState

+ type ManagerState string

+ const ManagerStateDegraded

+ const ManagerStateFailed

+ const ManagerStateHealthy

+ const ManagerStateIdle

+ const ManagerStateStarting

+ const ManagerStateStopped

+ type ManagerStatus struct

+ ActivationFailures uint64

+ CaptureErrors uint64

+ CaptureWriteErrors uint64

+ LastError string

+ LastErrorAt time.Time

+ LastPacketAt time.Time

+ LastReportAt time.Time

+ Listeners []ListenerStatus

+ ListenersActive int

+ ListenersConfigured int

+ Packets PacketCounters

+ Reconnects uint64

+ State ManagerState

+ type PacketCounters struct

+ Duplicates uint64

+ Invalid uint64

+ Processed uint64

+ Reports uint64

+ UnknownFiltered uint64

+ type StatusProvider interface

+ Status func() ManagerStatus

type TCPCommand

+ RequestID string

+ type TCPResponse struct

+ Error string

+ RequestID string

+ Status *ManagerStatus

+ Timestamp int64

+ Type string

Aug 13, 2026

Changes in this version

+ type OfflineHandler func(OfflinePacketResult) error

+ type OfflinePacketResult struct

+ Err error

+ InterfaceName string

+ Number int64

+ Packet gopacket.Packet

+ Report *IPReportPacket

+ Timestamp time.Time

+ type OfflineResult struct

+ Duplicates int

+ Invalid int

+ Processed int

+ Reports int

+ func ProcessCapture(ctx context.Context, reader io.Reader, handler OfflineHandler) (OfflineResult, error)

+ func (r OfflineResult) String() string

type PacketProcessor

+ func (p *PacketProcessor) IsDuplicate(packet *IPReportPacket) bool

+ func (p *PacketProcessor) ToIPRPacket(captured CapturedPacket) (*IPReportPacket, error)

Aug 9, 2026

Changes in this version

+ var ErrDuplicatePacket = errors.New("duplicate packet")

+ var ErrListenerManagerAlreadyStarted = errors.New("listener manager may only be run once")

+ func GetMsgPatternFromHint(hint MinerTypeHint) (*regexp.Regexp, bool)

+ type AuradineIPReport struct

+ Command string

+ Hostname string

+ IPAddress string

+ InternalType string

+ MACAddress string

+ Model string

+ SerialNo string

+ Version string

+ type CaptureWriter struct

+ func NewCaptureWriter(path string, rotate bool, logger Logger) *CaptureWriter

+ func (w *CaptureWriter) Close() error

+ func (w *CaptureWriter) Open() error

+ func (w *CaptureWriter) Path() string

+ func (w *CaptureWriter) Write(packet CapturedPacket) error

+ type CapturedPacket struct

+ CaptureInfo gopacket.CaptureInfo

+ Data []byte

+ Interface IPRInterface

+ LinkType layers.LinkType

+ type FlagInterface map[string]*InterfaceConfig

+ func (f *FlagInterface) Set(value string) error

+ func (f *FlagInterface) String() string

+ func (f FlagInterface) Configs() []InterfaceConfig

+ func (f FlagInterface) Selectors() []string

+ type FlagSlice []string

+ func (f *FlagSlice) Set(value string) error

+ func (f *FlagSlice) String() string

+ type ForwardConfig struct

+ Bind string

+ MDNS bool

+ Port int

+ func DefaultForwardConfig() *ForwardConfig

+ func (cfg *ForwardConfig) Merge(target *ForwardConfig) *ForwardConfig

+ func (cfg *ForwardConfig) Validate() error

+ type GoldshellIPReport struct

+ BoardSNs json.RawMessage

+ CtrlBoardSN string

+ DHCP string

+ DNS json.RawMessage

+ Gateway string

+ IPAddress string

+ LEDStatus bool

+ MACAddress string

+ Model string

+ Netmask string

+ Serial string

+ Time string

+ Version string

type IPRBroadcastMessage

+ func NewIPRBroadcastMessage(report *IPReportPacket) (IPRBroadcastMessage, error)

+ func (m IPRBroadcastMessage) Marshal() ([]byte, error)

type IPRListener

+ func (l *IPRListener) Packets() <-chan CapturedPacket

type IPReportPacket

+ InterfaceName string

+ type InterfaceConfig struct

+ IgnoredDevices []string

+ NetworkExclusions []string

+ NetworkInclusions []string

+ NoRootNetwork bool

+ Selector string

+ func DefaultInterfaceConfig() *InterfaceConfig

+ type ListenerConfig struct

+ Auto bool

+ CaptureFile string

+ Debug bool

+ ForwardKnown bool

+ IgnoredDevices []string

+ Interfaces []InterfaceConfig

+ ListenInterface string

+ ListenInterfaces []string

+ NetworkExclusions []string

+ NetworkInclusions []string

+ NoRootNetwork bool

+ RotateCaptureFiles bool

+ func DefaultListenerConfig() *ListenerConfig

+ func ParseListenerConfig(supplied *ListenerConfig) (*ListenerConfig, error)

+ func (cfg *ListenerConfig) Merge(target *ListenerConfig) *ListenerConfig

+ func (cfg *ListenerConfig) Validate() error

+ type ListenerManager struct

+ func NewListenerManager(cfg *ListenerConfig, logger Logger) (*ListenerManager, error)

+ func (m *ListenerManager) Reports() <-chan *IPReportPacket

+ func (m *ListenerManager) Run(ctx context.Context) error

+ type Logger interface

+ Debug func(msg string)

+ Error func(err error)

+ Info func(msg string)

+ Warn func(msg string)

type MinerTypeHint

+ func GetMinerHintFromPort(port int) (MinerTypeHint, bool)

+ type PacketProcessor struct

+ func NewPacketProcessor(record *Record) *PacketProcessor

+ func (p *PacketProcessor) CaptureToIPRPacket(captured CapturedPacket) (*IPReportPacket, error)

+ func (p *PacketProcessor) ParseIPReportPacket(packet *IPReportPacket) error

+ type SealminerIPReport struct

+ Info sealminerInfo

+ Interfaces []sealminerInterface

+ func (r *SealminerIPReport) UnmarshalJSON(data []byte) error

Jul 21, 2026

Changes in this version

+ const MDNSServiceType

type IPRDConfig

+ MDNS bool

+ RotateCaptureFiles bool

+ type MDNSAdvertiser struct

+ func NewMDNSAdvertiser(bind string, port int, version string) (*MDNSAdvertiser, error)

+ func (a *MDNSAdvertiser) Close() error

Jul 6, 2026

Changes in this version

type IPRDConfig

+ ForwardBind string

type IPRListener

+ func (l *IPRListener) Run(ctx context.Context) error

Jun 20, 2026

Changes in this version

+ func ParseBPFNetwork(net string) string

type IPRDConfig

+ ForwardKnown bool

+ IgnoredDevices []string

+ NetworkInclusions []string

Jun 17, 2026

Changes in this version

type MinerTypeHint

+ const HiveGPU

Jun 9, 2026

Changes in this version

type IPRDConfig

+ NetworkExclusions []string

Jun 5, 2026

Changes in this version

type MinerTypeHint

+ const IPollo

Jun 3, 2026

Changes in this version

type IPRDConfig

+ CaptureFile string

+ NoRootNetwork bool

May 12, 2026

Changes in this version

+ func ParseMACAddress(macAddress string) string

type IPRDConfig

+ NetworkPrefixes []string

+ type IPReportAuradine struct

+ Command string

+ Hostname string

+ IPAddress string

+ InternalType string

+ MACAddress string

+ Model string

+ SerialNo string

+ Version string

May 5, 2026

Changes in this version

+ func WriteIPRDConfigToFile(supplied *IPRDConfig, filePath string) error

+ type IPRDConfig struct

+ Auto bool

+ Debug bool

+ Filter bool

+ ForwardPort int

+ IgnoreAddresses []string

+ ListenInterface string

+ func DefaultIPRDConfig() *IPRDConfig

+ func NewIPRDConfigFromBytes(data []byte) (*IPRDConfig, error)

+ func NewIPRDConfigFromFile(filePath string) (*IPRDConfig, error)

+ func ParseConfig(supplied *IPRDConfig) (*IPRDConfig, error)

+ func (cfg *IPRDConfig) Merge(target *IPRDConfig) *IPRDConfig

+ func (cfg *IPRDConfig) Validate() error

type IPRInterface

+ func GetInterfaceByIndex(index int) (*IPRInterface, error)

+ func GetInterfaces() ([]IPRInterface, error)

+ func (i IPRInterface) String() string

May 1, 2026

Changes in this version

type Record

+ func (r *Record) Cap() int

+ func (r *Record) Clear()

+ func (r *Record) Remove(key string) error

Apr 23, 2026

Changes in this version

+ var MsgPatterns = map[string]*regexp.Regexp

+ var ValidIP = regexp.MustCompile(...)

+ var ValidMAC = regexp.MustCompile(`([0-9A-Fa-f]{2}[:-]){5}([0-9A-Fa-f]{2})`)

+ func ParseIPReportPacket(packet *IPReportPacket) error

+ type IPRBroadcast struct

+ Errs chan error

+ Msgs chan []byte

+ func NewBroadcaster(logger *IPRLogger, port int) (*IPRBroadcast, error)

+ func (b *IPRBroadcast) Listen()

+ type IPRBroadcastMessage struct

+ DstPort int

+ MinerHint MinerTypeHint

+ PacketID string

+ SrcIP string

+ SrcMAC string

+ Timestamp int64

+ type IPRInterface struct

+ Description string

+ Flags net.Flags

+ FriendlyName string

+ HardwareAddr net.HardwareAddr

+ IPv4 net.IP

+ Index int

+ Name string

+ func FindLANInterface() (*IPRInterface, error)

+ func GetInterfaceByName(name string) (*IPRInterface, error)

+ func (i *IPRInterface) IPAddr() string

+ func (i *IPRInterface) IsLAN() bool

+ func (i *IPRInterface) IsUp() bool

+ func (i *IPRInterface) MACAddr() string

+ func (i *IPRInterface) NetworkPrefix() string

+ type IPRListener struct

+ func NewListener(logger *IPRLogger, logDebug bool, filter bool, iface *IPRInterface) *IPRListener

+ func (l *IPRListener) Activate() error

+ func (l *IPRListener) Broadcast() chan []byte

+ func (l *IPRListener) Listen()

+ type IPRLogger struct

+ func NewLogger() *IPRLogger

+ func (l *IPRLogger) Debug(msg string)

+ func (l *IPRLogger) Error(err error)

+ func (l *IPRLogger) Fatal(err error)

+ func (l *IPRLogger) Info(raw string)

+ func (l *IPRLogger) Panic(err error)

+ func (l *IPRLogger) Warn(raw string)

+ type IPReportGoldshell struct

+ BoardSNs json.RawMessage

+ CtrlBoardSN string

+ DHCP string

+ DNS json.RawMessage

+ Gateway string

+ IPAddress string

+ LEDStatus bool

+ MACAddress string

+ Model string

+ Netmask string

+ Serial string

+ Time string

+ Version string

+ type IPReportPacket struct

+ CaptureLength int

+ Datagram []byte

+ DstIP string

+ DstMAC string

+ DstPort int

+ InterfaceIndex int

+ Length int

+ MinerHint MinerTypeHint

+ Payload string

+ SrcIP string

+ SrcMAC string

+ SrcPort int

+ Timestamp time.Time

+ func NewIPReportPacket(packet gopacket.Packet) (*IPReportPacket, error)

+ func (r *IPReportPacket) Marshal() ([]byte, error)

+ func (r IPReportPacket) String() string

+ type IPReportSealminer struct

+ Info SealMinerInfo

+ Interfaces []SealMinerInterface

+ func (i *IPReportSealminer) UnmarshalJSON(data []byte) error

+ type MinerTypeHint string

+ const Antminer

+ const Auradine

+ const Elphapex

+ const Goldshell

+ const Iceriver

+ const Sealminer

+ const UnknownType

+ const Whatsminer

+ type Record struct

+ func NewRecord(cap int) *Record

+ func (r *Record) Add(key string, record RecordEntry)

+ func (r *Record) Contains(key string) bool

+ func (r *Record) Display()

+ func (r *Record) Get(key string) *RecordEntry

+ func (r *Record) Length() int

+ type RecordEntry struct

+ CreatedAt int64

+ MinerHint MinerTypeHint

+ SrcIP string

+ SrcMAC string

+ UpdatedAt int64

+ type SealMinerBoard struct

+ BinNumber int

+ BinVersion int

+ Serial string

+ type SealMinerInfo struct

+ Boards []SealMinerBoard

+ CtrlBoard string

+ CtrlBoardSN string

+ Firmware string

+ InterfaceCount int

+ MACAddress string

+ PowerLimit int

+ RatedPower int

+ Type string

+ Upgrade int

+ type SealMinerInterface struct

+ Active bool

+ AutoReboot bool

+ DHCP bool

+ DNS1 string

+ DNS2 string

+ Gateway string

+ IPAddress string

+ Interface string

+ Netmask string

+ type TCPCommand struct

+ Command string