daemon

Documentation

Index

• Constants
• func WithClient(client *rest.Config) func(*HostSideManager)
• func WithPathManager(pathManager utils.PathManager) func(*DpuSideManager)
• func WithPathManager2(pathManager *utils.PathManager) func(*HostSideManager)
• func WithSriovManager(manager sriov.Manager) func(*HostSideManager)
• type Daemon
  • func NewDaemon(fs afero.Fs, p platform.Platform, config *rest.Config, ...) Daemon
  • func (d *Daemon) Prepare() error
  • func (d *Daemon) PrepareAndServe(ctx context.Context) error
  • func (d *Daemon) Serve(ctx context.Context) error
  • func (d *Daemon) SyncDpuCRs() error
  • func (d *Daemon) WithNodeName(nodeName string) *Daemon
• type DpuSideManager
  • func NewDpuSideManager(vsp plugin.VendorPlugin, config *rest.Config, opts ...func(*DpuSideManager)) (*DpuSideManager, error)
  • func (s *DpuSideManager) CreateBridgePort(context context.Context, bpr *pb.CreateBridgePortRequest) (*pb.BridgePort, error)
  • func (s *DpuSideManager) DeleteBridgePort(context context.Context, bpr *pb.DeleteBridgePortRequest) (*emptypb.Empty, error)
  • func (d *DpuSideManager) Listen() (net.Listener, error)
  • func (d *DpuSideManager) ListenAndServe(ctx context.Context) error
  • func (d *DpuSideManager) Serve(ctx context.Context, listener net.Listener) error
  • func (d *DpuSideManager) SetupDevices() error
  • func (d *DpuSideManager) StartVsp(ctx context.Context) error
• type HostSideManager
  • func NewHostSideManager(vsp plugin.VendorPlugin, opts ...func(*HostSideManager)) (*HostSideManager, error)
  • func (d *HostSideManager) CreateBridgePort(pf int, vf int, vlan int, mac string) (*pb.BridgePort, error)
  • func (d *HostSideManager) DeleteBridgePort(pf int, vf int, vlan int, mac string) error
  • func (d *HostSideManager) Listen() (net.Listener, error)
  • func (d *HostSideManager) ListenAndServe(ctx context.Context) error
  • func (d *HostSideManager) Serve(ctx context.Context, listener net.Listener) error
  • func (d *HostSideManager) SetupDevices() error
  • func (d *HostSideManager) StartVsp(ctx context.Context) error
  • func (d *HostSideManager) WithManager(manager ctrl.Manager) *HostSideManager
• type ManagedDpu
• type SideManager

Constants

const DpuSideLabelKey = "dpu.config.openshift.io/dpuside"

Functions

func WithClient

func WithClient(client *rest.Config) func(*HostSideManager)

func WithPathManager

func WithPathManager(pathManager utils.PathManager) func(*DpuSideManager)

func WithPathManager2

func WithPathManager2(pathManager *utils.PathManager) func(*HostSideManager)

func WithSriovManager

func WithSriovManager(manager sriov.Manager) func(*HostSideManager)

Types

type Daemon

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

func NewDaemon

func NewDaemon(fs afero.Fs, p platform.Platform, config *rest.Config, imageManager images.ImageManager, pathManager *utils.PathManager, nodeName string) Daemon

func (*Daemon) Prepare

func (d *Daemon) Prepare() error

func (*Daemon) PrepareAndServe

func (d *Daemon) PrepareAndServe(ctx context.Context) error

func (*Daemon) Serve

func (d *Daemon) Serve(ctx context.Context) error

func (*Daemon) SyncDpuCRs

func (d *Daemon) SyncDpuCRs() error

func (*Daemon) WithNodeName

func (d *Daemon) WithNodeName(nodeName string) *Daemon

type DpuSideManager

type DpuSideManager struct {
	pb.UnimplementedBridgePortServiceServer
	pb2.UnimplementedDeviceServiceServer
	// contains filtered or unexported fields
}

func NewDpuSideManager

func NewDpuSideManager(vsp plugin.VendorPlugin, config *rest.Config, opts ...func(*DpuSideManager)) (*DpuSideManager, error)

func (*DpuSideManager) CreateBridgePort

func (s *DpuSideManager) CreateBridgePort(context context.Context, bpr *pb.CreateBridgePortRequest) (*pb.BridgePort, error)

func (*DpuSideManager) DeleteBridgePort

func (s *DpuSideManager) DeleteBridgePort(context context.Context, bpr *pb.DeleteBridgePortRequest) (*emptypb.Empty, error)

func (*DpuSideManager) Listen

func (d *DpuSideManager) Listen() (net.Listener, error)

func (*DpuSideManager) ListenAndServe

func (d *DpuSideManager) ListenAndServe(ctx context.Context) error

func (*DpuSideManager) Serve

func (d *DpuSideManager) Serve(ctx context.Context, listener net.Listener) error

func (*DpuSideManager) SetupDevices

func (d *DpuSideManager) SetupDevices() error

func (*DpuSideManager) StartVsp

func (d *DpuSideManager) StartVsp(ctx context.Context) error

type HostSideManager

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

func NewHostSideManager

func NewHostSideManager(vsp plugin.VendorPlugin, opts ...func(*HostSideManager)) (*HostSideManager, error)

func (*HostSideManager) CreateBridgePort

func (d *HostSideManager) CreateBridgePort(pf int, vf int, vlan int, mac string) (*pb.BridgePort, error)

func (*HostSideManager) DeleteBridgePort

func (d *HostSideManager) DeleteBridgePort(pf int, vf int, vlan int, mac string) error

func (*HostSideManager) Listen

func (d *HostSideManager) Listen() (net.Listener, error)

func (*HostSideManager) ListenAndServe

func (d *HostSideManager) ListenAndServe(ctx context.Context) error

func (*HostSideManager) Serve

func (d *HostSideManager) Serve(ctx context.Context, listener net.Listener) error

func (*HostSideManager) SetupDevices

func (d *HostSideManager) SetupDevices() error

func (*HostSideManager) StartVsp

func (d *HostSideManager) StartVsp(ctx context.Context) error

func (*HostSideManager) WithManager

func (d *HostSideManager) WithManager(manager ctrl.Manager) *HostSideManager

type ManagedDpu

type ManagedDpu struct {
	DpuCR   *configv1.DataProcessingUnit
	Plugin  *plugin.GrpcPlugin
	Manager SideManager
}

ManagedDpu represents a DPU with all its runtime state and management components

type SideManager

type SideManager interface {
	StartVsp(ctx context.Context) error
	SetupDevices() error
	Listen() (net.Listener, error)
	Serve(ctx context.Context, listen net.Listener) error
}