- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 42 for defer (0.21 sec)
-
istioctl/pkg/waypoint/waypoint.go
} return err } if waitReady { startTime := time.Now() ticker := time.NewTicker(1 * time.Second) defer ticker.Stop() for range ticker.C { programmed := false gwc, err := kubeClient.GatewayAPI().GatewayV1().Gateways(ctx.NamespaceOrDefault(ctx.Namespace())).Get(context.TODO(), gw.Name, metav1.GetOptions{})
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 19:45:58 GMT 2024 - 15.5K bytes - Viewed (0) -
istioctl/pkg/proxystatus/proxystatus.go
func readConfigFile(filename string) ([]byte, error) { file := os.Stdin if filename != "-" { var err error file, err = os.Open(filename) if err != nil { return nil, err } } defer func() { if err := file.Close(); err != nil { log.Errorf("failed to close %s: %s", filename, err) } }() data, err := io.ReadAll(file) if err != nil { return nil, err } return data, nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 6.2K bytes - Viewed (0) -
common-protos/k8s.io/api/discovery/v1beta1/generated.proto
// serving is identical to ready except that it is set regardless of the // terminating state of endpoints. This condition should be set to true for // a ready endpoint that is terminating. If nil, consumers should defer to // the ready condition. // +optional optional bool serving = 2; // terminating indicates that this endpoint is terminating. A nil value
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 8K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
return "" } return m[constants.DataplaneModeLabel] } func (s *InformerHandlers) reconcilePod(input any) error { event := input.(controllers.Event) pod := event.Latest().(*corev1.Pod) defer EventTotals.With(eventTypeTag.Value(event.Event.String())).Increment() switch event.Event { case controllers.EventAdd: // pod was added to our cache // we get here in 2 cases:
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 9.6K bytes - Viewed (0) -
common-protos/k8s.io/api/discovery/v1/generated.proto
// serving is identical to ready except that it is set regardless of the // terminating state of endpoints. This condition should be set to true for // a ready endpoint that is terminating. If nil, consumers should defer to // the ready condition. // +optional optional bool serving = 2; // terminating indicates that this endpoint is terminating. A nil value
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 8K bytes - Viewed (0) -
common-protos/k8s.io/api/authorization/v1beta1/generated.proto
// drive authorization decisions as this raises confused deputy, cache lifetime/revocation, and correctness concerns. // SubjectAccessReview, and LocalAccessReview are the correct way to defer authorization decisions to the API server. message SelfSubjectRulesReview { // Standard list metadata. // More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#metadata
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 11.9K bytes - Viewed (0) -
common-protos/k8s.io/api/authorization/v1/generated.proto
// drive authorization decisions as this raises confused deputy, cache lifetime/revocation, and correctness concerns. // SubjectAccessReview, and LocalAccessReview are the correct way to defer authorization decisions to the API server. message SelfSubjectRulesReview { // Standard list metadata. // More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#metadata
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 11.9K bytes - Viewed (0) -
cni/cmd/istio-cni/main.go
) func main() { if err := runPlugin(); err != nil { os.Exit(1) } } func runPlugin() error { if err := log.Configure(plugin.GetLoggingOptions("")); err != nil { return err } defer func() { // Log sync will send logs to install-cni container via UDS. // We don't need a timeout here because underlying the log pkg already handles it. // this may fail, but it should be safe to ignore according
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 13:56:46 GMT 2024 - 1.9K bytes - Viewed (0) -
cni/pkg/plugin/plugin.go
} return loggingOptions } // CmdAdd is called for ADD requests func CmdAdd(args *skel.CmdArgs) (err error) { // Defer a panic recover, so that in case if panic we can still return // a proper error to the runtime. defer func() { if e := recover(); e != nil { msg := fmt.Sprintf("istio-cni panicked during cmdAdd: %v\n%v", e, string(debug.Stack())) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 10.5K bytes - Viewed (0) -
istioctl/pkg/authz/authz.go
return cmd } func getConfigDumpFromFile(filename string) (*configdump.Wrapper, error) { file, err := os.Open(filename) if err != nil { return nil, err } defer func() { if err := file.Close(); err != nil { log.Errorf("failed to close %s: %s", filename, err) } }() data, err := io.ReadAll(file) if err != nil { return nil, err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 5K bytes - Viewed (0)