go-micro: github.com/micro/go-micro/router Index | Files | Directories

package router

import "github.com/micro/go-micro/router"

Package router provides a network routing control plane

Index

Package Files

default.go options.go query.go route.go router.go table.go watcher.go

Variables

var (
    // AdvertiseEventsTick is time interval in which the router advertises route updates
    AdvertiseEventsTick = 10 * time.Second
    // DefaultAdvertTTL is default advertisement TTL
    DefaultAdvertTTL = 2 * time.Minute
    // AdvertSuppress is advert suppression threshold
    AdvertSuppress = 200.0
    // AdvertRecover is advert recovery threshold
    AdvertRecover = 20.0
    // Penalty for routes processed multiple times
    Penalty = 100.0
    // PenaltyHalfLife is the time the advert penalty decays to half its value
    PenaltyHalfLife = 30.0
    // MaxSuppressTime defines time after which the suppressed advert is deleted
    MaxSuppressTime = 90 * time.Second
    // PenaltyDecay is a coefficient which controls the speed the advert penalty decays
    PenaltyDecay = math.Log(2) / PenaltyHalfLife
)
var (
    // DefaultLink is default network link
    DefaultLink = "local"
    // DefaultLocalMetric is default route cost for a local route
    DefaultLocalMetric int64 = 1
)
var (
    // DefaultAddress is default router address
    DefaultAddress = ":9093"
    // DefaultName is default router service name
    DefaultName = "go.micro.router"
    // DefaultNetwork is default micro network
    DefaultNetwork = "go.micro"
    // DefaultRouter is default network router
    DefaultRouter = NewRouter()
)
var (
    // ErrRouteNotFound is returned when no route was found in the routing table
    ErrRouteNotFound = errors.New("route not found")
    // ErrDuplicateRoute is returned when the route already exists
    ErrDuplicateRoute = errors.New("duplicate route")
)
var (
    // ErrWatcherStopped is returned when routing table watcher has been stopped
    ErrWatcherStopped = errors.New("watcher stopped")
)
type Advert struct {
    // Id is the router Id
    Id  string
    // Type is type of advert
    Type AdvertType
    // Timestamp marks the time when the update is sent
    Timestamp time.Time
    // TTL is Advert TTL
    TTL time.Duration
    // Events is a list of routing table events to advertise
    Events []*Event
}

Advert contains a list of events advertised by the router to the network

type AdvertType Uses

type AdvertType int

AdvertType is route advertisement type

const (
    // Announce is advertised when the router announces itself
    Announce AdvertType = iota
    // RouteUpdate advertises route updates
    RouteUpdate
)

func (AdvertType) String Uses

func (t AdvertType) String() string

String returns human readable advertisement type

type Event Uses

type Event struct {
    // Unique id of the event
    Id  string
    // Type defines type of event
    Type EventType
    // Timestamp is event timestamp
    Timestamp time.Time
    // Route is table route
    Route Route
}

Event is returned by a call to Next on the watcher.

type EventType Uses

type EventType int

EventType defines routing table event

const (
    // Create is emitted when a new route has been created
    Create EventType = iota
    // Delete is emitted when an existing route has been deleted
    Delete
    // Update is emitted when an existing route has been updated
    Update
)

func (EventType) String Uses

func (t EventType) String() string

String returns human readable event type

type Option Uses

type Option func(*Options)

Option used by the router

func Address Uses

func Address(a string) Option

Address sets router service address

func Advertise(a Strategy) Option

Strategy sets route advertising strategy

func Client Uses

func Client(c client.Client) Option

Client to call router service

func Gateway Uses

func Gateway(g string) Option

Gateway sets network gateway

func Id Uses

func Id(id string) Option

Id sets Router Id

func Network Uses

func Network(n string) Option

Network sets router network

func Registry Uses

func Registry(r registry.Registry) Option

Registry sets the local registry

type Options Uses

type Options struct {
    // Id is router id
    Id  string
    // Address is router address
    Address string
    // Gateway is network gateway
    Gateway string
    // Network is network address
    Network string
    // Registry is the local registry
    Registry registry.Registry
    // Advertise is the advertising strategy
    Advertise Strategy
    // Client for calling router
    Client client.Client
}

Options are router options

func DefaultOptions Uses

func DefaultOptions() Options

DefaultOptions returns router default options

type QueryOption Uses

type QueryOption func(*QueryOptions)

QueryOption sets routing table query options

func QueryAddress Uses

func QueryAddress(a string) QueryOption

QueryAddress sets service to query

func QueryGateway Uses

func QueryGateway(g string) QueryOption

QueryGateway sets gateway address to query

func QueryNetwork Uses

func QueryNetwork(n string) QueryOption

QueryNetwork sets network name to query

func QueryRouter Uses

func QueryRouter(r string) QueryOption

QueryRouter sets router id to query

func QueryService Uses

func QueryService(s string) QueryOption

QueryService sets service to query

func QueryStrategy Uses

func QueryStrategy(s Strategy) QueryOption

QueryStrategy sets strategy to query

type QueryOptions Uses

type QueryOptions struct {
    // Service is destination service name
    Service string
    // Address of the service
    Address string
    // Gateway is route gateway
    Gateway string
    // Network is network address
    Network string
    // Router is router id
    Router string
    // Strategy is routing strategy
    Strategy Strategy
}

QueryOptions are routing table query options

func NewQuery Uses

func NewQuery(opts ...QueryOption) QueryOptions

NewQuery creates new query and returns it

type Route Uses

type Route struct {
    // Service is destination service name
    Service string
    // Address is service node address
    Address string
    // Gateway is route gateway
    Gateway string
    // Network is network address
    Network string
    // Router is router id
    Router string
    // Link is network link
    Link string
    // Metric is the route cost metric
    Metric int64
}

Route is network route

func (*Route) Hash Uses

func (r *Route) Hash() uint64

Hash returns route hash sum.

type Router Uses

type Router interface {
    // Init initializes the router with options
    Init(...Option) error
    // Options returns the router options
    Options() Options
    // The routing table
    Table() Table
    // Advertise advertises routes
    Advertise() (<-chan *Advert, error)
    // Process processes incoming adverts
    Process(*Advert) error
    // Lookup queries routes in the routing table
    Lookup(...QueryOption) ([]Route, error)
    // Watch returns a watcher which tracks updates to the routing table
    Watch(opts ...WatchOption) (Watcher, error)
    // Start starts the router
    Start() error
    // Stop stops the router
    Stop() error
    // Returns the router implementation
    String() string
}

Router is an interface for a routing control plane

func NewRouter Uses

func NewRouter(opts ...Option) Router

NewRouter creates new Router and returns it

type StatusCode Uses

type StatusCode int

StatusCode defines router status

const (
    // Running means the router is up and running
    Running StatusCode = iota
    // Advertising means the router is advertising
    Advertising
    // Stopped means the router has been stopped
    Stopped
    // Error means the router has encountered error
    Error
)

type Strategy Uses

type Strategy int

Strategy is route advertisement strategy

const (
    // AdvertiseAll advertises all routes to the network
    AdvertiseAll Strategy = iota
    // AdvertiseBest advertises optimal routes to the network
    AdvertiseBest
    // AdvertiseLocal will only advertise the local routes
    AdvertiseLocal
    // AdvertiseNone will not advertise any routes
    AdvertiseNone
)

TODO: remove the "Advertise" prefix from these

func (Strategy) String Uses

func (s Strategy) String() string

String returns human readable Strategy

type Table Uses

type Table interface {
    // Create new route in the routing table
    Create(Route) error
    // Delete existing route from the routing table
    Delete(Route) error
    // Update route in the routing table
    Update(Route) error
    // List all routes in the table
    List() ([]Route, error)
    // Query routes in the routing table
    Query(...QueryOption) ([]Route, error)
}

Table is an interface for routing table

type WatchOption Uses

type WatchOption func(*WatchOptions)

WatchOption is used to define what routes to watch in the table

func WatchService Uses

func WatchService(s string) WatchOption

WatchService sets what service routes to watch Service is the microservice name

type WatchOptions Uses

type WatchOptions struct {
    // Service allows to watch specific service routes
    Service string
}

WatchOptions are table watcher options TODO: expand the options to watch based on other criteria

type Watcher Uses

type Watcher interface {
    // Next is a blocking call that returns watch result
    Next() (*Event, error)
    // Chan returns event channel
    Chan() (<-chan *Event, error)
    // Stop stops watcher
    Stop()
}

Watcher defines routing table watcher interface Watcher returns updates to the routing table

Directories

PathSynopsis
service
service/proto

Package router imports 12 packages (graph) and is imported by 38 packages. Updated 2020-02-20. Refresh now. Tools for package owners.