Documentation
¶
Index ¶
- Constants
- type PruneStatus
- type Registry
- type 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 ¶
View Source
const ( CONNECTED = PruneStatus(iota) DISCONNECTED )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶
func NewRouteRegistry ¶
func NewRouteRegistry( logger logger.Logger, c *config.Config, listener routeUpdate.Listener, reporter metrics.RouteRegistryReporter, routerGroupGUID string, ) *RouteRegistry
func (*RouteRegistry) LookupWithInstance ¶
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))
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.