serviceregistryserver

package

v0.0.0-...-e58ac12 Latest Latest Go to latest Published: Oct 28, 2021 License: Apache-2.0 Imports: 16 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/networkservicemesh/networkservicemesh

Links

Open Source Insights

Documentation ¶

Overview ¶

Package serviceregistryserver - NSM Registry Server

Index ¶

Constants
func New(ctx context.Context) *grpc.Server
func StartNSMDTracking(ctx context.Context, rc *nseRegistryCache)
type NSERegistryCache
- func NewNSERegistryCache() NSERegistryCache
type NSERegistryService
- func NewNseRegistryService(cache NSERegistryCache) NSERegistryService
type ServiceRegistry
- func NewNSMDServiceRegistryServer() ServiceRegistry

Constants ¶

View Source

const (
	// NSEExpirationTimeoutDefault - default Endpoint expiration timeout, NSE will be deleted if UpdateNetworkServiceEndpoint not received
	NSEExpirationTimeoutDefault = 5 * time.Minute
	// NSEExpirationTimeoutEnv - environment variable contains custom NSEExpirationTimeout
	NSEExpirationTimeoutEnv = utils.EnvVar("NSE_EXPIRATION_TIMEOUT")
)

Variables ¶

This section is empty.

Functions ¶

func New ¶

func New(ctx context.Context) *grpc.Server

New - creates new grcp server and registers NSE discovery and registry services

func StartNSMDTracking ¶

func StartNSMDTracking(ctx context.Context, rc *nseRegistryCache)

StartNSMDTracking - starts tracking NSMD expiration time to keep registry up to dated

Types ¶

type NSERegistryCache ¶

type NSERegistryCache interface {
	AddNetworkServiceEndpoint(nse *registry.NSERegistration) (*registry.NSERegistration, error)
	UpdateNetworkServiceEndpoint(nse *registry.NSERegistration) (*registry.NSERegistration, error)
	DeleteNetworkServiceEndpoint(endpointName string) (*registry.NSERegistration, error)
	GetEndpoints(networkServiceName string) []*registry.NSERegistration
}

NSERegistryCache - cache of registered Network Service Endpoints

func NewNSERegistryCache ¶

func NewNSERegistryCache() NSERegistryCache

NewNSERegistryCache creates new nerwork service endpoints cache

type NSERegistryService ¶

type NSERegistryService interface {
	RegisterNSE(ctx context.Context, request *registry.NSERegistration) (*registry.NSERegistration, error)
	BulkRegisterNSE(registry.NetworkServiceRegistry_BulkRegisterNSEServer) error
	RemoveNSE(ctx context.Context, request *registry.RemoveNSERequest) (*empty.Empty, error)
}

NSERegistryService - service registering Network Service Endpoints

func NewNseRegistryService ¶

func NewNseRegistryService(cache NSERegistryCache) NSERegistryService

NewNseRegistryService - creates NSE Registry service

type ServiceRegistry ¶

type ServiceRegistry interface {
	NewPublicListener(registryAPIAddress string) (net.Listener, error)
}

ServiceRegistry - service starting NSE registry server

func NewNSMDServiceRegistryServer ¶

func NewNSMDServiceRegistryServer() ServiceRegistry

NewNSMDServiceRegistryServer - creates new service registry service

Source Files ¶

View all Source files

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