registry

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) GetNamespaces() ([]string, error)
  • func (sub *EtcdSubnetRegistry) GetNetNamespace(name string) (api.NetNamespace, error)
  • func (sub *EtcdSubnetRegistry) GetNetNamespaces() ([]api.NetNamespace, error)
  • func (sub *EtcdSubnetRegistry) GetNodes() ([]api.Node, error)
  • func (sub *EtcdSubnetRegistry) GetServices() ([]api.Service, error)
  • func (sub *EtcdSubnetRegistry) GetServicesNetwork() (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) InitServices() 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) WatchServices(receiver chan *api.ServiceEvent, 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, serviceNetwork string) error

Functions

func NewEtcdSubnetRegistry

func NewEtcdSubnetRegistry(config *EtcdConfig) (api.SubnetRegistry, error)

Types

type EtcdConfig

type EtcdConfig struct {
	Endpoints        []string
	Keyfile          string
	Certfile         string
	CAFile           string
	SubnetPath       string
	SubnetConfigPath string
	NodePath         string
}

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) GetNamespaces

func (sub *EtcdSubnetRegistry) GetNamespaces() ([]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() ([]api.Node, error)

func (*EtcdSubnetRegistry) GetServices

func (sub *EtcdSubnetRegistry) GetServices() ([]api.Service, error)

func (*EtcdSubnetRegistry) GetServicesNetwork

func (sub *EtcdSubnetRegistry) GetServicesNetwork() (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) InitServices

func (sub *EtcdSubnetRegistry) InitServices() 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) WatchServices

func (sub *EtcdSubnetRegistry) WatchServices(receiver chan *api.ServiceEvent, 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, serviceNetwork string) error