- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 132 for neil (0.15 sec)
-
cmd/warm-backend-minio.go
// Validation of credentials if conf.AccessKey == "" || conf.SecretKey == "" { return nil, errors.New("both access and secret keys are required") } if conf.Bucket == "" { return nil, errors.New("no bucket name was provided") } u, err := url.Parse(conf.Endpoint) if err != nil { return nil, err } creds := credentials.NewStaticV4(conf.AccessKey, conf.SecretKey, "")
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 3.8K bytes - Viewed (0) -
cmd/storage-datatypes_gen.go
if err != nil { return } err = en.WriteBool(z.Recursive) if err != nil { err = msgp.WrapError(err, "Recursive") return } // write "i" err = en.Append(0xa1, 0x69) if err != nil { return } err = en.WriteBool(z.Immediate) if err != nil { err = msgp.WrapError(err, "Immediate") return } // write "u" err = en.Append(0xa1, 0x75) if err != nil { return }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 127.5K bytes - Viewed (0) -
cmd/site-replication.go
objAPI := newObjectLayerFn() if objAPI == nil { return errServerNotInitialized } if globalDNSConfig != nil { if err := globalDNSConfig.Delete(bucket); err != nil { return err } } err := objAPI.DeleteBucket(ctx, bucket, opts) if err != nil { if globalDNSConfig != nil { if err2 := globalDNSConfig.Put(bucket); err2 != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
migrator/migrator.go
return err } } } for _, idx := range parseIndexes { if !queryTx.Migrator().HasIndex(value, idx.Name) { if err := execTx.Migrator().CreateIndex(value, idx.Name); err != nil { return err } } } return nil }); err != nil { return err } } }
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Fri Apr 26 07:15:49 GMT 2024 - 29K bytes - Viewed (0) -
cmd/metacache-entries.go
if e.isDir() { return nil, errFileNotFound } if e.cached == nil { if len(e.metadata) == 0 { // only happens if the entry is not found. return nil, errFileNotFound } var xl xlMetaV2 err := xl.LoadOrConvert(e.metadata) if err != nil { return nil, err } e.cached = &xl } return e.cached, nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:43:43 GMT 2024 - 23.2K bytes - Viewed (0) -
cmd/test-utils_test.go
} func TestToErrIsNil(t *testing.T) { if toObjectErr(nil) != nil { t.Errorf("Test expected to return nil, failed instead got a non-nil value %s", toObjectErr(nil)) } if toStorageErr(nil) != nil { t.Errorf("Test expected to return nil, failed instead got a non-nil value %s", toStorageErr(nil)) } ctx := context.Background() if toAPIError(ctx, nil) != noError {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0) -
cmd/endpoint-ellipses.go
patterns, perr := ellipses.FindEllipsesPatterns(arg) if perr != nil { return endpointSet{}, config.ErrInvalidErasureEndpoints(nil).Msg(perr.Error()) } argPatterns[i] = patterns } ep.setIndexes, err = getSetIndexes(args, getTotalSizes(argPatterns), setDriveCount, argPatterns) if err != nil { return endpointSet{}, config.ErrInvalidErasureEndpoints(nil).Msg(err.Error()) } ep.argPatterns = argPatterns
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 14.7K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
config.QPS = 80 config.Burst = 160 }) if err != nil { return nil, fmt.Errorf("failed creating kube config: %v", err) } client, err := kube.NewClient(kube.NewClientConfigForRestConfig(kubeRestConfig), "") if err != nil { return nil, fmt.Errorf("failed creating kube client: %v", err) } return client, nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 7.2K bytes - Viewed (0) -
internal/grid/handlers.go
} func (h *handlers) hasAny(id HandlerID) bool { if !id.valid() { return false } return h.single[id] != nil || h.stateless[id] != nil || h.streams[id] != nil } func (h *handlers) hasSubhandler(id subHandlerID) bool { return h.subSingle[id] != nil || h.subStateless[id] != nil || h.subStreams[id] != nil } // RoundTripper provides an interface for type roundtrip serialization. type RoundTripper interface {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 27.1K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
if openNetns != nil { return openNetns, nil } log.Debug("pod netns was not found, trying to find it using procfs") // this can happen if the pod was dynamically added to the mesh after it was created. // in that case, try finding the netns using procfs. if err := s.rescanPod(pod); err != nil { log.Errorf("error scanning proc: error was %s", err) return nil, err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1)