router

Dec 8, 2019

Changes in this version

type AdvertType

+ const Solicitation

Nov 27, 2019

Changes in this version

type Strategy

+ const AdvertiseLocal

+ const AdvertiseNone

Nov 3, 2019

Changes in this version

+ const Penalty

Oct 16, 2019

Changes in this version

type QueryOption

+ func QueryAddress(a string) QueryOption

type QueryOptions

+ Address string

+ type Strategy int

+ const AdvertiseAll

+ const AdvertiseBest

+ func (s Strategy) String() string

Sep 11, 2019

Changes in this version

type Router

+ Solicit func() error

Aug 19, 2019

Changes in this version

type Router

+ Start func() error

type Status

+ func (s Status) String() string

Aug 6, 2019

Changes in this version

+ const AdvertRecover

+ const AdvertSuppress

+ const AdvertiseEventsTick

+ const AdvertiseFlushTick

+ const AdvertiseTableTick

+ const DefaultAdvertTTL

+ const DeletePenalty

+ const MaxSuppressTime

+ const PenaltyHalfLife

+ const UpdatePenalty

+ var DefaultLink = "local"

+ var DefaultName = "go.micro.router"

+ var DefaultNetwork = "go.micro"

+ var DefaultRouter = NewRouter()

+ var PenaltyDecay = math.Log(2) / PenaltyHalfLife

+ type Advert struct

+ Events []*Event

+ Id string

+ TTL time.Duration

+ Timestamp time.Time

+ Type AdvertType

+ type AdvertType int

+ const Announce

+ const RouteUpdate

+ func (t AdvertType) String() string

type Event

+ Timestamp time.Time

type EventType

+ const Create

+ const Delete

+ const Update

type Option

+ func Client(c client.Client) Option

+ func Gateway(g string) Option

+ func Id(id string) Option

type Options

+ Client client.Client

+ Gateway string

+ Id string

type QueryOption

+ func QueryGateway(g string) QueryOption

+ func QueryService(s string) QueryOption

type QueryOptions

+ Gateway string

+ Service string

type Route

+ Address string

+ Gateway string

+ Link string

+ Service string

+ func (r *Route) Hash() uint64

type Router

+ Lookup func(Query) ([]Route, error)

+ Process func(*Advert) error

+ Status func() Status

+ Watch func(opts ...WatchOption) (Watcher, error)

+ type Status struct

+ Code StatusCode

+ Error error

+ type StatusCode int

+ const Advertising

+ const Error

+ const Running

+ const Stopped

+ func (s StatusCode) String() string

type Table

+ Create func(Route) error

+ Query func(Query) ([]Route, error)

type WatchOption

+ func WatchService(s string) WatchOption

type WatchOptions

+ Service string

Jun 21, 2019

Changes in this version

+ var AdvertiseTTL = 120 * time.Second

+ var AdvertiseTick = 5 * time.Second

+ var DefaultAddress = ":9093"

+ var DefaultAdvertise = ":9094"

+ var DefaultLocalMetric = 1

+ var DefaultNetworkMetric = 10

+ var ErrDuplicateRoute = errors.New("duplicate route")

+ var ErrRouteNotFound = errors.New("route not found")

+ var ErrWatcherStopped = errors.New("routing table watcher stopped")

+ type Event struct

+ Route Route

+ Type EventType

+ type EventType int

+ const CreateEvent

+ const DeleteEvent

+ const UpdateEvent

+ func (et EventType) String() string

+ type LookupPolicy int

+ const ClosestMatch

+ const DiscardNoRoute

+ func (lp LookupPolicy) String() string

+ type Option func(*Options)

+ func Address(a string) Option

+ func Advertise(n string) Option

+ func ID(id string) Option

+ func Network(r registry.Registry) Option

+ func Registry(r registry.Registry) Option

+ func RoutingTable(t Table) Option

+ type Options struct

+ Address string

+ Advertise string

+ ID string

+ Network registry.Registry

+ Registry registry.Registry

+ Table Table

+ func DefaultOptions() Options

+ type Query interface

+ Options func() QueryOptions

+ func NewQuery(opts ...QueryOption) Query

+ type QueryOption func(*QueryOptions)

+ func QueryDestination(a string) QueryOption

+ func QueryMetric(m int) QueryOption

+ func QueryNetwork(a string) QueryOption

+ func QueryPolicy(p LookupPolicy) QueryOption

+ func QueryRouter(r Router) QueryOption

+ type QueryOptions struct

+ Destination string

+ Metric int

+ Network string

+ Policy LookupPolicy

+ Router Router

+ type Route struct

+ Destination string

+ Metric int

+ Network string

+ Policy RoutePolicy

+ Router Router

+ func (r *Route) String() string

+ type RoutePolicy int

+ const IgnoreIfExists

+ const OverrideIfExists

+ func (p RoutePolicy) String() string

+ type Router interface

+ Address func() string

+ Advertise func() error

+ ID func() string

+ Init func(...Option) error

+ Network func() string

+ Options func() Options

+ Stop func() error

+ String func() string

+ Table func() Table

+ func NewRouter(opts ...Option) Router

+ type Table interface

+ Add func(Route) error

+ Delete func(Route) error

+ Init func(...TableOption) error

+ List func() ([]Route, error)

+ Lookup func(Query) ([]Route, error)

+ Options func() TableOptions

+ Size func() int

+ String func() string

+ Update func(Route) error

+ Watch func(opts ...WatchOption) (Watcher, error)

+ func NewTable(opts ...TableOption) Table

+ type TableOption func(*TableOptions)

+ type TableOptions struct

+ type WatchOption func(*WatchOptions)

+ func WatchDestination(a string) WatchOption

+ func WatchNetwork(n string) WatchOption

+ type WatchOptions struct

+ Destination string

+ Network string

+ type Watcher interface

+ Chan func() (<-chan *Event, error)

+ Next func() (*Event, error)

+ Stop func()