- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 117 for rack (0.19 sec)
-
cmd/endpoint-ellipses_test.go
[][]uint64{{16, 16, 16, 16}}, }, true, }, { "http://rack{1...4}.mydomain.minio{1...16}/data", endpointSet{ []ellipses.ArgPattern{ []ellipses.Pattern{ { Prefix: "", Suffix: "/data", Seq: getSequences(1, 16, 0), }, { Prefix: "http://rack", Suffix: ".mydomain.minio", Seq: getSequences(1, 4, 0), },
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Dec 07 09:33:56 GMT 2023 - 15.2K bytes - Viewed (0) -
cmd/admin-handlers-users-race_test.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. //go:build !race // +build !race // Tests in this file are not run under the `-race` flag as they are too slow // and cause context deadline errors. package cmd import ( "context" "fmt" "runtime" "testing" "time"
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 3.9K bytes - Viewed (0) -
cni/pkg/nodeagent/netns_linux.go
defer threadNS.Close() // switch to target namespace if err = NetnsSet(fdable); err != nil { return err } defer func() { err := threadNS.Set() // switch back if err == nil { // Unlock the current thread only when we successfully switched back // to the original namespace; otherwise leave the thread locked which // will force the runtime to scrap the current thread, that is maybe
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Wed Jan 31 10:05:36 GMT 2024 - 2.7K bytes - Viewed (0) -
cni/pkg/repair/repair.go
"istio.io/istio/pkg/kube" "istio.io/istio/pkg/log" ) var repairLog = log.RegisterScope("repair", "CNI race condition repair") func StartRepair(ctx context.Context, cfg config.RepairConfig) { if !cfg.Enabled { repairLog.Info("CNI repair is disable.") return } repairLog.Info("Start CNI race condition repair.") client, err := clientSetup() if err != nil {
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Tue May 23 17:08:31 GMT 2023 - 1.5K bytes - Viewed (0) -
internal/config/lambda/event/event.go
type UserRequest struct { URL string `json:"url"` Headers http.Header `json:"headers"` } // GetObjectContext provides the necessary details to perform // download of the object, and return back the processed response // to the server. type GetObjectContext struct { OutputRoute string `json:"outputRoute"` OutputToken string `json:"outputToken"` InputS3URL string `json:"inputS3Url"` }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Mar 07 16:12:41 GMT 2023 - 2.6K bytes - Viewed (0) -
cmd/admin-handlers-idp-config.go
if err = validateConfig(ctx, cfg, subSys); err != nil { var validationErr ldap.Validation if errors.As(err, &validationErr) { // If we got an LDAP validation error, we need to send appropriate // error message back to client (likely mc). writeCustomErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrAdminConfigLDAPValidation), validationErr.FormatError(), r.URL) return }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.7K bytes - Viewed (0) -
cni/pkg/repair/repair_test_helpers.go
var ( brokenInitContainerWaiting = corev1.ContainerStatus{ Name: constants.ValidationContainerName, State: corev1.ContainerState{ Waiting: &corev1.ContainerStateWaiting{ Reason: "CrashLoopBackOff", Message: "Back-off 5m0s restarting failed blah blah blah", }, }, LastTerminationState: corev1.ContainerState{ Terminated: &corev1.ContainerStateTerminated{ ExitCode: constants.ValidationErrorCode, Reason: "Error",
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri May 12 17:39:53 GMT 2023 - 4.7K bytes - Viewed (0) -
src/archive/tar/writer_test.go
} // Simple test to make sure PAX extensions are in effect if !bytes.Contains(buf.Bytes(), []byte("PaxHeaders.0")) { t.Fatal("Expected at least one PAX header to be written.") } // Test that we can get a long name back out of the archive. reader := NewReader(&buf) hdr, err = reader.Next() if err != nil { t.Fatal(err) } if hdr.Name != longName { t.Fatal("Couldn't recover long file name") } }
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Tue Feb 27 16:39:23 GMT 2024 - 38.7K bytes - Viewed (0) -
internal/s3select/simdj/reader.go
if !ok { dstRec = &Record{} } dstRec.object = v return dstRec, nil } // Close - closes underlying reader. func (r *Reader) Close() error { // Close the input. // Potentially racy if the stream decoder is still reading. if r.readCloser != nil { r.readCloser.Close() } if r.exitReader != nil { close(r.exitReader) r.readerWg.Wait() r.exitReader = nil r.input = nil }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue May 30 17:02:22 GMT 2023 - 4.9K bytes - Viewed (0) -
cmd/metacache.go
"strings" "time" ) type scanStatus uint8 const ( scanStateNone scanStatus = iota scanStateStarted scanStateSuccess scanStateError // Time in which the initiator of a scan must have reported back. metacacheMaxRunningAge = time.Minute // Max time between client calls before dropping an async cache listing. metacacheMaxClientWait = 3 * time.Minute
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 5K bytes - Viewed (0)