Versions in this module Expand all Collapse all v0 v0.1.0 Sep 12, 2022 Changes in this version + func Cleanup(nodes []v1.Node) + func CreateConnection(ip string) (*client, func() error) + func PrintCounters(c pb.CaptureServiceClient, req *pb.CountersRequest, reqCtx *ReqContext) + func PrintHCNLogs(c pb.HCNServiceClient, req *pb.HCNRequest, reqCtx *ReqContext) + func PrintVFPCounters(c pb.CaptureServiceClient, req *pb.VFPCountersRequest, reqCtx *ReqContext) + func RunCaptureStream(c pb.CaptureServiceClient, req *pb.CaptureRequest, reqCtx *ReqContext) + func RunStopCapture(c pb.CaptureServiceClient, reqCtx *ReqContext) + func ValidateIPAddrs(ips []string) error + func ValidateMACAddrs(macs []string) error + func ValidateNodes(nodes []string, winNodes []string) error + func ValidatePktType(pktType string) error + func ValidatePods(pods []string, podNames []string) error + func ValidatePorts(ports []string) error + func ValidateProtocols(protocols []string) error + func ValidateTime(time int32) error + type Node struct + Ip string + Name string + type ReqContext struct + Server Node + Wg *sync.WaitGroup + func (rq *ReqContext) Done()