Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  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
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

network

package

Go to main page

Versions in this module

v0

v0.5.0

Dec 30, 2024

Changes in this version

+ const ValidationAccept

+ const ValidationIgnore

+ const ValidationReject

+ type Messenger interface

+ SendMessage func(ctx context.Context, hostID string, msg types.MessageEnvelope, ...) error

+ SendMessageSync func(ctx context.Context, hostID string, msg types.MessageEnvelope, ...) error

+ type Network interface

+ AcceptSubnetPeer func(subnetID, peerID, ip string) error

+ AddSubnetDNSRecords func(subnetID string, records map[string]string) error

+ AddSubnetPeer func(subnetID, peerID, ip string) error

+ Advertise func(ctx context.Context, key string, data []byte) error

+ CreateSubnet func(ctx context.Context, subnetID string, routingTable map[string]string) error

+ DestroySubnet func(subnetID string) error

+ GetBroadcastScore func() map[PeerID]*PeerScoreSnapshot

+ GetHostID func() PeerID

+ GetPeerIP func(p PeerID) string

+ GetPeerPubKey func(peerID PeerID) crypto.PubKey

+ HandleMessage func(messageType string, handler func(data []byte, peerId peer.ID)) error

+ Init func(*config.Config) error

+ MapPort func(subnetID, protocol, sourceIP, sourcePort, destIP, destPort string) error

+ Notify func(ctx context.Context, preconnected func(PeerID, []ProtocolID, int), ...) error

+ PeerConnected func(p PeerID) bool

+ Ping func(ctx context.Context, address string, timeout time.Duration) (types.PingResult, error)

+ Publish func(ctx context.Context, topic string, data []byte) error

+ Query func(ctx context.Context, key string) ([]*commonproto.Advertisement, error)

+ RemoveSubnetDNSRecord func(subnetID, name string) error

+ RemoveSubnetPeer func(subnetID, peerID, ip string) error

+ ResolveAddress func(ctx context.Context, id string) ([]string, error)

+ SetBroadcastAppScore func(func(PeerID) float64)

+ SetupBroadcastTopic func(topic string, setup func(*Topic) error) error

+ Start func() error

+ Stat func() types.NetworkStats

+ Stop func() error

+ Subscribe func(ctx context.Context, topic string, handler func(data []byte), ...) (uint64, error)

+ Unadvertise func(ctx context.Context, key string) error

+ UnmapPort func(subnetID, protocol, sourceIP, sourcePort, destIP, destPort string) error

+ UnregisterMessageHandler func(messageType string)

+ Unsubscribe func(topic string, subID uint64) error

+ func NewNetwork(netConfig *types.NetworkConfig, fs afero.Fs) (Network, error)

+ type PeerID = libp2p.PeerID

+ type PeerScoreSnapshot = libp2p.PeerScoreSnapshot

+ type ProtocolID = libp2p.ProtocolID

+ type Topic = libp2p.Topic

+ type VPN interface

+ AddPeer func() error

+ RemovePeer func() error

+ Start func() error

+ Stop func() error

+ type ValidationResult = libp2p.ValidationResult

+ type Validator = libp2p.Validator

v0.5.0-rc2

Dec 13, 2024

v0.5.0-rc1-p1

Nov 19, 2024

v0.5.0-rc1

Nov 10, 2024

v0.5.0-boot-p3

Oct 1, 2024

v0.5.0-boot-p2

Sep 25, 2024

v0.5.0-boot-p1

Sep 20, 2024

v0.5.0-boot

Sep 17, 2024