2019-06-18 11:56:11 +01:00
|
|
|
// Package network is a package for defining a network overlay
|
2019-06-17 16:57:53 +01:00
|
|
|
package network
|
|
|
|
|
|
|
|
import (
|
|
|
|
"github.com/micro/go-micro/config/options"
|
|
|
|
)
|
|
|
|
|
2019-07-01 22:41:27 +01:00
|
|
|
// Network defines a network interface. The network is a single
|
|
|
|
// shared network between all nodes connected to it. The network
|
|
|
|
// is responsible for routing messages to the correct services.
|
2019-06-17 16:57:53 +01:00
|
|
|
type Network interface {
|
|
|
|
options.Options
|
2019-07-07 10:10:38 +01:00
|
|
|
// Name of the network
|
|
|
|
Name() string
|
2019-06-22 16:51:20 +01:00
|
|
|
// Connect to the network
|
|
|
|
Connect() (Node, error)
|
|
|
|
// Peer with a neighboring network
|
|
|
|
Peer(Network) (Link, error)
|
2019-06-17 16:57:53 +01:00
|
|
|
}
|
|
|
|
|
2019-06-22 16:51:20 +01:00
|
|
|
// Node represents a single node on a network
|
2019-06-17 16:57:53 +01:00
|
|
|
type Node interface {
|
2019-07-01 11:55:15 +01:00
|
|
|
// Id of the node
|
|
|
|
Id() string
|
2019-06-22 19:02:57 +01:00
|
|
|
// Address of the node
|
|
|
|
Address() string
|
2019-07-01 11:55:15 +01:00
|
|
|
// The network of the node
|
2019-07-01 22:41:27 +01:00
|
|
|
Network() string
|
2019-06-22 19:02:57 +01:00
|
|
|
// Close the network connection
|
|
|
|
Close() error
|
|
|
|
// Accept messages on the network
|
|
|
|
Accept() (*Message, error)
|
|
|
|
// Send a message to the network
|
|
|
|
Send(*Message) error
|
2019-06-17 16:57:53 +01:00
|
|
|
}
|
|
|
|
|
2019-06-22 16:51:20 +01:00
|
|
|
// Link is a connection between one network and another
|
2019-06-18 11:56:11 +01:00
|
|
|
type Link interface {
|
2019-07-01 22:54:26 +01:00
|
|
|
// remote node the link is peered with
|
2019-06-18 11:56:11 +01:00
|
|
|
Node
|
2019-07-01 11:55:15 +01:00
|
|
|
// length defines the speed or distance of the link
|
2019-06-18 11:56:11 +01:00
|
|
|
Length() int
|
2019-07-01 11:55:15 +01:00
|
|
|
// weight defines the saturation or usage of the link
|
2019-06-18 11:56:11 +01:00
|
|
|
Weight() int
|
2019-06-17 16:57:53 +01:00
|
|
|
}
|
2019-06-17 18:25:42 +01:00
|
|
|
|
2019-06-18 11:56:11 +01:00
|
|
|
// Message is the base type for opaque data
|
2019-06-22 16:51:20 +01:00
|
|
|
type Message struct {
|
|
|
|
// Headers which provide local/remote info
|
|
|
|
Header map[string]string
|
|
|
|
// The opaque data being sent
|
2019-07-01 11:55:15 +01:00
|
|
|
Body []byte
|
2019-06-22 16:51:20 +01:00
|
|
|
}
|
2019-06-18 11:56:11 +01:00
|
|
|
|
2019-06-17 18:25:42 +01:00
|
|
|
var (
|
2019-07-07 10:10:38 +01:00
|
|
|
// The default network name is local
|
|
|
|
DefaultName = "local"
|
2019-06-26 16:12:57 +01:00
|
|
|
|
|
|
|
// just the standard network element
|
|
|
|
DefaultNetwork = NewNetwork()
|
2019-06-17 18:25:42 +01:00
|
|
|
)
|
2019-06-26 16:12:57 +01:00
|
|
|
|
2019-07-01 11:55:15 +01:00
|
|
|
// NewNetwork returns a new network interface
|
2019-06-26 16:12:57 +01:00
|
|
|
func NewNetwork(opts ...options.Option) Network {
|
2019-07-01 22:59:11 +01:00
|
|
|
return newNetwork(opts...)
|
2019-06-26 16:12:57 +01:00
|
|
|
}
|