registry

Documentation

Index

• type RegistryInterface
• type RouteRegistry
  • func NewRouteRegistry(c *config.Config, mbus yagnats.NATSConn, reporter metrics.RouteReporter) *RouteRegistry
  • func (r *RouteRegistry) Lookup(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) TimeOfLastUpdate() time.Time
  • func (r *RouteRegistry) Unregister(uri route.Uri, endpoint *route.Endpoint)
• type Trie
  • func NewTrie() *Trie
  • func (r *Trie) Delete(uri route.Uri) bool
  • func (r *Trie) EachNodeWithPool(f func(*Trie))
  • func (r *Trie) EndpointCount() int
  • func (r *Trie) Find(uri route.Uri) (*route.Pool, bool)
  • func (r *Trie) Insert(uri route.Uri, value *route.Pool) *Trie
  • func (r *Trie) MatchUri(uri route.Uri) (*route.Pool, bool)
  • func (r *Trie) PoolCount() int
  • func (r *Trie) PruneDeadLeaves()
  • func (r *Trie) Snip()
  • func (r *Trie) ToMap() map[route.Uri]*route.Pool

Types

type RegistryInterface

type RegistryInterface interface {
	Register(uri route.Uri, endpoint *route.Endpoint)
	Unregister(uri route.Uri, endpoint *route.Endpoint)
	Lookup(uri route.Uri) *route.Pool
	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(c *config.Config, mbus yagnats.NATSConn, reporter metrics.RouteReporter) *RouteRegistry

func (*RouteRegistry) Lookup

func (r *RouteRegistry) Lookup(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) TimeOfLastUpdate

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

func (*RouteRegistry) Unregister

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

type Trie

type Trie struct {
	Segment    string
	Pool       *route.Pool
	ChildNodes map[string]*Trie
	Parent     *Trie
}

func NewTrie

func NewTrie() *Trie

func (*Trie) Delete

func (r *Trie) Delete(uri route.Uri) bool

func (*Trie) EachNodeWithPool

func (r *Trie) EachNodeWithPool(f func(*Trie))

func (*Trie) EndpointCount

func (r *Trie) EndpointCount() int

func (*Trie) Find

func (r *Trie) Find(uri route.Uri) (*route.Pool, bool)

func (*Trie) Insert

func (r *Trie) Insert(uri route.Uri, value *route.Pool) *Trie

func (*Trie) MatchUri

func (r *Trie) MatchUri(uri route.Uri) (*route.Pool, bool)

func (*Trie) PoolCount

func (r *Trie) PoolCount() int

func (*Trie) PruneDeadLeaves

func (r *Trie) PruneDeadLeaves()

func (*Trie) Snip

func (r *Trie) Snip()

func (*Trie) ToMap

func (r *Trie) ToMap() map[route.Uri]*route.Pool