- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for newWorkloadManager (0.41 sec)
-
pkg/test/framework/components/echo/kube/workload_manager.go
ctx resource.Context grpcPort uint16 tls *echoCommon.TLSSettings closing bool stopCh chan struct{} handler workloadHandler } func newWorkloadManager(ctx resource.Context, cfg echo.Config, handler workloadHandler) (*workloadManager, error) { // Get the gRPC port and TLS settings. var grpcInstancePort int var tls *echoCommon.TLSSettings if cfg.IsProxylessGRPC() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 02:12:37 UTC 2023 - 6.4K bytes - Viewed (0) -
pkg/test/framework/components/echo/kube/instance.go
} // Deploy echo to the cluster c.deployment, err = newDeployment(ctx, cfg) if err != nil { return nil, err } // Create the manager for echo workloads for this instance. c.workloadMgr, err = newWorkloadManager(ctx, cfg, c.deployment) if err != nil { return nil, err } // Now that we have the successfully created the workload manager, track this resource so // that it will be closed when it goes out of scope.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 16 18:55:23 UTC 2023 - 9K bytes - Viewed (0)