registry

Documentation

Index

• Constants
• type PruneStatus
• type Registry
• type RouteRegistry
  • func NewRouteRegistry(logger logger.Logger, c *config.Config, listener routeUpdate.Listener, ...) *RouteRegistry
  • func (r *RouteRegistry) Lookup(uri route.Uri) *route.Pool
  • func (r *RouteRegistry) LookupWithInstance(uri route.Uri, appID string, appIndex string) *route.Pool
  • func (r *RouteRegistry) LookupWithoutWildcard(uri route.Uri) *route.Pool
  • func (r *RouteRegistry) MarshalJSON() ([]byte, error)
  • func (r *RouteRegistry) NumEndpoints() int
  • func (registry *RouteRegistry) NumUris() int
  • func (r *RouteRegistry) Register(uri route.Uri, endpoint *route.Endpoint)
  • func (r *RouteRegistry) StartPruningCycle()
  • func (r *RouteRegistry) StopPruningCycle()
  • func (r *RouteRegistry) SuspendPruning(f func() bool)
  • func (r *RouteRegistry) TimeOfLastUpdate() time.Time
  • func (r *RouteRegistry) Unregister(uri route.Uri, endpoint *route.Endpoint)
  • func (r *RouteRegistry) WalkNodesWithPool(f func(*container.Trie))

Constants

const (
	CONNECTED = PruneStatus(iota)
	DISCONNECTED
)

Types

type PruneStatus

type PruneStatus int

type Registry

type Registry interface {
	Register(uri route.Uri, endpoint *route.Endpoint)
	Unregister(uri route.Uri, endpoint *route.Endpoint)
	Lookup(uri route.Uri) *route.Pool
	LookupWithInstance(uri route.Uri, appID, appIndex string) *route.Pool
	LookupWithoutWildcard(uri route.Uri) *route.Pool
	WalkNodesWithPool(func(f *container.Trie))
	StartPruningCycle()
	StopPruningCycle()
	NumUris() int
	NumEndpoints() int
	MarshalJSON() ([]byte, error)
}

type RouteRegistry

type RouteRegistry struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewRouteRegistry

func NewRouteRegistry(
	logger logger.Logger,
	c *config.Config,
	listener routeUpdate.Listener,
	reporter metrics.RouteRegistryReporter,
	routerGroupGUID string,
) *RouteRegistry

func (*RouteRegistry) Lookup

func (r *RouteRegistry) Lookup(uri route.Uri) *route.Pool

func (*RouteRegistry) LookupWithInstance

func (r *RouteRegistry) LookupWithInstance(
	uri route.Uri,
	appID string,
	appIndex string,
) *route.Pool

func (*RouteRegistry) LookupWithoutWildcard

func (r *RouteRegistry) LookupWithoutWildcard(uri route.Uri) *route.Pool

func (*RouteRegistry) MarshalJSON

func (r *RouteRegistry) MarshalJSON() ([]byte, error)

func (*RouteRegistry) NumEndpoints

func (r *RouteRegistry) NumEndpoints() int

func (*RouteRegistry) NumUris

func (registry *RouteRegistry) NumUris() int

func (*RouteRegistry) Register

func (r *RouteRegistry) Register(uri route.Uri, endpoint *route.Endpoint)

func (*RouteRegistry) StartPruningCycle

func (r *RouteRegistry) StartPruningCycle()

func (*RouteRegistry) StopPruningCycle

func (r *RouteRegistry) StopPruningCycle()

func (*RouteRegistry) SuspendPruning

func (r *RouteRegistry) SuspendPruning(f func() bool)

func (*RouteRegistry) TimeOfLastUpdate

func (r *RouteRegistry) TimeOfLastUpdate() time.Time

func (*RouteRegistry) Unregister

func (r *RouteRegistry) Unregister(uri route.Uri, endpoint *route.Endpoint)

func (*RouteRegistry) WalkNodesWithPool

func (r *RouteRegistry) WalkNodesWithPool(f func(*container.Trie))