network

Documentation

Index

• func ReadConfiguration(reader io.Reader, config *Config) error
• func Register(networkImpl string, allocFn Allocator)
• type Allocator
• type Config
• type NetworkController
• type NetworkFactory
  • func NewNetworkFactory() *NetworkFactory
  • func (f *NetworkFactory) Create(client *client.Client, args []string) NetworkController

Functions

func ReadConfiguration

func ReadConfiguration(reader io.Reader, config *Config) error

func Register

func Register(networkImpl string, allocFn Allocator)

Types

type Allocator

type Allocator func(*client.Client, []string) NetworkController

type Config

type Config struct {
	KubeUrl        string        `gcfg:"master"`
	KubeConfig     string        `gcfg:"kubeconfig"`
	ResyncPeriod   time.Duration `gcfg:"resync-interval"`
	ClusterIpRange string        `gcfg:"service-cluster-ip-range"`
}

type NetworkController

type NetworkController interface {
	Init(global *Config, configFile io.Reader) error

	SetNamespaceStore(store cache.Store)
	AddNamespace(obj *api.Namespace)
	UpdateNamespace(oldObj, newObj *api.Namespace)
	DeleteNamespace(obj *api.Namespace)

	SetPodStore(store cache.Indexer)
	AddPod(obj *api.Pod)
	UpdatePod(oldObj, newObj *api.Pod)
	DeletePod(obj *api.Pod)

	SetReplicationControllerStore(store cache.Store)
	AddReplicationController(obj *api.ReplicationController)
	UpdateReplicationController(oldObj, newObj *api.ReplicationController)
	DeleteReplicationController(obj *api.ReplicationController)

	SetServiceStore(store cache.Store)
	AddService(obj *api.Service)
	UpdateService(oldObj, newObj *api.Service)
	DeleteService(obj *api.Service)

	Run(shutdown chan struct{})
}

type NetworkFactory

type NetworkFactory struct {
}

Placeholder class that constructs a NetworkController

func NewNetworkFactory

func NewNetworkFactory() *NetworkFactory

func (*NetworkFactory) Create

func (f *NetworkFactory) Create(client *client.Client, args []string) NetworkController