Documentation ¶
Index ¶
- func NewEtcdSubnetRegistry(config *EtcdConfig) (api.SubnetRegistry, error)
- type EtcdConfig
- type EtcdSubnetRegistry
- func (sub *EtcdSubnetRegistry) CheckEtcdIsAlive(seconds uint64) bool
- func (sub *EtcdSubnetRegistry) CreateNode(nodeName string, data string) error
- func (sub *EtcdSubnetRegistry) CreateSubnet(nodeName string, subnet *api.Subnet) error
- func (sub *EtcdSubnetRegistry) DeleteNetNamespace(name string) error
- func (sub *EtcdSubnetRegistry) DeleteSubnet(nodeName string) error
- func (sub *EtcdSubnetRegistry) GetContainerNetwork() (string, error)
- func (sub *EtcdSubnetRegistry) GetNetNamespace(name string) (api.NetNamespace, error)
- func (sub *EtcdSubnetRegistry) GetNetNamespaces() ([]api.NetNamespace, error)
- func (sub *EtcdSubnetRegistry) GetNodes() (*[]string, error)
- func (sub *EtcdSubnetRegistry) GetSubnet(nodeName string) (*api.Subnet, error)
- func (sub *EtcdSubnetRegistry) GetSubnetLength() (uint64, error)
- func (sub *EtcdSubnetRegistry) GetSubnets() (*[]api.Subnet, error)
- func (sub *EtcdSubnetRegistry) InitNodes() error
- func (sub *EtcdSubnetRegistry) InitSubnets() error
- func (sub *EtcdSubnetRegistry) WatchNamespaces(receiver chan *api.NamespaceEvent, stop chan bool) error
- func (sub *EtcdSubnetRegistry) WatchNetNamespaces(receiver chan *api.NetNamespaceEvent, stop chan bool) error
- func (sub *EtcdSubnetRegistry) WatchNodes(receiver chan *api.NodeEvent, stop chan bool) error
- func (sub *EtcdSubnetRegistry) WatchSubnets(receiver chan *api.SubnetEvent, stop chan bool) error
- func (sub *EtcdSubnetRegistry) WriteNetNamespace(name string, id uint) error
- func (sub *EtcdSubnetRegistry) WriteNetworkConfig(network string, subnetLength uint) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewEtcdSubnetRegistry ¶
func NewEtcdSubnetRegistry(config *EtcdConfig) (api.SubnetRegistry, error)
Types ¶
type EtcdConfig ¶
type EtcdSubnetRegistry ¶
type EtcdSubnetRegistry struct {
// contains filtered or unexported fields
}
func (*EtcdSubnetRegistry) CheckEtcdIsAlive ¶
func (sub *EtcdSubnetRegistry) CheckEtcdIsAlive(seconds uint64) bool
func (*EtcdSubnetRegistry) CreateNode ¶
func (sub *EtcdSubnetRegistry) CreateNode(nodeName string, data string) error
func (*EtcdSubnetRegistry) CreateSubnet ¶
func (sub *EtcdSubnetRegistry) CreateSubnet(nodeName string, subnet *api.Subnet) error
func (*EtcdSubnetRegistry) DeleteNetNamespace ¶
func (sub *EtcdSubnetRegistry) DeleteNetNamespace(name string) error
func (*EtcdSubnetRegistry) DeleteSubnet ¶
func (sub *EtcdSubnetRegistry) DeleteSubnet(nodeName string) error
func (*EtcdSubnetRegistry) GetContainerNetwork ¶
func (sub *EtcdSubnetRegistry) GetContainerNetwork() (string, error)
func (*EtcdSubnetRegistry) GetNetNamespace ¶
func (sub *EtcdSubnetRegistry) GetNetNamespace(name string) (api.NetNamespace, error)
func (*EtcdSubnetRegistry) GetNetNamespaces ¶
func (sub *EtcdSubnetRegistry) GetNetNamespaces() ([]api.NetNamespace, error)
func (*EtcdSubnetRegistry) GetNodes ¶
func (sub *EtcdSubnetRegistry) GetNodes() (*[]string, error)
func (*EtcdSubnetRegistry) GetSubnet ¶
func (sub *EtcdSubnetRegistry) GetSubnet(nodeName string) (*api.Subnet, error)
func (*EtcdSubnetRegistry) GetSubnetLength ¶
func (sub *EtcdSubnetRegistry) GetSubnetLength() (uint64, error)
func (*EtcdSubnetRegistry) GetSubnets ¶
func (sub *EtcdSubnetRegistry) GetSubnets() (*[]api.Subnet, error)
func (*EtcdSubnetRegistry) InitNodes ¶
func (sub *EtcdSubnetRegistry) InitNodes() error
func (*EtcdSubnetRegistry) InitSubnets ¶
func (sub *EtcdSubnetRegistry) InitSubnets() error
func (*EtcdSubnetRegistry) WatchNamespaces ¶
func (sub *EtcdSubnetRegistry) WatchNamespaces(receiver chan *api.NamespaceEvent, stop chan bool) error
func (*EtcdSubnetRegistry) WatchNetNamespaces ¶
func (sub *EtcdSubnetRegistry) WatchNetNamespaces(receiver chan *api.NetNamespaceEvent, stop chan bool) error
func (*EtcdSubnetRegistry) WatchNodes ¶
func (sub *EtcdSubnetRegistry) WatchNodes(receiver chan *api.NodeEvent, stop chan bool) error
func (*EtcdSubnetRegistry) WatchSubnets ¶
func (sub *EtcdSubnetRegistry) WatchSubnets(receiver chan *api.SubnetEvent, stop chan bool) error
func (*EtcdSubnetRegistry) WriteNetNamespace ¶
func (sub *EtcdSubnetRegistry) WriteNetNamespace(name string, id uint) error
func (*EtcdSubnetRegistry) WriteNetworkConfig ¶
func (sub *EtcdSubnetRegistry) WriteNetworkConfig(network string, subnetLength uint) error
Click to show internal directories.
Click to hide internal directories.