lib

Documentation

Index

• type Delegator
  • func NewDelegator() Delegator
• type PluginController
  • func (c *PluginController) AddIPMasq(ip, deviceName string) error
  • func (c *PluginController) DelIPMasq(ip, deviceName string) error
  • func (c *PluginController) DelegateAdd(netconf map[string]interface{}) (types.Result, error)
  • func (c *PluginController) DelegateDel(netconf map[string]interface{}) error
• type RuntimeConfig
• type WrapperConfig
  • func LoadWrapperConfig(bytes []byte) (*WrapperConfig, error)

Types

type Delegator

type Delegator interface {
	DelegateAdd(delegatePlugin string, netconf []byte) (types.Result, error)
	DelegateDel(delegatePlugin string, netconf []byte) error
}

func NewDelegator

func NewDelegator() Delegator

type PluginController

type PluginController struct {
	Delegator Delegator
	IPTables  rules.IPTablesAdapter
}

func (*PluginController) AddIPMasq

func (c *PluginController) AddIPMasq(ip, deviceName string) error

func (*PluginController) DelIPMasq

func (c *PluginController) DelIPMasq(ip, deviceName string) error

func (*PluginController) DelegateAdd

func (c *PluginController) DelegateAdd(netconf map[string]interface{}) (types.Result, error)

func (*PluginController) DelegateDel

func (c *PluginController) DelegateDel(netconf map[string]interface{}) error

type RuntimeConfig

type RuntimeConfig struct {
	PortMappings []garden.NetIn      `json:"portMappings"`
	NetOutRules  []garden.NetOutRule `json:"netOutRules"`
}

type WrapperConfig

type WrapperConfig struct {
	Datastore                     string                 `json:"datastore"`
	IPTablesLockFile              string                 `json:"iptables_lock_file"`
	Delegate                      map[string]interface{} `json:"delegate"`
	InstanceAddress               string                 `json:"instance_address"`
	DNSServers                    []string               `json:"dns_servers"`
	IPTablesASGLogging            bool                   `json:"iptables_asg_logging"`
	IPTablesC2CLogging            bool                   `json:"iptables_c2c_logging"`
	IPTablesDeniedLogsPerSec      int                    `json:"iptables_denied_logs_per_sec" validate:"min=1"`
	IPTablesAcceptedUDPLogsPerSec int                    `json:"iptables_accepted_udp_logs_per_sec" validate:"min=1"`
	IngressTag                    string                 `json:"ingress_tag"`
	VTEPName                      string                 `json:"vtep_name"`
	RuntimeConfig                 RuntimeConfig          `json:"runtimeConfig,omitempty"`
}

func LoadWrapperConfig

func LoadWrapperConfig(bytes []byte) (*WrapperConfig, error)