- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 32 for Dynamic (0.15 sec)
-
cmd/dynamic-timeouts.go
func newDynamicTimeoutWithOpts(opts dynamicTimeoutOpts) *dynamicTimeout { dt := newDynamicTimeout(opts.timeout, opts.minimum) dt.retryInterval = opts.retryInterval return dt } // newDynamicTimeout returns a new dynamic timeout initialized with timeout value func newDynamicTimeout(timeout, minimum time.Duration) *dynamicTimeout { if timeout <= 0 || minimum <= 0 { panic("newDynamicTimeout: negative or zero timeout") }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Aug 19 23:21:05 GMT 2022 - 4.5K bytes - Viewed (0) -
cmd/dynamic-timeouts_test.go
Harshavardhana <******@****.***> 1665742120 -0700
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Oct 14 10:08:40 GMT 2022 - 5.4K bytes - Viewed (0) -
cmd/admin-handlers-config-kv.go
writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } dynamic := config.SubSystemsDynamic.Contains(subSys) if dynamic { applyDynamic(ctx, objectAPI, cfg, subSys, r, w) if subSys == config.SubnetSubSys && loggerWebhookProxyDeleted { // Logger webhook proxy deleted, apply the dynamic changes applyDynamic(ctx, objectAPI, cfg, config.LoggerWebhookSubSys, r, w) } } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.7K bytes - Viewed (0) -
cni/pkg/nodeagent/netns_linux_test.go
import "testing" func TestOpenNetns(t *testing.T) { ns, err := OpenNetns("/proc/self/ns/net") if err != nil { t.Fatalf("unexpected error: %v", err) } // the inode for netns is proc dynamic, so it needs to be higher than // #define PROC_DYNAMIC_FIRST 0xF0000000U if ns.Inode() < 0xF0000000 { t.Fatalf("unexpected inode: %v", ns.Inode()) } defer ns.Close()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 976 bytes - Viewed (0) -
istioctl/pkg/wait/wait_test.go
watch.(addObject).Add(object) } } return true, watch, nil }) k.Dynamic().Resource(gvr.VirtualService).Namespace("default").Create(context.Background(), newUnstructured("networking.istio.io/v1alpha3", "virtualservice", "default", "foo", int64(1)), metav1.CreateOptions{}) k.Dynamic().Resource(gvr.VirtualService).Namespace("default").Create(context.Background(),
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 08:28:50 GMT 2024 - 6.8K bytes - Viewed (1) -
cmd/config-current.go
if err != nil { configLogIf(ctx, fmt.Errorf("Unable to initialize lambda target(s): %w", err)) } bootstrapTraceMsg("applying the dynamic configuration") // Apply dynamic config values if err := applyDynamicConfig(ctx, objAPI, s); err != nil { configLogIf(ctx, err) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 30.8K bytes - Viewed (0) -
cmd/license-update.go
if err != nil { internalLogIf(ctx, fmt.Errorf("error setting subnet license config: %w", err)) return } if result.Dynamic { if err := applyDynamicConfigForSubSys(GlobalContext, objectAPI, result.Cfg, result.SubSys); err != nil { subnetLogIf(ctx, fmt.Errorf("error applying subnet dynamic config: %w", err)) return } globalNotificationSys.SignalConfigReload(result.SubSys) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 3.3K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/configdump.go
func (c *ConfigWriter) PrintVersionSummary() error { // TODO return nil } // PrintPodRootCAFromDynamicSecretDump prints just pod's root ca from dynamic secret config dump to the ConfigWriter stdout func (c *ConfigWriter) PrintPodRootCAFromDynamicSecretDump() (string, error) { // TODO return "", nil } func (c *ConfigWriter) tabwriter() *tabwriter.Writer {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 23 21:30:30 GMT 2024 - 2.8K bytes - Viewed (0) -
istioctl/pkg/util/configdump/cluster.go
cluster "github.com/envoyproxy/go-control-plane/envoy/config/cluster/v3" v3 "istio.io/istio/pilot/pkg/xds/v3" ) // GetDynamicClusterDump retrieves a cluster dump with just dynamic active clusters in it func (w *Wrapper) GetDynamicClusterDump(stripVersions bool) (*admin.ClustersConfigDump, error) { clusterDump, err := w.GetClusterConfigDump() if err != nil { return nil, err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Nov 03 08:41:32 GMT 2022 - 2.1K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/certificates.go
} if outputFormat == "yaml" { if out, err = yaml.JSONToYAML(out); err != nil { return err } } fmt.Fprintln(c.Stdout, string(out)) return nil } // PrintSecretSummary prints a summary of dynamic active secrets from the config dump func (c *ConfigWriter) PrintSecretSummary() error { if c.ztunnelDump == nil { return fmt.Errorf("config writer has not been primed") } secretDump := c.ztunnelDump.Certificates
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 25 16:38:16 GMT 2024 - 3.2K bytes - Viewed (0)