vmesh

type BackingService struct {
	// contains filtered or unexported fields
}

type DistributedConfig struct {
	PrefixWhitelist map[string][]string `json:"prefix_whitelist"` // node **name** -> list of allowed prefixes
}

type DistributedConfigState struct {
	sync.Mutex

	Config    *DistributedConfig
	RawConfig *protocol.DistributedConfig

	PrefixWhitelistTable map[string]*LikeRoutingTable // typeof value = PrefixWhitelistEntryProps
	// contains filtered or unexported fields
}

type DummyVif struct{}

type LatencyMeasurementResult struct {
	// contains filtered or unexported fields
}

type LatencyMeasurementState struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type LikeRoutingTable struct {
	Routes [129]sync.Map // prefix_len -> (IPV6 Address ([16]byte) -> interface{})
}

type LocalAnnouncement struct {
	Prefix string `json:"prefix"`
	Vif    string `json:"vif"`
}

type MessageStream interface {
	Send(message *protocol.Message) error
	Recv() (*protocol.Message, error)
	Context() context.Context
}

type MessageTag uint32

type Node struct {
	Config    *NodeConfig
	CAPool    *x509.CertPool // Internal CA
	CA        *x509.Certificate
	PeerCerts PeerCertCollection // External Peers' certificates
	FullCert  tls.Certificate
	LocalID   PeerID
	Domain    string

	// Values of the `Peers` map can be temporarily nil to indicate a peer is being initialized.
	Peers sync.Map // PeerID -> *Peer

	RoutingTable LikeRoutingTable

	Vifs map[string]Vif

	DCState DistributedConfigState

	UDPChannelAddr     *net.UDPAddr
	UDPChannelListener net.PacketConn
}

type NodeConfig struct {
	ListenAddr            string               `json:"listen_addr"`
	CAPath                string               `json:"ca"`
	ExternalPeerCertPaths []string             `json:"external_peer_certs"`
	CertPath              string               `json:"cert"`
	PrivateKeyPath        string               `json:"private_key"`
	ServerName            string               `json:"server_name"`
	LocalAnnouncements    []LocalAnnouncement  `json:"local_announcements"`
	Peers                 []PeerConfig         `json:"peers"`
	Vifs                  map[string]VifConfig `json:"vifs"`
}

type Peer struct {
	Node       *Node
	LocalCert  *x509.Certificate
	LocalID    PeerID
	RemoteCert *x509.Certificate
	RemoteID   PeerID
	RemoteName string
	Out        chan<- *protocol.Message
	// contains filtered or unexported fields
}

type PeerCertCollection struct {
	Certs map[PeerID]*x509.Certificate
}

type PeerConfig struct {
	Addr string `json:"addr"`
	Name string `json:"name"`
	UDP  bool   `json:"udp"`
}

type PeerID [32]byte

type PeerServer struct {
	protocol.UnimplementedVnetPeerServer
	// contains filtered or unexported fields
}

type PrefixWhitelistEntryProps struct {
	MaxPrefixLen uint8
}

type RouteInfo struct {
	Route        *protocol.Route
	NextPeerID   PeerID
	TotalLatency uint64
	UpdateTime   time.Time
	Vif          Vif // only for local routes
}

type Tun struct {
	// contains filtered or unexported fields
}

type UDPChannel struct {
	// contains filtered or unexported fields
}

type Vif interface {
	GetName() string
	Send([]byte) (int, error)
	Recv([]byte) (int, error)
}

type VifConfig struct {
	Type string `json:"type"` // required

	// for type: tun
	TunName string `json:"tun_name"`

	// for type: service
	ServiceName    string `json:"service_name"`
	ServiceNetwork string `json:"service_network"`
	ServiceAddress string `json:"service_address"`
}