registryserver

package

v1.0.13 Latest Latest Go to latest Published: Dec 17, 2020 License: Apache-2.0 Imports: 25 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/adodon2go/networkservicemesh

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func FindNetworkServiceWithCache(cache RegistryCache, networkServiceName string) (*registry.FindNetworkServiceResponse, error)
func New(ctx context.Context, clientset *nsmClientset.Clientset, nsmName string) *grpc.Server
type RegistryCache
- func NewRegistryCache(cs *nsmClientset.Clientset, conf *ResourceFilterConfig) RegistryCache
type ResourceFilterConfig

Constants ¶

View Source

const (
	ProxyNsmdK8sAddressEnv      = "PROXY_NSMD_K8S_ADDRESS"
	ProxyNsmdK8sAddressDefaults = "pnsmgr-svc:5005"
)

Default values and environment variables of proxy connection

View Source

const (
	// ForwardingTimeout - Timeout waiting for Proxy NseRegistryClient
	ForwardingTimeout = 15 * time.Second
	// ProxyRegistryReconnectInterval - reconnect interval to Proxy NSMD-K8S if connection refused
	ProxyRegistryReconnectInterval = 15 * time.Second
)

View Source

const PodNameEnv = utils.EnvVar("POD_NAME")

View Source

const PodUidEnv = utils.EnvVar("POD_UID")

Variables ¶

This section is empty.

Functions ¶

func FindNetworkServiceWithCache ¶

func FindNetworkServiceWithCache(cache RegistryCache, networkServiceName string) (*registry.FindNetworkServiceResponse, error)

FindNetworkServiceWithCache returns network service with name from registry cache

func New ¶

func New(ctx context.Context, clientset *nsmClientset.Clientset, nsmName string) *grpc.Server

New - construct a registration server

Types ¶

type RegistryCache ¶

type RegistryCache interface {
	AddNetworkService(ns *v1.NetworkService) (*v1.NetworkService, error)
	GetNetworkService(name string) (*v1.NetworkService, error)

	CreateOrUpdateNetworkServiceManager(nsm *v1.NetworkServiceManager) (*v1.NetworkServiceManager, error)
	GetNetworkServiceManager(name string) (*v1.NetworkServiceManager, error)

	AddNetworkServiceEndpoint(nse *v1.NetworkServiceEndpoint) (*v1.NetworkServiceEndpoint, error)
	DeleteNetworkServiceEndpoint(endpointName string) error
	GetEndpointsByNs(networkServiceName string) []*v1.NetworkServiceEndpoint
	GetEndpointsByNsm(nsmName string) []*v1.NetworkServiceEndpoint

	Start() error
	Stop()
}

func NewRegistryCache ¶

func NewRegistryCache(cs *nsmClientset.Clientset, conf *ResourceFilterConfig) RegistryCache

NewRegistryCache creates new registry cache

type ResourceFilterConfig ¶

type ResourceFilterConfig struct {
	NetworkServiceEndpointFilterPolicy resourcecache.CacheFilterPolicy
	NetworkServiceManagerPolicy        resourcecache.CacheFilterPolicy
	NetworkServiceFilterPolicy         resourcecache.CacheFilterPolicy
}

ResourceFilterConfig means filter resource config for nsm custom resources

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
resourcecache

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL