kubernetes

Documentation

Index

• func InCluster() bool
• type Config
  • func GetConfig(ctx context.Context, params Params) (*Config, error)
  • func (cfg *Config) ExtraRules() rules.RuleSet
  • func (cfg *Config) FlatNetworks() []fw.StaticRoute
  • func (cfg *Config) LAN() fw.Link
  • func (cfg *Config) LANAddr() (a fw.Addr, ok bool)
  • func (cfg *Config) LANHWAddr() net.HardwareAddr
  • func (cfg *Config) Uplink() fw.Link
  • func (cfg *Config) UplinkHWAddr() net.HardwareAddr
• type Coordinator
  • func (c *Coordinator) Run(ctx context.Context, m ha.Member) (err error)
• type Params
  • func ParamsFromFile() (params Params, err error)

Functions

func InCluster

func InCluster() bool

Returns if it seems the current environment is hosted by Kubernetes.

Types

type Config

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

func GetConfig

func GetConfig(ctx context.Context, params Params) (*Config, error)

func (*Config) ExtraRules

func (cfg *Config) ExtraRules() rules.RuleSet

func (*Config) FlatNetworks

func (cfg *Config) FlatNetworks() []fw.StaticRoute

func (*Config) LAN

func (cfg *Config) LAN() fw.Link

func (*Config) LANAddr

func (cfg *Config) LANAddr() (a fw.Addr, ok bool)

func (*Config) LANHWAddr

func (cfg *Config) LANHWAddr() net.HardwareAddr

func (*Config) Uplink

func (cfg *Config) Uplink() fw.Link

func (*Config) UplinkHWAddr

func (cfg *Config) UplinkHWAddr() net.HardwareAddr

type Coordinator

type Coordinator struct {
	// The name of the lock and the namespace to store it in.
	LockName      string
	LockNamespace string

	// These are as defined in
	// k8s.io/client-go/tools/leaderelection.LeaderElectionConfig.
	LeaseDuration time.Duration
	RenewDeadline time.Duration
	RetryPeriod   time.Duration
}

func (*Coordinator) Run

func (c *Coordinator) Run(ctx context.Context, m ha.Member) (err error)

type Params

type Params struct {
	LANNetwork       string   `json:"lanNetwork"`
	LANMACAddress    string   `json:"lanMACAddress"`
	FlatNetworks     []string `json:"flatNetworks"`
	UplinkNetwork    string   `json:"uplinkNetwork"`
	UplinkInterface  string   `json:"uplinkInterface"`
	UplinkMACAddress string   `json:"uplinkMACAddress"`
	UplinkIPAddress  string   `json:"uplinkIPAddress"`
}

func ParamsFromFile

func ParamsFromFile() (params Params, err error)

Reads params from the file `/etc/config/egress.json`.