nri

Documentation

Index

• type NriServer
  • func NewNriServer(opt Options) (*NriServer, error)
  • func (p *NriServer) Configure(config, runtime, version string) (stub.EventMask, error)
  • func (p *NriServer) CreateContainer(pod *api.PodSandbox, container *api.Container) (*api.ContainerAdjustment, []*api.ContainerUpdate, error)
  • func (p *NriServer) RemovePodSandbox(pod *api.PodSandbox) error
  • func (p *NriServer) RunPodSandbox(pod *api.PodSandbox) error
  • func (p *NriServer) Start() error
  • func (p *NriServer) Stop()
  • func (p *NriServer) Synchronize(pods []*api.PodSandbox, containers []*api.Container) ([]*api.ContainerUpdate, error)
  • func (p *NriServer) UpdateContainer(pod *api.PodSandbox, container *api.Container) ([]*api.ContainerUpdate, error)
• type Options
  • func (o Options) Validate() error

Types

type NriServer

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

func NewNriServer

func NewNriServer(opt Options) (*NriServer, error)

func (*NriServer) Configure

func (p *NriServer) Configure(config, runtime, version string) (stub.EventMask, error)

func (*NriServer) CreateContainer

func (p *NriServer) CreateContainer(pod *api.PodSandbox, container *api.Container) (*api.ContainerAdjustment, []*api.ContainerUpdate, error)

func (*NriServer) RemovePodSandbox

func (p *NriServer) RemovePodSandbox(pod *api.PodSandbox) error

func (*NriServer) RunPodSandbox

func (p *NriServer) RunPodSandbox(pod *api.PodSandbox) error

func (*NriServer) Start

func (p *NriServer) Start() error

func (*NriServer) Stop

func (p *NriServer) Stop()

func (*NriServer) Synchronize

func (p *NriServer) Synchronize(pods []*api.PodSandbox, containers []*api.Container) ([]*api.ContainerUpdate, error)

func (*NriServer) UpdateContainer

func (p *NriServer) UpdateContainer(pod *api.PodSandbox, container *api.Container) ([]*api.ContainerUpdate, error)

type Options

type Options struct {
	NriPluginName     string
	NriPluginIdx      string
	NriSocketPath     string
	NriConnectTimeout time.Duration
	// support stop running other hooks once someone failed
	PluginFailurePolicy rmconfig.FailurePolicyType
	// todo: add support for disable stages
	DisableStages map[string]struct{}
	Executor      resourceexecutor.ResourceUpdateExecutor
	BackOff       wait.Backoff
}

func (Options) Validate

func (o Options) Validate() error