oimregistry

type Option func(r *registry) error

type RegistryDB interface {
	// Store a new mapping. Empty address removes the entry.
	Store(controllerID, address string)

	// Lookup returns the endpoint or the empty string if not found.
	Lookup(controllerID string) (address string)

	// Foreach iterates over all DB entries until
	// the callback function returns false.
	Foreach(func(controllerID, address string) bool)
}

type RegistryServer interface {
	oim.RegistryServer

	// Server creates a server as required to run the registry service.
	Server(endpoint string) (*oimcommon.NonBlockingGRPCServer, func(*grpc.Server))
}