node

Jun 20, 2025

Changes in this version

+ type Constraints struct

+ CPU string

+ Memory string

type Impl

+ func (n *Impl) DefaultNodeConstraints() Constraints

type Implementation

+ DefaultNodeConstraints func() Constraints

Aug 20, 2024

Changes in this version

+ func GetNodeLinks(n *tpb.Node) ([]topologyv1.Link, error)

type Implementation

+ ValidateConstraints func() error

Dec 14, 2023

Changes in this version

type Impl

+ func (n *Impl) BackToBackLoop() bool

type Implementation

+ BackToBackLoop func() bool

Sep 21, 2023

Changes in this version

type Impl

+ func (n *Impl) String() string

+ func (n *Impl) ValidateConstraints() error

type Interface

+ String func() string

Jun 5, 2023

Changes in this version

+ const OndatraRoleATE

+ const OndatraRoleDUT

+ const OndatraRoleLabel

May 11, 2023

Changes in this version

type Status

+ const ConfigVolumeName

Sep 14, 2022

Changes in this version

+ const DefaultInitContainerImage

Aug 18, 2022

Changes in this version

type Impl

+ func (n *Impl) GetCLIConn(platform string, opts []scrapliutil.Option) (*scraplinetwork.Driver, error)

+ func (n *Impl) PatchCLIConnOpen(bin string, cliCmd []string, opts []scrapliutil.Option) []scrapliutil.Option

+ type Status string

+ const StatusFailed

+ const StatusPending

+ const StatusRunning

+ const StatusUnknown

Jun 29, 2022

Changes in this version

+ func Register(t tpb.Node_Type, fn NewNodeFn)

+ func ToEnvVar(kv map[string]string) []corev1.EnvVar

+ func ToResourceRequirements(kv map[string]string) corev1.ResourceRequirements

+ func Vendor(v tpb.Vendor, fn NewNodeFn)

+ type Certer interface

+ GenerateSelfSigned func(context.Context) error

+ type ConfigPusher interface

+ ConfigPush func(context.Context, io.Reader) error

+ type Impl struct

+ BasePath string

+ KubeClient kubernetes.Interface

+ Kubecfg string

+ Namespace string

+ Proto *tpb.Node

+ RestConfig *rest.Config

+ func (n *Impl) Create(ctx context.Context) error

+ func (n *Impl) CreateConfig(ctx context.Context) error

+ func (n *Impl) CreatePod(ctx context.Context) error

+ func (n *Impl) CreateService(ctx context.Context) error

+ func (n *Impl) Delete(ctx context.Context) error

+ func (n *Impl) DeleteConfig(ctx context.Context) error

+ func (n *Impl) DeleteResource(ctx context.Context) error

+ func (n *Impl) DeleteService(ctx context.Context) error

+ func (n *Impl) Exec(ctx context.Context, cmd []string, stdin io.Reader, stdout io.Writer, ...) error

+ func (n *Impl) GetNamespace() string

+ func (n *Impl) GetProto() *tpb.Node

+ func (n *Impl) Name() string

+ func (n *Impl) Pods(ctx context.Context) ([]*corev1.Pod, error)

+ func (n *Impl) Services(ctx context.Context) ([]*corev1.Service, error)

+ func (n *Impl) Status(ctx context.Context) (NodeStatus, error)

+ func (n *Impl) TopologySpecs(context.Context) ([]*topologyv1.Topology, error)

+ type Implementation interface

+ Create func(context.Context) error

+ Delete func(context.Context) error

+ Pods func(context.Context) ([]*corev1.Pod, error)

+ Services func(context.Context) ([]*corev1.Service, error)

+ Status func(context.Context) (NodeStatus, error)

+ TopologySpecs func(context.Context) ([]*topologyv1.Topology, error)

+ type Interface interface

+ GetNamespace func() string

+ GetProto func() *tpb.Node

+ Name func() string

+ type NewNodeFn func(n *Impl) (Node, error)

+ type Node interface

+ func New(namespace string, pb *tpb.Node, kClient kubernetes.Interface, ...) (Node, error)

+ type NodeStatus string

+ const NODE_FAILED

+ const NODE_PENDING

+ const NODE_RUNNING

+ const NODE_UNKNOWN

+ type Resetter interface

+ ResetCfg func(ctx context.Context) error