Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

directory

package

Go to main page

Versions in this module

v0

v0.2.5

Jun 19, 2026

Changes in this version

type NodeInfo

+ Badge string

+ BadgeSig string

+ RecoveryCommitment string

+ RecoveryProvider string

+ VerificationProvider string

+ VerifiedAt time.Time

v0.2.4

Jun 7, 2026

v0.2.3

May 29, 2026

v0.2.2

May 29, 2026

v0.2.1

May 29, 2026

v0.2.1-beta.1

May 29, 2026

v0.2.0

May 28, 2026

Changes in this version

+ const AdminListNodesTTL

+ const NumNodeShards

+ const RawResponseKey

+ const ReapChunkSize

+ func ValidateHostname(name string) error

+ type Callbacks struct

+ AddNodeToBackbone func(nodeID uint32)

+ AdminToken func() string

+ Audit func(action string, attrs ...any)

+ BeaconAddr func() string

+ ClearInviteInbox func(nodeID uint32)

+ IncDeregistrations func()

+ IncErrorsTotal func(label string)

+ IncRegistrations func()

+ IncRequestsTotal func(label string)

+ InvalidateAdminListNodesCache func()

+ InvalidateListNodesCache func(netID uint16)

+ IsTrusted func(nodeA, nodeB uint32) bool

+ Now func() time.Time

+ ObserveRequestDuration func(label string, seconds float64)

+ PublishMembershipChanged func(netID uint16)

+ RecordWALDeregister func(nodeID uint32)

+ RecordWALRegister func(nodeID uint32, owner, pubKeyB64, realAddr, hostname string, lanAddrs []string, ...)

+ RemoveFromNetworks func(nodeID uint32, networks []uint16) (lostOwnerNets []uint16)

+ RequireAdminToken func(msg map[string]interface{}) error

+ RequireAdminTokenLocked func(msg map[string]interface{}) error

+ Save func()

+ ScanNetworkMemberships func(nodeID uint32) []uint16

+ VerifyNodeSignature func(pubKey []byte, adminToken string, msg map[string]interface{}, challenge string) error

+ type KeyInfo struct

+ CreatedAt time.Time

+ ExpiresAt time.Time

+ RotateCount int

+ RotatedAt time.Time

+ type ListNodesCacheState struct

+ Building bool

+ BuiltAt time.Time

+ CacheHits uint64

+ CacheRebuilds uint64

+ CacheWaits uint64

+ Cond *sync.Cond

+ FullBody []byte

+ LastBuildErr error

+ Mu sync.Mutex

+ type NetworkMemberView struct

+ MemberRoles map[uint32]string

+ MemberTags map[uint32][]string

+ Members []uint32

+ type NodeInfo struct

+ ExternalID string

+ Hostname string

+ ID uint32

+ KeyMeta KeyInfo

+ LANAddrs []string

+ LastSeen time.Time

+ LastSeenNano atomic.Int64

+ LastVerifiedNano atomic.Int64

+ Networks []uint16

+ Owner string

+ Public bool

+ PublicKey []byte

+ RealAddr string

+ RelayOnly bool

+ Tags []string

+ TaskExec bool

+ Version string

+ func (n *NodeInfo) GetLastSeen() time.Time

+ func (n *NodeInfo) SetLastSeen(t time.Time)

+ type NodeShards = [NumNodeShards]sync.RWMutex

+ type Store struct

+ func NewStore(mu *sync.RWMutex, nodeShards *NodeShards, nodes map[uint32]*NodeInfo, ...) *Store

+ func (st *Store) AdminListNodesCached() ([]byte, error)

+ func (st *Store) HandleBinaryHeartbeat(conn net.Conn, payload []byte)

+ func (st *Store) HandleBinaryLookup(conn net.Conn, payload []byte)

+ func (st *Store) HandleBinaryResolve(conn net.Conn, payload []byte)

+ func (st *Store) HandleDeregister(msg map[string]interface{}) (map[string]interface{}, error)

+ func (st *Store) HandleHeartbeat(msg map[string]interface{}) (map[string]interface{}, error)

+ func (st *Store) HandleListNodes(msg map[string]interface{}, ...) (map[string]interface{}, error)

+ func (st *Store) HandleLookup(msg map[string]interface{}) (map[string]interface{}, error)

+ func (st *Store) HandleReRegister(pubKeyB64, listenAddr, owner, hostname string, lanAddrs []string, ...) (map[string]interface{}, error)

+ func (st *Store) HandleRegister(msg map[string]interface{}, remoteAddr string, ...) (map[string]interface{}, error)

+ func (st *Store) HandleResolve(msg map[string]interface{}) (map[string]interface{}, error)

+ func (st *Store) HandleResolveHostname(msg map[string]interface{}) (map[string]interface{}, error)

+ func (st *Store) HandleSetHostname(msg map[string]interface{}) (map[string]interface{}, error)

+ func (st *Store) HandleSetTags(msg map[string]interface{}) (map[string]interface{}, error)

+ func (st *Store) HandleSetVisibility(msg map[string]interface{}) (map[string]interface{}, error)

+ func (st *Store) InvalidateAdminListNodesCache()

+ func (st *Store) InvalidateListNodesCacheForNetwork(netID uint16)

+ func (st *Store) PerNetworkListNodesCached(netID uint16) ([]byte, error)

+ func (st *Store) ReapStaleNodes(threshold time.Time)

+ func (st *Store) ReplaceState(nodes map[uint32]*NodeInfo, pubKeyIdx map[string]uint32, ...)

v0.1.0

May 22, 2026