binding

Jan 6, 2025

Changes in this version

+ type ChanPort struct

+ RXQueue *queue.Queue

+ TXQueue *queue.Queue

+ type Option func(lb *LocalBind)

+ func WithOverridePortManager(mgr *PortMgr) Option

+ type PortMgr struct

+ func (pm *PortMgr) CreateHandle(name string) (common.Port, error)

+ func (pm *PortMgr) GetPort(p *ondatra.Port) *ChanPort

Jun 18, 2024

Changes in this version

+ func KNE(topoDir string) func() (binding.Binding, error)

+ func Local(topoDir string) func() (binding.Binding, error)

+ type LocalBind struct

+ func (lb *LocalBind) Release(context.Context) error

+ func (lb *LocalBind) Reserve(ctx context.Context, tb *opb.Testbed, _, _ time.Duration, _ map[string]string) (*binding.Reservation, error)

Mar 15, 2023

Changes in this version

+ func Get(topoDir string) func() (binding.Binding, error)

+ type LemmingBind struct

+ func (lb *LemmingBind) Release(ctx context.Context) error

+ func (lb *LemmingBind) Reserve(ctx context.Context, tb *proto.Testbed, runTime time.Duration, ...) (*binding.Reservation, error)