network

Documentation

Index

• type Service
  • func New(staticConfig *netpb.Net, dnsHandlerNames []string, ...) *Service
  • func (s *Service) AddLoopbackIP(ip net.IP) error
  • func (s *Service) ReleaseLoopbackIP(ip net.IP) error
  • func (s *Service) Run(ctx context.Context) error

Types

type Service

type Service struct {
	// If set, use the given static network configuration instead of relying on
	// autoconfiguration.
	StaticConfig *netpb.Net

	// Vendor Class identifier of the system
	DHCPVendorClassID string

	DNS *dns.Service

	// Status is the current status of the network as seen by the service.
	Status memory.Value[*node.NetStatus]
	// contains filtered or unexported fields
}

Service is the network service for this node. It maintains all networking-related functionality, but is generally not aware of the inner workings of Metropolis, instead functioning in a generic manner. Once created via New, it can be started and restarted arbitrarily, but the service object itself must be long-lived.

func New

func New(staticConfig *netpb.Net, dnsHandlerNames []string, ipamPrefixSrc event.Value[*ipam.Prefixes]) *Service

New instantiates a new network service. If autoconfiguration is desired, staticConfig must be set to nil. If staticConfig is set to a non-nil value, it will be used instead of autoconfiguration. If dnsHandlerNames is non-nil, DNS handlers with these names must be set on the DNS service with s.DNS.SetHandler. When serving DNS queries, they will be tried in the order they appear here before forwarding.

func (*Service) AddLoopbackIP

func (s *Service) AddLoopbackIP(ip net.IP) error

AddLoopbackIP adds the given IP to a loopback interface which can then be used to bind listeners to. Once this function returns, the IP is assigned and is ready to use. It's recommended to use defer to call ReleaseLoopbackIP to make sure IPs are released when the goroutine using it exits.

func (*Service) ReleaseLoopbackIP

func (s *Service) ReleaseLoopbackIP(ip net.IP) error

ReleaseLoopbackIP releases an IP allocated by AddLoopbackIP. Calling it multiple times for the same IP is an error.

func (*Service) Run

func (s *Service) Run(ctx context.Context) error