Documentation ¶
Index ¶
- type DynamicWeightsSpec
- type Spec
- func (s *Spec) GetDownwardData() ([]model.DownwardBackendServer, error)
- func (s *Spec) HasDownwardInterface() bool
- func (s *Spec) HasUpwardInterface() bool
- func (s *Spec) Initialize(globals *model.Globals) error
- func (s *Spec) Name() string
- func (s *Spec) PushUpwardData(data model.UpwardData) error
- func (s *Spec) RunNotificationLoop(notChan chan struct{}, quitChan chan struct{}) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DynamicWeightsSpec ¶
type DynamicWeightsSpec struct { Weight int `yaml:"weight"` MatchLabels map[string]string `yaml:"matchLabels"` }
DynamicWeightsSpec associates a number of matchLabels with a concrete weight All containers matching the labels are given that weight.
type Spec ¶
type Spec struct { MatchLabels map[string]string `yaml:"matchLabels"` DynamicWeights []*DynamicWeightsSpec `yaml:"dynamicWeights,omitempty"` // contains filtered or unexported fields }
Spec is the spec subpart of a service for the docker front proxy plugin
func (*Spec) GetDownwardData ¶
func (s *Spec) GetDownwardData() ([]model.DownwardBackendServer, error)
GetDownwardData queries docker containers by spec and returns a list of ip address/port number endpoints
func (*Spec) HasDownwardInterface ¶
HasDownwardInterface is true, plugin checks local docker containers for new ips
func (*Spec) HasUpwardInterface ¶
HasUpwardInterface is false, does not expose something
func (*Spec) Initialize ¶
Initialize the plugin
func (*Spec) PushUpwardData ¶
func (s *Spec) PushUpwardData(data model.UpwardData) error
func (*Spec) RunNotificationLoop ¶
RunNotificationLoop connects to docker daemon and waits for container events. Each matching event will trigger an update on notCh
Click to show internal directories.
Click to hide internal directories.