micro/network/network.go

57 lines
1.2 KiB
Go
Raw Normal View History

2019-06-18 13:56:11 +03:00
// Package network is a package for defining a network overlay
2019-06-17 18:57:53 +03:00
package network
import (
"github.com/micro/go-micro/config/options"
)
2019-06-22 18:51:20 +03:00
// Network is an interface defining a network
2019-06-17 18:57:53 +03:00
type Network interface {
options.Options
2019-06-18 13:56:11 +03:00
// Id of this node
2019-06-22 18:51:20 +03:00
Id() string
// Address of the network
Address() string
// Connect to the network
Connect() (Node, error)
// Peer with a neighboring network
Peer(Network) (Link, error)
2019-06-17 18:57:53 +03:00
// Close the network connection
Close() error
2019-06-18 13:56:11 +03:00
// Accept messages on the network
2019-06-17 18:57:53 +03:00
Accept() (*Message, error)
2019-06-18 13:56:11 +03:00
// Send a message to the network
2019-06-17 18:57:53 +03:00
Send(*Message) error
2019-06-18 13:56:11 +03:00
// Retrieve list of connections
Links() ([]Link, error)
2019-06-17 18:57:53 +03:00
}
2019-06-22 18:51:20 +03:00
// Node represents a single node on a network
2019-06-17 18:57:53 +03:00
type Node interface {
2019-06-17 23:11:39 +03:00
// Node is a network. Network is a node.
Network
2019-06-17 18:57:53 +03:00
}
2019-06-22 18:51:20 +03:00
// Link is a connection between one network and another
2019-06-18 13:56:11 +03:00
type Link interface {
2019-06-22 18:51:20 +03:00
// remote node the link is to
2019-06-18 13:56:11 +03:00
Node
// length of link which dictates speed
Length() int
// weight of link which dictates curvature
Weight() int
2019-06-17 18:57:53 +03:00
}
2019-06-17 20:25:42 +03:00
2019-06-18 13:56:11 +03:00
// Message is the base type for opaque data
2019-06-22 18:51:20 +03:00
type Message struct {
// Headers which provide local/remote info
Header map[string]string
// The opaque data being sent
Data []byte
}
2019-06-18 13:56:11 +03:00
2019-06-17 20:25:42 +03:00
var (
// TODO: set default network
DefaultNetwork Network
)