daemon

package

Go to main page

Versions in this module

v1

v1.7.2

Apr 10, 2026

v1.7.1

Apr 9, 2026

v1.7.0

Apr 9, 2026

Changes in this version

+ const DefaultNetworkSyncInterval

+ func ValidateWebhookURL(rawURL string) error

type Config

+ TrustAutoApprove bool

+ Version string

type DaemonInfo

+ Version string

v1.6.2

Apr 9, 2026

Changes in this version

type DaemonInfo

+ Networks []NetworkMembership

+ type NetworkMembership struct

+ Address string

+ NetworkID uint16

v1.6.1

Apr 9, 2026

v1.6.0

Apr 9, 2026

Changes in this version

+ const CmdManaged

+ const CmdManagedOK

+ const ResolveCacheTTL

+ const SubManagedCycle

+ const SubManagedMemberTags

+ const SubManagedPolicy

+ const SubManagedRankings

+ const SubManagedScore

+ const SubManagedStatus

type Config

+ WebhookHTTPTimeout time.Duration

+ WebhookRetryBackoff time.Duration

type Daemon

+ func (d *Daemon) GetManagedEngine(netID uint16) *ManagedEngine

+ func (d *Daemon) GetMemberTags(netID uint16) []string

+ func (d *Daemon) GetPolicyRunner(netID uint16) *PolicyRunner

+ func (d *Daemon) SetMemberTags(netID uint16, tags []string)

+ func (d *Daemon) StartManagedEngine(netID uint16, rules *registry.NetworkRules)

+ func (d *Daemon) StartPolicyRunner(netID uint16, policyJSON json.RawMessage) error

+ func (d *Daemon) StopManagedEngine(netID uint16)

+ func (d *Daemon) StopPolicyRunner(netID uint16)

+ type ManagedEngine struct

+ func NewManagedEngine(netID uint16, rules *registry.NetworkRules, d *Daemon) *ManagedEngine

+ func (me *ManagedEngine) Bootstrap() error

+ func (me *ManagedEngine) ForceCycle() map[string]interface{}

+ func (me *ManagedEngine) Rankings() []map[string]interface{}

+ func (me *ManagedEngine) Score(nodeID uint32, delta int, topic string) error

+ func (me *ManagedEngine) Start()

+ func (me *ManagedEngine) Status() map[string]interface{}

+ func (me *ManagedEngine) Stop()

+ type PolicyRunner struct

+ func NewPolicyRunner(netID uint16, cp *policy.CompiledPolicy, d *Daemon) *PolicyRunner

+ func (pr *PolicyRunner) EvaluateActions(eventType policy.EventType, ctx map[string]interface{})

+ func (pr *PolicyRunner) EvaluateGate(eventType policy.EventType, ctx map[string]interface{}) bool

+ func (pr *PolicyRunner) ForceCycle() map[string]interface{}

+ func (pr *PolicyRunner) Policy() *policy.CompiledPolicy

+ func (pr *PolicyRunner) Rankings() []map[string]interface{}

+ func (pr *PolicyRunner) Score(nodeID uint32, delta int, topic string) error

+ func (pr *PolicyRunner) Start()

+ func (pr *PolicyRunner) Status() map[string]interface{}

+ func (pr *PolicyRunner) Stop()

+ type WebhookOption func(*WebhookClient)

+ func WithHTTPTimeout(d time.Duration) WebhookOption

+ func WithRetryBackoff(d time.Duration) WebhookOption

v1.5.1

Apr 6, 2026

Changes in this version

+ const CmdHealth

+ const CmdHealthOK

+ const CmdNetwork

+ const CmdNetworkOK

+ const EndpointCacheTTL

+ const SubNetworkInvite

+ const SubNetworkJoin

+ const SubNetworkLeave

+ const SubNetworkList

+ const SubNetworkMembers

+ const SubNetworkPollInvites

+ const SubNetworkRespondInvite

type Config

+ AdminToken string

+ Networks []uint16

type Daemon

+ func (d *Daemon) CachedEndpoint(nodeID uint32) (string, bool)

type DaemonInfo

+ EncryptFail uint64

+ EncryptOK uint64

+ HandshakePendingCount int

type HandshakeManager

+ func (hm *HandshakeManager) PendingCount() int

type TunnelManager

+ EncryptFail uint64

+ EncryptOK uint64

type WebhookClient

+ func (wc *WebhookClient) Dropped() uint64

type WebhookEvent

+ EventID uint64

v1.5.0-rc1

Mar 27, 2026

v1.4.1

Mar 25, 2026

Changes in this version

type DaemonInfo

+ Email string

v1.4.0

Mar 24, 2026

Changes in this version

type Config

+ Email string

type Daemon

+ func (d *Daemon) AddTunnelPeer(nodeID uint32, addr *net.UDPAddr)

+ func (d *Daemon) TunnelAddr() net.Addr

v1.3.0

Mar 15, 2026

Changes in this version

+ func CancelTaskBothSides(taskID string) error

+ func ExpireTaskBothSides(taskID, stagedAt string, regConn *registry.Client, receiverNodeID uint32) error

+ func GetQueueStagedAt(taskID string) string

+ func LoadSubmittedTaskFile(taskID string) (*tasksubmit.TaskFile, error)

+ func LoadTaskFile(taskID string) (*tasksubmit.TaskFile, error)

+ func RemoveFromQueue(taskID string) bool

+ func SaveTaskFile(tf *tasksubmit.TaskFile, isSubmitter bool) error

+ func UpdateTaskFileWithTimes(taskID, status, justification, action string, isSubmitter bool, ...) error

+ func UpdateTaskStatus(taskID, status, justification string, isSubmitter bool) error

type Config

+ DisableTaskSubmit bool

type Daemon

+ func (d *Daemon) TaskQueue() *TaskQueue

+ type TaskQueue struct

+ func NewTaskQueue() *TaskQueue

+ func (q *TaskQueue) Add(taskID string)

+ func (q *TaskQueue) GetHeadStagedAt() string

+ func (q *TaskQueue) GetStagedAt(taskID string) string

+ func (q *TaskQueue) Len() int

+ func (q *TaskQueue) List() []string

+ func (q *TaskQueue) Peek() string

+ func (q *TaskQueue) Pop() string

+ func (q *TaskQueue) Remove(taskID string) bool

v1.2.2

Feb 17, 2026

Changes in this version

+ const AcceptQueueLen

+ const ClockGranularity

+ const CmdAccept

+ const CmdBind

+ const CmdBindOK

+ const CmdClose

+ const CmdCloseOK

+ const CmdDeregister

+ const CmdDeregisterOK

+ const CmdDial

+ const CmdDialOK

+ const CmdError

+ const CmdHandshake

+ const CmdHandshakeOK

+ const CmdInfo

+ const CmdInfoOK

+ const CmdRecv

+ const CmdRecvFrom

+ const CmdResolveHostname

+ const CmdResolveHostnameOK

+ const CmdSend

+ const CmdSendTo

+ const CmdSetHostname

+ const CmdSetHostnameOK

+ const CmdSetTags

+ const CmdSetTagsOK

+ const CmdSetTaskExec

+ const CmdSetTaskExecOK

+ const CmdSetVisibility

+ const CmdSetVisibilityOK

+ const CmdSetWebhook

+ const CmdSetWebhookOK

+ const DefaultIdleSweepInterval

+ const DefaultIdleTimeout

+ const DefaultKeepaliveInterval

+ const DefaultMaxConnectionsPerPort

+ const DefaultMaxTotalConnections

+ const DefaultSYNRateLimit

+ const DefaultTimeWaitDuration

+ const DelayedACKThreshold

+ const DelayedACKTimeout

+ const DialCheckInterval

+ const DialDirectRetries

+ const DialInitialRTO

+ const DialMaxRTO

+ const DialMaxRetries

+ const HandshakeAccept

+ const HandshakeReject

+ const HandshakeRequest

+ const HandshakeRevoke

+ const HeartbeatReregThresh

+ const InitialCongWin

+ const InitialRTO

+ const MaxCongWin

+ const MaxOOOBuf

+ const MaxRecvWin

+ const MaxRetxAttempts

+ const MaxSegmentSize

+ const NagleTimeout

+ const RTOMax

+ const RTOMin

+ const RecvBufSize

+ const RecvChSize

+ const RetxCheckInterval

+ const SYNBucketAge

+ const SendBufLen

+ const SubHandshakeApprove

+ const SubHandshakePending

+ const SubHandshakeReject

+ const SubHandshakeRevoke

+ const SubHandshakeSend

+ const SubHandshakeTrusted

+ const ZeroWinProbeInitial

+ const ZeroWinProbeMax

+ func DiscoverEndpoint(beaconAddr string, nodeID uint32, conn *net.UDPConn) (*net.UDPAddr, error)

+ func EncodeSACK(blocks []SACKBlock) []byte

+ type Config struct

+ BeaconAddr string

+ DisableDataExchange bool

+ DisableEcho bool

+ DisableEventStream bool

+ Encrypt bool

+ Endpoint string

+ Hostname string

+ IdentityPath string

+ IdleTimeout time.Duration

+ KeepaliveInterval time.Duration

+ ListenAddr string

+ MaxConnectionsPerPort int

+ MaxTotalConnections int

+ Owner string

+ Public bool

+ RegistryAddr string

+ RegistryFingerprint string

+ RegistryTLS bool

+ SYNRateLimit int

+ SocketPath string

+ TimeWaitDuration time.Duration

+ WebhookURL string

+ type ConnState uint8

+ const StateCloseWait

+ const StateClosed

+ const StateEstablished

+ const StateFinWait

+ const StateListen

+ const StateSynReceived

+ const StateSynSent

+ const StateTimeWait

+ func (s ConnState) String() string

+ type ConnStats struct

+ BytesRecv uint64

+ BytesSent uint64

+ DupACKs uint64

+ FastRetx uint64

+ Retransmits uint64

+ SACKRecv uint64

+ SACKSent uint64

+ SegsRecv uint64

+ SegsSent uint64

+ type Connection struct

+ ACKTimer *time.Timer

+ AckMu sync.Mutex

+ CloseOnce sync.Once

+ CongWin int

+ DupAckCount int

+ ExpectedSeq uint32

+ ID uint32

+ InRecovery bool

+ LastAck uint32

+ LastActivity time.Time

+ LastRetxTime time.Time

+ LocalAddr protocol.Addr

+ LocalPort uint16

+ Mu sync.Mutex

+ NagleBuf []byte

+ NagleCh chan struct{}

+ NagleMu sync.Mutex

+ NoDelay bool

+ OOOBuf []*recvSegment

+ PeerRecvWin int

+ PendingACKs int

+ RTO time.Duration

+ RTTVAR time.Duration

+ RecoveryPoint uint32

+ RecvAck uint32

+ RecvBuf chan []byte

+ RecvClosed bool

+ RecvMu sync.Mutex

+ RemoteAddr protocol.Addr

+ RemotePort uint16

+ RetxMu sync.Mutex

+ RetxSend func(*protocol.Packet)

+ RetxStop chan struct{}

+ SRTT time.Duration

+ SSThresh int

+ SendBuf chan []byte

+ SendSeq uint32

+ State ConnState

+ Stats ConnStats

+ Unacked []*retxEntry

+ WindowCh chan struct{}

+ func (c *Connection) BytesInFlight() int

+ func (c *Connection) CloseRecvBuf()

+ func (c *Connection) DeliverInOrder(seq uint32, data []byte) uint32

+ func (c *Connection) EffectiveWindow() int

+ func (c *Connection) ProcessAck(ack uint32, pureACK bool)

+ func (c *Connection) ProcessSACK(blocks []SACKBlock)

+ func (c *Connection) RecvWindow() uint16

+ func (c *Connection) SACKBlocks() []SACKBlock

+ func (c *Connection) TrackSend(seq uint32, data []byte)

+ func (c *Connection) WindowAvailable() bool

+ type ConnectionInfo struct

+ CongWin int

+ ID uint32

+ InFlight int

+ InRecovery bool

+ LocalPort uint16

+ OOOBuf int

+ PeerRecvWin int

+ RTTVAR time.Duration

+ RecvAck uint32

+ RecvWin int

+ RemoteAddr string

+ RemotePort uint16

+ SRTT time.Duration

+ SSThresh int

+ SendSeq uint32

+ State string

+ Stats ConnStats

+ Unacked int

+ type Daemon struct

+ func New(cfg Config) *Daemon

+ func (d *Daemon) Addr() protocol.Addr

+ func (d *Daemon) CloseConnection(conn *Connection)

+ func (d *Daemon) DialConnection(dstAddr protocol.Addr, dstPort uint16) (*Connection, error)

+ func (d *Daemon) Identity() *crypto.Identity

+ func (d *Daemon) Info() *DaemonInfo

+ func (d *Daemon) NodeID() uint32

+ func (d *Daemon) SendData(conn *Connection, data []byte) error

+ func (d *Daemon) SendDatagram(dstAddr protocol.Addr, dstPort uint16, data []byte) error

+ func (d *Daemon) SetWebhookURL(url string)

+ func (d *Daemon) Start() error

+ func (d *Daemon) Stop() error

+ type DaemonInfo struct

+ Address string

+ AuthenticatedPeers int

+ BytesRecv uint64

+ BytesSent uint64

+ ConnList []ConnectionInfo

+ Connections int

+ Encrypt bool

+ EncryptedPeers int

+ Hostname string

+ Identity bool

+ NodeID uint32

+ Owner string

+ PeerList []PeerInfo

+ Peers int

+ PktsRecv uint64

+ PktsSent uint64

+ Ports int

+ PublicKey string

+ Uptime time.Duration

+ type HandshakeManager struct

+ func NewHandshakeManager(d *Daemon) *HandshakeManager

+ func (hm *HandshakeManager) ApproveHandshake(peerNodeID uint32) error

+ func (hm *HandshakeManager) IsTrusted(nodeID uint32) bool

+ func (hm *HandshakeManager) PendingRequests() []PendingHandshake

+ func (hm *HandshakeManager) RejectHandshake(peerNodeID uint32, reason string) error

+ func (hm *HandshakeManager) RevokeTrust(peerNodeID uint32) error

+ func (hm *HandshakeManager) SendRequest(peerNodeID uint32, justification string) error

+ func (hm *HandshakeManager) SetWebhook(wc *WebhookClient)

+ func (hm *HandshakeManager) Start() error

+ func (hm *HandshakeManager) Stop()

+ func (hm *HandshakeManager) TrustedPeers() []TrustRecord

+ type HandshakeMsg struct

+ Justification string

+ NodeID uint32

+ PublicKey string

+ Reason string

+ Signature string

+ Timestamp int64

+ Type string

+ type IPCServer struct

+ func NewIPCServer(socketPath string, d *Daemon) *IPCServer

+ func (s *IPCServer) Close() error

+ func (s *IPCServer) DeliverDatagram(srcAddr protocol.Addr, srcPort uint16, dstPort uint16, data []byte)

+ func (s *IPCServer) Start() error

+ type IncomingPacket struct

+ From *net.UDPAddr

+ Packet *protocol.Packet

+ type Listener struct

+ AcceptCh chan *Connection

+ Port uint16

+ type PeerInfo struct

+ Authenticated bool

+ Encrypted bool

+ Endpoint string

+ NodeID uint32

+ Relay bool

+ type PendingHandshake struct

+ Justification string

+ NodeID uint32

+ PublicKey string

+ ReceivedAt time.Time

+ type PortManager struct

+ func NewPortManager() *PortManager

+ func (pm *PortManager) AllConnections() []*Connection

+ func (pm *PortManager) AllocEphemeralPort() uint16

+ func (pm *PortManager) Bind(port uint16) (*Listener, error)

+ func (pm *PortManager) ConnectionCountForPort(port uint16) int

+ func (pm *PortManager) ConnectionList() []ConnectionInfo

+ func (pm *PortManager) FindConnection(localPort uint16, remoteAddr protocol.Addr, remotePort uint16) *Connection

+ func (pm *PortManager) GetConnection(id uint32) *Connection

+ func (pm *PortManager) GetListener(port uint16) *Listener

+ func (pm *PortManager) IdleConnections(maxIdle time.Duration) []*Connection

+ func (pm *PortManager) NewConnection(localPort uint16, remoteAddr protocol.Addr, remotePort uint16) *Connection

+ func (pm *PortManager) RemoveConnection(id uint32)

+ func (pm *PortManager) StaleConnections(timeWaitDur time.Duration) []*Connection

+ func (pm *PortManager) TotalActiveConnections() int

+ func (pm *PortManager) Unbind(port uint16)

+ type SACKBlock struct

+ Left uint32

+ Right uint32

+ func DecodeSACK(data []byte) ([]SACKBlock, bool)

+ type TrustRecord struct

+ ApprovedAt time.Time

+ Mutual bool

+ Network uint16

+ NodeID uint32

+ PublicKey string

+ type TunnelManager struct

+ BytesRecv uint64

+ BytesSent uint64

+ PktsRecv uint64

+ PktsSent uint64

+ func NewTunnelManager() *TunnelManager

+ func (tm *TunnelManager) AddPeer(nodeID uint32, addr *net.UDPAddr)

+ func (tm *TunnelManager) Close() error

+ func (tm *TunnelManager) EnableEncryption() error

+ func (tm *TunnelManager) HasCrypto(nodeID uint32) bool

+ func (tm *TunnelManager) HasPeer(nodeID uint32) bool

+ func (tm *TunnelManager) IsEncrypted(nodeID uint32) bool

+ func (tm *TunnelManager) IsRelayPeer(nodeID uint32) bool

+ func (tm *TunnelManager) Listen(addr string) error

+ func (tm *TunnelManager) LocalAddr() net.Addr

+ func (tm *TunnelManager) PeerCount() int

+ func (tm *TunnelManager) PeerList() []PeerInfo

+ func (tm *TunnelManager) RecvCh() <-chan *IncomingPacket

+ func (tm *TunnelManager) RegisterWithBeacon()

+ func (tm *TunnelManager) RemovePeer(nodeID uint32)

+ func (tm *TunnelManager) RequestHolePunch(targetNodeID uint32)

+ func (tm *TunnelManager) Send(nodeID uint32, pkt *protocol.Packet) error

+ func (tm *TunnelManager) SendTo(addr *net.UDPAddr, nodeID uint32, pkt *protocol.Packet) error

+ func (tm *TunnelManager) SetBeaconAddr(addr string) error

+ func (tm *TunnelManager) SetIdentity(id *crypto.Identity)

+ func (tm *TunnelManager) SetNodeID(id uint32)

+ func (tm *TunnelManager) SetPeerPubKey(nodeID uint32, pubKey ed25519.PublicKey)

+ func (tm *TunnelManager) SetPeerVerifyFunc(fn func(uint32) (ed25519.PublicKey, error))

+ func (tm *TunnelManager) SetRelayPeer(nodeID uint32, relay bool)

+ func (tm *TunnelManager) SetWebhook(wc *WebhookClient)

+ type WebhookClient struct

+ func NewWebhookClient(url string, nodeIDFunc func() uint32) *WebhookClient

+ func (wc *WebhookClient) Close()

+ func (wc *WebhookClient) Emit(event string, data interface{})

+ type WebhookEvent struct

+ Data interface{}

+ Event string

+ NodeID uint32

+ Timestamp time.Time

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL