netpod

Documentation

Index

• func WithCacheCreator(c cacheCreator) option
• func WithMasqueradeAdapter(h masqueradeAdapter) option
• func WithNMStateAdapter(h nmstateAdapter) option
• type NSExecutor
• type NetPod
  • func NewNetPod(vmiNetworks []v1.Network, vmiIfaces []v1.Interface, vmiUID string, ...) NetPod
  • func (n NetPod) Setup() error
• type State
  • func NewState(cache stateCacheReaderWriterDeleter, ns NSExecutor) *State
  • func (s *State) Delete(nets []v1.Network) error
  • func (s *State) PendingStartedFinished(nets []v1.Network) ([]v1.Network, []v1.Network, []v1.Network, error)
  • func (s *State) SetFinished(nets []v1.Network) error
  • func (s *State) SetStarted(nets []v1.Network) error

Functions

func WithCacheCreator

func WithCacheCreator(c cacheCreator) option

func WithMasqueradeAdapter

func WithMasqueradeAdapter(h masqueradeAdapter) option

func WithNMStateAdapter

func WithNMStateAdapter(h nmstateAdapter) option

Types

type NSExecutor

type NSExecutor interface {
	Do(func() error) error
}

type NetPod

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

func NewNetPod

func NewNetPod(vmiNetworks []v1.Network, vmiIfaces []v1.Interface, vmiUID string, podPID, ownerID, queuesCapacity int, state *State, opts ...option) NetPod

func (NetPod) Setup

func (n NetPod) Setup() error

type State

type State struct {
	NSExec NSExecutor
	// contains filtered or unexported fields
}

func NewState

func NewState(cache stateCacheReaderWriterDeleter, ns NSExecutor) *State

func (*State) Delete

func (s *State) Delete(nets []v1.Network) error

func (*State) PendingStartedFinished

func (s *State) PendingStartedFinished(nets []v1.Network) ([]v1.Network, []v1.Network, []v1.Network, error)

func (*State) SetFinished

func (s *State) SetFinished(nets []v1.Network) error

func (*State) SetStarted

func (s *State) SetStarted(nets []v1.Network) error