daemonapi

package

Go to main page

Versions in this module

v0

v0.5.7

Jul 3, 2026

v0.5.6

Jun 21, 2026

v0.5.5

Jun 21, 2026

v0.5.4

Jun 21, 2026

v0.5.3

Jun 21, 2026

v0.5.2

Jun 21, 2026

v0.5.1

Jun 20, 2026

v0.5.0

Jun 19, 2026

v0.4.8

Jun 7, 2026

v0.4.7

Jun 6, 2026

v0.4.6

May 29, 2026

v0.4.5

May 29, 2026

v0.4.4

May 29, 2026

v0.4.3

May 29, 2026

Changes in this version

+ type VersionInfo struct

+ BuildTime string

+ Commit string

+ Version string

v0.4.2

May 29, 2026

v0.4.1

May 29, 2026

v0.4.0

May 29, 2026

Changes in this version

type Connection

+ Info func() ConnectionInfo

+ type ConnectionInfo struct

+ LocalAddr protocol.Addr

+ LocalPort uint16

+ RemoteAddr protocol.Addr

+ RemotePort uint16

+ type Listener interface

+ Accept func() (conn Connection, ok bool)

+ Close func() error

+ Port func() uint16

type PortAllocator

+ Bind func(port uint16) (Listener, error)

+ Unbind func(port uint16)

type TunnelRegistry

+ RemovePeer func(nodeID uint32)

v0.3.0

May 28, 2026

Changes in this version

+ const PolicyEventConnect

+ const PolicyEventCycle

+ const PolicyEventDatagram

+ const PolicyEventDial

+ const PolicyEventJoin

+ const PolicyEventLeave

+ func RegisterPlugin(name string, f Factory)

+ func Registered() []string

+ func ShutdownAll(ctx context.Context, plugins []Plugin) error

+ type ConnReadWriter interface

+ Close func() error

+ Read func(p []byte) (int, error)

+ Write func(p []byte) (int, error)

+ type Connection interface

+ type Daemon interface

+ Addr func() protocol.Addr

+ AdminToken func() string

+ Bus func() EventBus

+ CloseConnection func(conn Connection)

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

+ DialConnectionContext func(ctx context.Context, dstAddr protocol.Addr, dstPort uint16) (Connection, error)

+ GetTrustChecker func() TrustChecker

+ HandshakeRevokeTrust func(nodeID uint32) error

+ HandshakeSendRequest func(nodeID uint32, reason string) error

+ HandshakeService func() HandshakeService

+ Identity func() *crypto.Identity

+ IdentityPath func() string

+ NewConnReadWriter func(conn Connection) ConnReadWriter

+ NodeID func() uint32

+ Ports func() PortAllocator

+ PublishEvent func(topic string, payload map[string]any)

+ RegConnListNodes func(netID uint16, token string) (map[string]any, error)

+ RegisterHandshakeService func(svc HandshakeService)

+ RegisterPolicyManager func(pm PolicyManager)

+ RegisterTrustChecker func(tc TrustChecker)

+ RegisterWebhookManager func(wm WebhookManager)

+ RegistryClient func() *registry.Client

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

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

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

+ SetWebhookURL func(url string)

+ Sign func(msg []byte) []byte

+ Start func() error

+ Stop func() error

+ TrustAutoApprove func() bool

+ TrustedPeers func() []HandshakeTrustRecord

+ Tunnels func() TunnelRegistry

+ type Event struct

+ NodeID uint32

+ Payload map[string]any

+ Time time.Time

+ Topic string

+ type EventBus interface

+ Publish func(topic string, payload map[string]any)

+ Subscribe func(pattern string) (<-chan Event, func())

+ type Factory func() Plugin

+ type HandshakePendingRecord struct

+ Justification string

+ NodeID uint32

+ PublicKey string

+ ReceivedAt time.Time

+ type HandshakeService interface

+ ApproveHandshake func(peerNodeID uint32) error

+ IsTrusted func(nodeID uint32) bool

+ PendingCount func() int

+ PendingRequests func() []HandshakePendingRecord

+ ProcessRelayedApproval func(fromNodeID uint32)

+ ProcessRelayedRejection func(fromNodeID uint32)

+ ProcessRelayedRequest func(fromNodeID uint32, justification string)

+ RejectHandshake func(peerNodeID uint32, reason string) error

+ RevokeTrust func(peerNodeID uint32) error

+ SendRequest func(peerNodeID uint32, justification string) error

+ Stop func()

+ TrustedPeers func() []HandshakeTrustRecord

+ WaitForTrust func(peerNodeID uint32, timeout time.Duration) bool

+ type HandshakeTrustRecord struct

+ ApprovedAt time.Time

+ Mutual bool

+ Network uint16

+ NodeID uint32

+ PublicKey string

+ type Plugin interface

+ Init func(d Daemon) error

+ Name func() string

+ Shutdown func(ctx context.Context) error

+ func LoadAll(d Daemon) ([]Plugin, error)

+ type PolicyEventType = string

+ type PolicyManager interface

+ All func() []PolicyRunner

+ Get func(netID uint16) PolicyRunner

+ LoadPersisted func() error

+ Start func(netID uint16, policyJSON []byte) (PolicyRunner, error)

+ Stop func(netID uint16)

+ StopAll func()

+ type PolicyRunner interface

+ EvaluateActions func(eventType string, ctx map[string]any)

+ EvaluatePortGate func(eventType string, port uint16, peerNodeID uint32, payloadSize int, ...) bool

+ ForceCycle func() map[string]any

+ HasMember func(peerNodeID uint32) bool

+ NetworkID func() uint16

+ PeerList func() []map[string]interface{}

+ PolicyJSON func() ([]byte, error)

+ ReconcileNow func()

+ Status func() map[string]any

+ Stop func()

+ type PortAllocator interface

+ type TrustChecker interface

+ IsTrusted func(nodeID uint32) (string, bool)

+ type TunnelRegistry interface

+ type WebhookManager interface

+ SetURL func(url string)

+ Stats func() WebhookStats

+ type WebhookStats struct

+ CircuitSkips uint64

+ Dropped uint64

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