Documentation ¶
Overview ¶
Package network is for creating internetworks
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // NetworkChannel is the name of the tunnel channel for passing network messages NetworkChannel = "network" // ControlChannel is the name of the tunnel channel for passing control message ControlChannel = "control" // DefaultLink is default network link DefaultLink = "network" // MaxConnections is the max number of network client connections MaxConnections = 3 )
View Source
var ( // ErrClientNotFound is returned when client for tunnel channel could not be found ErrClientNotFound = errors.New("client not found") // ErrPeerLinkNotFound is returned when peer link could not be found in tunnel Links ErrPeerLinkNotFound = errors.New("peer link not found") )
View Source
var ( // DefaultName is default network name DefaultName = "go.micro" // DefaultAddress is default network address DefaultAddress = ":0" // ResolveTime defines time interval to periodically resolve network nodes ResolveTime = 1 * time.Minute // AnnounceTime defines time interval to periodically announce node neighbours AnnounceTime = 30 * time.Second // PruneTime defines time interval to periodically check nodes that need to be pruned // due to their not announcing their presence within this time interval PruneTime = 90 * time.Second )
View Source
var ( // ErrPeerExists is returned when adding a peer which already exists ErrPeerExists = errors.New("peer already exists") // ErrPeerNotFound is returned when a peer could not be found in node topology ErrPeerNotFound = errors.New("peer not found") )
View Source
var ( // MaxDepth defines max depth of peer topology MaxDepth uint = 3 )
Functions ¶
func PeersToProto ¶
PeersToProto returns node peers graph encoded into protobuf
Types ¶
type Network ¶
type Network interface { // Node is network node Node // Initialise options Init(...Option) error // Options returns the network options Options() Options // Name of the network Name() string // Connect starts the resolver and tunnel server Connect() error // Close stops the tunnel and resolving Close() error // Client is micro client Client() client.Client // Server is micro server Server() server.Server }
Network is micro network
func NewNetwork ¶
NewNetwork returns a new network interface
type Node ¶
type Node interface { // Id is node id Id() string // Address is node bind address Address() string // Peers returns node peers Peers() []Node // Network is the network node is in Network() Network }
Node is network node
type Options ¶
type Options struct { // Id of the node Id string // Name of the network Name string // Address to bind to Address string // Advertise sets the address to advertise Advertise string // Peers is a list of peers to connect to Peers []string // Tunnel is network tunnel Tunnel tunnel.Tunnel // Router is network router Router router.Router // Proxy is network proxy Proxy proxy.Proxy // Resolver is network resolver Resolver resolver.Resolver }
Options configure network
Directories ¶
Path | Synopsis |
---|---|
Package resolver resolves network names to addresses
|
Package resolver resolves network names to addresses |
dns
Package dns resolves names to dns records
|
Package dns resolves names to dns records |
dnssrv
Package dns srv resolves names to dns srv records
|
Package dns srv resolves names to dns srv records |
http
Package http resolves names to network addresses using a http request
|
Package http resolves names to network addresses using a http request |
registry
Package registry resolves names using the go-micro registry
|
Package registry resolves names using the go-micro registry |
static
Package static is a static resolver
|
Package static is a static resolver |
service
|
|
handler
Package handler implements network RPC handler
|
Package handler implements network RPC handler |
Click to show internal directories.
Click to hide internal directories.