capture

Mar 13, 2024

Changes in this version

+ type CaptureJobNumExceedLimitError struct

+ CurrentNum int

+ Limit int

+ func (err CaptureJobNumExceedLimitError) Error() string

+ type CaptureManager struct

+ func NewCaptureManager(logger *log.ZapLogger, tel telemetry.Telemetry) *CaptureManager

+ func (cm *CaptureManager) CaptureNetwork(sigChan <-chan os.Signal) (string, error)

+ func (cm *CaptureManager) Cleanup() error

+ func (cm *CaptureManager) OutputCapture(srcDir string) error

+ type CaptureTarget struct

+ CaptureNodeInterface bool

+ OS string

+ PodIpAddresses []string

+ type CaptureTargetsOnNode map[string]CaptureTarget

+ func (cton CaptureTargetsOnNode) AddNodeInterface(hostname string)

+ func (cton CaptureTargetsOnNode) AddPod(hostname string, ipAddresses []string)

+ func (cton CaptureTargetsOnNode) UpdateNodeOS(hostname string, os string)

+ type CaptureToPodTranslator struct

+ Apiserver string

+ func NewCaptureToPodTranslator(kubeClient kubernetes.Interface, logger *log.ZapLogger, ...) *CaptureToPodTranslator

+ func (translator *CaptureToPodTranslator) CalculateCaptureTargetsOnNode(captureTarget retinav1alpha1.CaptureTarget) (*CaptureTargetsOnNode, error)

+ func (translator *CaptureToPodTranslator) ObtainCaptureJobPodEnv(capture retinav1alpha1.Capture) (map[string]string, error)

+ func (translator *CaptureToPodTranslator) TranslateCaptureToJobs(capture *retinav1alpha1.Capture) ([]*batchv1.Job, error)

+ type SecretNotFoundError struct

+ Namespace string

+ SecretName string

+ func (err SecretNotFoundError) Error() string