kubernetes

Documentation

Index

• func WatchKubernetes(eclient *etcd.Client)
• type FlagSet
  • func (f *FlagSet) BoolVar(p *bool, name string, value bool, usage string)
  • func (f *FlagSet) DurationVar(p *time.Duration, name string, value time.Duration, usage string)
  • func (f *FlagSet) Float32Var(p *float32, name string, value float32, usage string)
  • func (f *FlagSet) IntVar(p *int, name string, value int, usage string)
  • func (f *FlagSet) StringVar(p *string, name, value, usage string)
  • func (f *FlagSet) UintVar(p *uint, name string, value uint, usage string)
• type KubernetesSync
  • func NewKubernetesSync(client *etcd.Client) *KubernetesSync
  • func (ksync *KubernetesSync) OnUpdate(services []api.Service)

Functions

func WatchKubernetes

func WatchKubernetes(eclient *etcd.Client)

Types

type FlagSet

type FlagSet struct {
}

func (*FlagSet) BoolVar

func (f *FlagSet) BoolVar(p *bool, name string, value bool, usage string)

func (*FlagSet) DurationVar

func (f *FlagSet) DurationVar(p *time.Duration, name string, value time.Duration, usage string)

func (*FlagSet) Float32Var

func (f *FlagSet) Float32Var(p *float32, name string, value float32, usage string)

func (*FlagSet) IntVar

func (f *FlagSet) IntVar(p *int, name string, value int, usage string)

func (*FlagSet) StringVar

func (f *FlagSet) StringVar(p *string, name, value, usage string)

func (*FlagSet) UintVar

func (f *FlagSet) UintVar(p *uint, name string, value uint, usage string)

type KubernetesSync

type KubernetesSync struct {
	// contains filtered or unexported fields
}

func NewKubernetesSync

func NewKubernetesSync(client *etcd.Client) *KubernetesSync

func (*KubernetesSync) OnUpdate

func (ksync *KubernetesSync) OnUpdate(services []api.Service)

OnUpdate manages the active set of service records. Active service records get ttl bumps if found in the update set or removed if missing from the update set.