- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for loadConfig (0.13 sec)
-
cmd/config-current_test.go
} if err := saveServerConfig(context.Background(), objLayer, globalServerConfig); err != nil { t.Fatalf("Unable to save updated config file %s", err) } // Initialize server config. if err := loadConfig(objLayer, nil); err != nil { t.Fatalf("Unable to initialize from updated config file %s", err) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 16 23:13:47 UTC 2024 - 2K bytes - Viewed (0) -
cmd/config-migrate.go
return quick.SaveConfig(data, configFile, globalEtcdClient) } // Load config from backend func Load(configFile string, data interface{}) (quick.Config, error) { return quick.LoadConfig(configFile, globalEtcdClient, data) } func readConfigWithoutMigrate(ctx context.Context, objAPI ObjectLayer) (config.Config, error) { // Construct path to config.json for the given bucket.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.4K bytes - Viewed (0) -
cmd/kube-proxy/app/server_test.go
config, err := options.loadConfig([]byte(yaml)) assert.NoError(t, err, "unexpected error for %s: %v", tc.name, err) if diff := cmp.Diff(config, expected); diff != "" { t.Fatalf("unexpected config for %s, diff = %s", tc.name, diff) } } } // TestLoadConfigFailures tests failure modes for loadConfig() func TestLoadConfigFailures(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 32.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/generic/webhook.go
// NewWebhook creates a new generic admission webhook. func NewWebhook(handler *admission.Handler, configFile io.Reader, sourceFactory sourceFactory, dispatcherFactory dispatcherFactory) (*Webhook, error) { kubeconfigFile, err := config.LoadConfig(configFile) if err != nil { return nil, err } cm, err := webhookutil.NewClientManager( []schema.GroupVersion{ admissionv1beta1.SchemeGroupVersion, admissionv1.SchemeGroupVersion, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 22:07:40 UTC 2024 - 9.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/config.go
return fmt.Errorf("kmsv2 Provider %s is not healthy, error: %w", h.name, err) } return nil } // loadConfig parses the encryption configuration file at filepath and returns the parsed config and hash of the file. func loadConfig(filepath string, reload bool) (*apiserver.EncryptionConfiguration, string, error) { data, contentHash, err := loadDataAndHash(filepath) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 16:56:39 UTC 2024 - 41.2K bytes - Viewed (0) -
cmd/config-current.go
} func getValidConfig(objAPI ObjectLayer) (config.Config, error) { return readServerConfig(GlobalContext, objAPI, nil) } // loadConfig - loads a new config from disk, overrides params // from env if found and valid // data is optional. If nil it will be loaded from backend. func loadConfig(objAPI ObjectLayer, data []byte) error { bootstrapTraceMsg("load the configuration") srvCfg, err := readServerConfig(GlobalContext, objAPI, data)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 30 08:14:58 UTC 2024 - 30.8K bytes - Viewed (0) -
cmd/kube-proxy/app/server.go
data, err := os.ReadFile(file) if err != nil { return nil, err } return o.loadConfig(data) } // loadConfig decodes a serialized KubeProxyConfiguration to the internal type. func (o *Options) loadConfig(data []byte) (*kubeproxyconfig.KubeProxyConfiguration, error) { configObj, gvk, err := proxyconfigscheme.Codecs.UniversalDecoder().Decode(data, nil, nil)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 13:27:41 UTC 2024 - 46.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/config_test.go
return &testKMSv2EnvelopeService{nil, keyID, 0, nil}, nil } func TestLegacyConfig(t *testing.T) { legacyV1Config := "testdata/valid-configs/legacy.yaml" legacyConfigObject, _, err := loadConfig(legacyV1Config, false) cacheSize := int32(10) if err != nil { t.Fatalf("error while parsing configuration file: %s.\nThe file was:\n%s", err, legacyV1Config) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 16 16:56:39 UTC 2024 - 72.3K bytes - Viewed (0) -
pkg/kube/inject/webhook.go
} func (p ParsedContainers) AllContainers() []corev1.Container { return append(slices.Clone(p.Containers), p.InitContainers...) } // nolint directives: interfacer func loadConfig(injectFile, valuesFile string) (*Config, string, error) { data, err := os.ReadFile(injectFile) if err != nil { return nil, "", err } var c *Config if c, err = unmarshalConfig(data); err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:59:39 UTC 2024 - 42.2K bytes - Viewed (0) -
tensorflow/compiler/mlir/runlit.site.cfg.py
# Configure this to work with msys2, TF's preferred windows bash. config.lit_tools_dir = '/usr/bin' lit.llvm.initialize(lit_config, config) # Let the main config do the real work. lit_config.load_config( config, os.path.join( os.path.join(real_test_srcdir, os.environ['TEST_WORKSPACE'], 'tensorflow/compiler/mlir/runlit.cfg.py')))
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed May 01 21:33:52 UTC 2024 - 3K bytes - Viewed (0)