pkg/

Package client provides a simple wrapper for building a NetworkServiceMeshClient

Package endpoint provides a simple wrapper for building a NetworkServiceServer

Package nsmgr provides a Network Service Manager (nsmgrServer), but interface and implementation

Package peertracker provides a wrapper for a Nsmgr that tracks connections received from local Clients Its designed to be used in a DevicePlugin to allow us to properly Close connections on re-Allocate

Package nsmgrproxy provides chain of networkservice.NetworkServiceServer chain elements to creating NSMgrProxy

Package authorize provides authz checks for incoming or returning connections.

Code generated by "-output client_map.gen.go -type clientMap<string,*eventFactoryClient> -output client_map.gen.go -type clientMap<string,*eventFactoryClient>"; DO NOT EDIT.

Package clientconn - chain element for injecting a grpc.ClientConnInterface into the client chain Package clientconn allows storing grpc.ClientConnInterface stored in per Connection.Id metadata

Package clientinfo provides a chain element that adds pod, node and cluster names to request

Package clienturl provides server chain element that sets client URL in context Package clienturl provides server chain element that sets client URL in context

Package connect provides chain elements to 'connect' clients

Package dial will dial up a grpc.ClientConnInterface if a client *url.URL is provided in the ctx, retrievable by clienturlctx.ClientURL(ctx) and put the resulting grpc.ClientConnInterface into the ctx using clientconn.Store(..) where it can be retrieved by other chain elements using clientconn.Load(...)

Package discover provides a NetworkServiceServer chain element that discovers possible NSEs that can provide the requested network service and add them to the context.Context where they can be retrieved by Candidates(ctx)

Package discoverforwarder discovers forwarder from the registry.

Package excludedprefixes provides a networkservice.NetworkServiceServer chain element that can read excluded prefixes from config map and add them to request to avoid repeated usage.

Package externalips provides to the context on Request or Close possible to resolve external IP to internal or vise versa Code generated by "-output string_map.gen.go -type stringMap<string,string> -output string_map.gen.go -type stringMap<string,string>"; DO NOT EDIT.

Package filtermechanisms filters out remote mechanisms if communicating by remote url filters out local mechanisms otherwise.

Package heal provides a client chain element that can be used to enable fast heal of Connections if something goes wrong with the current Connection (as detected by monitor).

Package interdomainurl injects into incoming context the URL to remote side only if requesting endpoint has been resolved.

Package journal emits IP and PATH related event messages to NATS.

Package mechanisms provides a simple shim to allow the attempt to select a mechanism based on the MechanismPreference expressed in the Request.

Package checkmechanism provides TestSuites for use with implementations of a mechanism networkservice chain element.

Package kernel provides the necessary mechanisms to request and inject a kernel interface.

Package vlan provides server chain element setting vlan id on the kernel mechanism

Package recvfd provides a NetworkService{Client,Server} chain element that looks at Connection.Mechanism.Parameters[common.InodeURL] with scheme 'inode' and receives the fds (if possible) and converts them to scheme file.

Package sendfd provides a NetworkService{Client,Server} chain element that looks at the Connection.Mechanism and Request.MechanismPreferences and if they have the Parameters[common.InodeURL] with scheme 'file' converts them to scheme inode and sends them over the connection as fds if possible.

Package vni provides networkservice.NetworkService{Client,Server} chain elements for setting SrcIP/DstIP/VNI for the vxlan mechanism Code generated by "-output vni_map.gen.go -type Map<vniKey,*vniKey> -output vni_map.gen.go -type Map<vniKey,*vniKey>"; DO NOT EDIT.

Package mechanismtranslation provides client chain element to perform serverRequest -> clientRequest and clientConn -> serverConn mechanism translations Code generated by "-output mechanism_map.gen.go -type mechanismMap<string,*github.com/networkservicemesh/api/pkg/api/networkservice.Mechanism> -output mechanism_map.gen.go -type mechanismMap<string,*github.com/networkservicemesh/api/pkg/api/networkservice.Mechanism>"; DO NOT EDIT.

Package monitor provides a NetworkServiceServer chain element to provide a monitor server that reflects the connections actually in the NetworkServiceServer

Package null provides simple networkservice chain elements that do nothing by call next and returns what comes back.

Package onidle provides server chain element that executes a callback when there were no active connections for specified time

Package refresh periodically resends NetworkServiceMesh.Request for an existing connection so that the Endpoint doesn't 'expire' the networkservice.

Package replacelabels sets connection labels

Package retry provides a networkservice.NetworksrviceClient wrapper that allows to retries requests and closes.

Package roundrobin provides a networkservice chain element that round robins among the candidates for providing a requested networkservice

Package setextracontext define a chain element to set some extra context values

Package setlogoption - allow to overide some of logging capabilities.

Package swapip provides chain element to swapping fields of remote mechanisms such as common.SrcIP and common.DstIP from internal to external and vice versa on response.

Package switchcase provides chain elements acting like a switch-case statement, selecting a chain element with first succeed condition

Package timeout provides a NetworkServiceServer chain element that times out expired connection

Package trimpath provides a simple pair of chain elements, one for the server side, one for the client side.

Package updatepath provides a chain element that sets the id of an incoming or outgoing request

Package updatetoken provides chain elements to update Connection.Path

Package dnscontext provides a dns context specific chain element.

Package adapters provides adapters to translate between networkservice.NetworkService{Server,Client} Package adapters provides adapters to translate between networkservice.NetworkService{Server,Client}

Package chain provides a simple file for creating a networkservice.NetworkService{Server,Client} from a 'chain' of networkservice.NetworkService{Server,Client}s

Package eventchannel provides implementations based on event channels of: networkservice.MonitorConnectionClient networkservice.MonitorConnectionServer networkservice.MonitorConnection_MonitorConnectionsClient networkservice.MonitorConnection_MonitorConnectionsServer Package eventchannel provides API for creating monitoring components via golang channels

Package next provides a mechanism for chained networkservice.NetworkService{Server,Client}s to call the next element in the chain.

Package tests contains tests for package 'next'

Package trace provides a wrapper for tracing around a networkservice.NetworkServiceClient

Code generated by "-output connectionInfoMap.gen.go -type Map<string,*connectionInfo> -output connectionInfoMap.gen.go -type Map<string,*connectionInfo>"; DO NOT EDIT.

Code generated by "-output connectionInfoMap.gen.go -type Map<string,*connectionInfo> -output connectionInfoMap.gen.go -type Map<string,*connectionInfo>"; DO NOT EDIT.

Package checkconnection provides utilities for checking the returned connection from the next element in a chain

Package checkcontext - provides networkservice chain elements for checking the context.Context passed on by the previous chain element

Package checkcontextonreturn - provides a NetworkServiceClient chain element for checking the state of the context.Context after the next element in the chain has returned

Package checkerror provides chain elements to check for errors during testing

Package checkopts - provides tools for checking to make sure that grpc.CallOptions are propagated through a client chain elements

Package checkrequest - provides networkservice chain elements to check the request received from the previous element in the chain

Package checkresponse - provides networkservice chain elements to check the response received from the next element in the chain

Package count provides test chain elements for counting Requests/Closes

Package injectclock can be used in testing to inject a mockClock into the context of the chain

Package injecterror provides chain elements returning given error on Request, Close on given times

Package injectopts - injects grpc.CallOptions by appending them to the end of the opts...

Package metadata provides per Connection.Id metadata Code generated by "-output meta_data_map.gen.go -type metaDataMap<string,*metaData> -output meta_data_map.gen.go -type metaDataMap<string,*metaData>"; DO NOT EDIT.

Package client provides common functions for building NS, NSE registry clients Package client provides a simple functions for building a NetworkServiceEndpointRegistryClient, NetworkServiceRegistryClient

Package memory provides registry chain based on memory chain elements

Package proxydns provides default chain for stateless proxy registries based on DNS

Package clientinfo provides a chain element that adds pod, node and cluster names to request

Package clienturl provides NS, NSE registry server chain elements that set client URL in context

Package connect provides NS, NSE registry server chain elements providing access to remote registry servers Code generated by "-output ns_client_map.gen.go -type nsClientMap<string,*nsClient> -output ns_client_map.gen.go -type nsClientMap<string,*nsClient>"; DO NOT EDIT.

Package dnsresolve provides registry chain elements that can resolve passed Domain to URL

Package endpointurls provides registry.NetworkServiceEndpointRegistryServer that can be injected in the chain of registry.NetworkServiceEndpointRegistryServer to get an actual nses of registry.NetworkServiceEndpoint URLs.

Package expire provides registry server chain elements for unregistering expired endpoints, services

Package heal provides NS, NSE registry client chain elements for healing failed remote side Code generated by "-output ns_info_map.gen.go -type nsInfoMap<string,*nsInfo> -output ns_info_map.gen.go -type nsInfoMap<string,*nsInfo>"; DO NOT EDIT.

Package localbypass implements a chain element to set NSMgr URL to endpoints on registration and set back endpoints URLs on find

Package memory provides NSM registry chain elements to building memory-based registries Code generated by "-output ns_sync_map.gen.go -type NetworkServiceSyncMap<string,*github.com/networkservicemesh/api/pkg/api/registry.NetworkService> -output ns_sync_map.gen.go -type NetworkServiceSyncMap<string,*github.com/networkservicemesh/api/pkg/api/registry.NetworkService>"; DO NOT EDIT.

Package null provides simple registry chain elements that do nothing by call next and returns what comes back.

Package proxy provides registry chain elements that can put URL to the proxy registry to the context in case of interdomain upstream.

Code generated by "-output cache_entry_map.gen.go -type cacheEntryMap<string,*cacheEntry> -output cache_entry_map.gen.go -type cacheEntryMap<string,*cacheEntry>"; DO NOT EDIT.

Code generated by "-output per_endpoint_file_map.gen.go -type perEndpointFileMapMap<string,*perEndpointFileMap> -output per_endpoint_file_map.gen.go -type perEndpointFileMapMap<string,*perEndpointFileMap>"; DO NOT EDIT.

Package refresh provides registry elements for refreshing resources Code generated by "-output sync_map.gen.go -type cancelsMap<string,context.CancelFunc> -output sync_map.gen.go -type cancelsMap<string,context.CancelFunc>"; DO NOT EDIT.

Package sendfd provides a registry.NetworkServiceEndpointRegistryClient chain element to convert any unix file socket endpoint.URLs into 'inode://${dev}/${ino}' urls and send the fd over the unix file socket.

Package serialize provides NSE, NS registry chain elements for serial Register, Unregister event processing

Package setlogoption implements a chain element to set log options before full chain

Package setpayload provides registry elements for setting ns.payload default

Package setregistrationtime provides registry server chain elements for initial registration time setting

Package seturl provides registry.NetworkServiceEndpointRegistryServer that sets passed url for each found nse

Package storeurl provides chain element that stores incoming NSE URLs into map

Package swapip allows to replace internal NSE address to external for register/unregister/find queries.

Package adapters provide API to converting client to server and vise versa Package adapters provide API to converting client to server and vise versa

Package chain provides API to make chains of registry elements

Package next provides a mechanism for chained registry.{Registry,Discovery}{Server,Client}s to call the next element in the chain.

Package streamchannel provides find client/servers based on channels

Package streamcontext provides API to extend context for find client/server

Package trace provides a wrapper for tracing around a registry.{Registry,Discovery}{Server,Client}

Package checkcontext - provides registry chain elements for checking the context.Context passed on by the previous chain element

Package checknse - provides registry chain elements for checking the *registry.NetworkServiceEndpoint passed on by the previous chain element

Package injecterror provides chain elements returning given error on Register, Unregister on given times

Package addressof provides convenient functions for converting implementations of an interface to pointers to implementations of the interface.

Package cancelctx provides methods for creating context with injected cancel func for it

Package cidr provides common functions useful when working with Classless Inter-Domain Routing (CIDR)

Package clientinfo provides a set of utilities for adding client info to labels map

Code generated by "-output clientmap.gen.go -type Map<string,github.com/networkservicemesh/api/pkg/api/networkservice.NetworkServiceClient> -output clientmap.gen.go -type Map<string,github.com/networkservicemesh/api/pkg/api/networkservice.NetworkServiceClient>"; DO NOT EDIT.

Package clienturlctx allows the setting of a client url in the context of the request

Package clock provides tools for accessing time functions

Package clockmock provides tools for mocking time functions

Package debug provides a very simple function that, if executed will replace the executable with dlv running the executable and listening on the port specified by an environment variable.

Code generated by "-output dns_configs_map.gen.go -type dnsConfigsMap<string,[]*github.com/networkservicemesh/api/pkg/api/networkservice.DNSConfig> -output dns_configs_map.gen.go -type dnsConfigsMap<string,[]*github.com/networkservicemesh/api/pkg/api/networkservice.DNSConfig>"; DO NOT EDIT.

Package expire provide expiration manager Code generated by "-output timer_map.gen.go -type timerMap<string,*timer> -output timer_map.gen.go -type timerMap<string,*timer>"; DO NOT EDIT.

Package extend allows you to extend a context with values from another context

Package fs provides common filesystem functions and utilities

Package grpcutils - provides a simple ListenAndServe for grpc

Package interdomain provides tools to work with interdomain cases

Package ippool provides service for managing ip addresses

Package jaeger provides a set of utilities for assisting with using jaeger

Package log provides an unified interface Logger for logging

Package logruslogger provides wrapper for logrus logger which is consistent with Logger interface

Package spanlogger provides a set of utilities to assist in working with opentracing spans

Package matchutils provides utils to match network services and network service endpoints

Package multiexecutor provides a structure MultiExecutor that can be used to guarantee exclusive by ID, in order execution of functions.

Package nsurl provides a wrapper for a url.URL that is being used to represent a Network Service being requested by a workload.

Package opa provides of utilities for using OPA

Package opentracing provides a set of utilities to assist in working with opentracing

Package postpone is used to create a context with postponed deadline for some cleanup operations.

Package prefixpool provides service for prefix managing

Package sandbox provides API for testing NSM chains such as Forwarder, NSC, NSMgrs, Registries, NSE.

Package serializectx allows to set executor in the context

Package spiffejwt provides a token.GeneratorFunc for spiffe jwt tokens signed by x509vids

Package spire provides two simple functions: - Start to start a SpireServer/SpireAgent for local testing - AddEntry to add entries into the spire server

Package stringurl provides sync map like a Go map[string]*url.URL but is safe for concurrent using Code generated by "-output sync_map.gen.go -type Map<string,*net/url.URL> -output sync_map.gen.go -type Map<string,*net/url.URL>"; DO NOT EDIT.

Package token provides a simple type for functions that generate tokens

Package typeutils provides as simpler helper for getting a type Name from an interface{}