- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 293 for OK (0.14 sec)
-
cmd/warm-backend-azure.go
if conf.IsSPEnabled() { credential, err = newCredentialFromSP(conf) } else { credential, err = azblob.NewSharedKeyCredential(conf.AccountName, conf.AccountKey) } if err != nil { if _, ok := err.(base64.CorruptInputError); ok { return nil, errors.New("invalid Azure credentials") } return nil, err } p := azblob.NewPipeline(credential, azblob.PipelineOptions{}) var u *url.URL if conf.Endpoint != "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 05 16:44:08 GMT 2024 - 7.8K bytes - Viewed (1) -
operator/cmd/mesh/profile-dump.go
decoded = make([]any, 0) } else { decoded = map[string]any{} } if err := json.Unmarshal(uglyJSON, &decoded); err != nil { return []string{}, err } if d, ok := decoded.(map[string]any); ok { if v, ok := d["spec"]; ok { // Fall back to showing the entire spec. // (When --config-path is used there will be no spec to remove) decoded = v } } setflags, err := walk("", "", decoded)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 7.1K bytes - Viewed (0) -
cmd/sftp-server-driver.go
FilePut: handler, FileCmd: handler, FileList: handler, } } func (f *sftpDriver) getMinIOClient() (*minio.Client, error) { ui, ok := globalIAMSys.GetUser(context.Background(), f.AccessKey()) if !ok && !globalIAMSys.LDAPConfig.Enabled() { return nil, errNoSuchUser } if !ok && globalIAMSys.LDAPConfig.Enabled() { sa, _, err := globalIAMSys.getServiceAccount(context.Background(), f.AccessKey())
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 12:23:42 GMT 2024 - 12.9K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/posix/posix_filesystem.cc
TF_SetStatusFromIOError(status, errno, dst); else TF_SetStatus(status, TF_OK, ""); } static void PathExists(const TF_Filesystem* filesystem, const char* path, TF_Status* status) { if (access(path, F_OK) != 0) TF_SetStatusFromIOError(status, errno, path); else TF_SetStatus(status, TF_OK, ""); } static void Stat(const TF_Filesystem* filesystem, const char* path,
C++ - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Sun Mar 24 20:08:23 GMT 2024 - 15.8K bytes - Viewed (0) -
cmd/tier.go
config.Lock() defer config.Unlock() var ok bool // Lookup in-memory drivercache d, ok = config.drivercache[tierName] if ok { return d, nil } // Initialize driver from tier config matching tierName t, ok := config.Tiers[tierName] if !ok { return nil, errTierNotFound } d, err = newWarmBackend(ctx, t, false) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 15.5K bytes - Viewed (0) -
cmd/metrics.go
gatherers := prometheus.Gatherers{ prometheus.DefaultGatherer, registry, } return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { tc, ok := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt) if ok { tc.FuncName = "handler.MetricsLegacy" tc.ResponseRecorder.LogErrBody = true } mfs, err := gatherers.Gather() if err != nil { if len(mfs) == 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 06:48:36 GMT 2024 - 16.9K bytes - Viewed (0) -
cmd/erasure-server-pool.go
} // let's the rest shutdown } return nil } // Legacy returns 'true' if distribution algo is CRCMOD func (z *erasureServerPools) Legacy() (ok bool) { ok = true for _, set := range z.serverPools { ok = ok && set.Legacy() } return ok } func (z *erasureServerPools) BackendInfo() (b madmin.BackendInfo) { b.Type = madmin.Erasure
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns.go
fi, err := fs.Stat(proc, netnsName) if err != nil { return nil, err } inode, err := GetInode(fi) if err != nil { return nil, err } if _, ok := netnsObserved[inode]; ok { log.Debugf("netns: %d already processed. skipping", inode) return nil, nil } cgroup, err := proc.Open(path.Join(entry.Name(), "cgroup")) if err != nil { return nil, nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 11K bytes - Viewed (0) -
cmd/xl-storage-free-version.go
// no tiered content, it returns false. func (j xlMetaV2Object) InitFreeVersion(fi FileInfo) (xlMetaV2Version, bool) { if fi.SkipTierFreeVersion() { return xlMetaV2Version{}, false } if status, ok := j.MetaSys[ReservedMetadataPrefixLower+TransitionStatus]; ok && bytes.Equal(status, []byte(lifecycle.TransitionComplete)) { vID, err := uuid.Parse(fi.TierFreeVersionID()) if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Mar 02 05:11:03 GMT 2024 - 3.4K bytes - Viewed (0) -
cmd/tier-sweeper.go
// // if gerr == nil { // os.SetTransitionState(goi) // } // // // After the overwriting object operation is complete. // // if jentry, ok := os.ShouldRemoveRemoteObject(); ok { // err := globalTierJournal.AddEntry(jentry) // logger.LogIf(ctx, err) // } type objSweeper struct { Object string Bucket string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 4.7K bytes - Viewed (0)