network

Documentation

Index

• type Config
• type EndpointManager
• type HCSClient
• type Mtu
• type NetRuleApplier
• type NetworkManager
  • func NewNetworkManager(client HCSClient, applier NetRuleApplier, endpointManager EndpointManager, ...) *NetworkManager
  • func (n *NetworkManager) CreateHostNATNetwork() error
  • func (n *NetworkManager) DeleteHostNATNetwork() error
  • func (n *NetworkManager) Down() error
  • func (n *NetworkManager) Up(inputs UpInputs) (UpOutputs, error)
• type NoNATNetworkError
  • func (e *NoNATNetworkError) Error() string
• type SameNATNetworkNameError
  • func (e *SameNATNetworkNameError) Error() string
• type UpInputs
  • func (u *UpInputs) IsEmpty() bool
• type UpOutputs

Types

type Config

type Config struct {
	MTU                           int      `json:"mtu"`
	NetworkName                   string   `json:"network_name"`
	SubnetRange                   string   `json:"subnet_range"`
	GatewayAddress                string   `json:"gateway_address"`
	DNSServers                    []string `json:"dns_servers"`
	MaximumOutgoingBandwidth      uint64   `json:"maximum_outgoing_bandwidth"`
	DNSSuffix                     []string `json:"search_domains"`
	AllowOutboundTrafficByDefault bool     `json:"allow_outbound_traffic_by_default"`
	WaitTimeoutInSeconds          int      `json:"wait_timeout_in_seconds"`
}

type EndpointManager

type EndpointManager interface {
	Create() (hcsshim.HNSEndpoint, error)
	Delete() error
	ApplyPolicies(hcsshim.HNSEndpoint, []*hcsshim.NatPolicy, []*hcsshim.ACLPolicy) (hcsshim.HNSEndpoint, error)
}

type HCSClient

type HCSClient interface {
	GetHNSNetworkByName(string) (*hcsshim.HNSNetwork, error)
	CreateNetwork(*hcsshim.HNSNetwork, func() (bool, error)) (*hcsshim.HNSNetwork, error)
	DeleteNetwork(*hcsshim.HNSNetwork) (*hcsshim.HNSNetwork, error)
}

type Mtu

type Mtu interface {
	SetNat(int) error
	SetContainer(int) error
}

type NetRuleApplier

type NetRuleApplier interface {
	In(netrules.NetIn, string) (*hcsshim.NatPolicy, *hcsshim.ACLPolicy, error)
	Out(netrules.NetOut, string) (*hcsshim.ACLPolicy, error)
	Cleanup() error
	OpenPort(port uint32) error
}

type NetworkManager

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

func NewNetworkManager

func NewNetworkManager(client HCSClient, applier NetRuleApplier, endpointManager EndpointManager, containerId string, config Config, mtu Mtu) *NetworkManager

func (*NetworkManager) CreateHostNATNetwork

func (n *NetworkManager) CreateHostNATNetwork() error

func (*NetworkManager) DeleteHostNATNetwork

func (n *NetworkManager) DeleteHostNATNetwork() error

func (*NetworkManager) Down

func (n *NetworkManager) Down() error

func (*NetworkManager) Up

func (n *NetworkManager) Up(inputs UpInputs) (UpOutputs, error)

type NoNATNetworkError

type NoNATNetworkError struct {
	Name string
}

func (*NoNATNetworkError) Error

func (e *NoNATNetworkError) Error() string

type SameNATNetworkNameError

type SameNATNetworkNameError struct {
	Name    string
	Subnets []hcsshim.Subnet
}

func (*SameNATNetworkNameError) Error

func (e *SameNATNetworkNameError) Error() string

type UpInputs

type UpInputs struct {
	Pid        int
	Properties map[string]interface{}
	NetOut     []netrules.NetOut `json:"netout_rules"`
	NetIn      []netrules.NetIn  `json:"netin"`
}

func (*UpInputs) IsEmpty

func (u *UpInputs) IsEmpty() bool

type UpOutputs

type UpOutputs struct {
	Properties struct {
		ContainerIP      string `json:"garden.network.container-ip"`
		DeprecatedHostIP string `json:"garden.network.host-ip"`
		MappedPorts      string `json:"garden.network.mapped-ports"`
	} `json:"properties"`
	DNSServers []string `json:"dns_servers,omitempty"`
}