- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for Cooper (0.19 sec)
-
cni/pkg/plugin/cnieventclient_test.go
testServer := httptest.NewServer(http.HandlerFunc(func(res http.ResponseWriter, req *http.Request) { res.WriteHeader(http.StatusInternalServerError) res.Write([]byte("server pooped itself")) })) defer func() { testServer.Close() }() cniC := fakeCNIEventClient(testServer.URL) err := PushCNIEvent(cniC, fakeCmdArgs, []*cniv1.IPConfig{&fakePrevResultIPConfig}, "testpod", "testns")
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 4.2K bytes - Viewed (0) -
cni/pkg/install/kubeconfig.go
}, }, CurrentContext: contextName, } lcfg, err := latest.Scheme.ConvertToVersion(kcfg, latest.ExternalVersion) if err != nil { return kubeconfig{}, err } // Convert to v1 schema which has proper encoding fullYaml, err := yaml.Marshal(lcfg) if err != nil { return kubeconfig{}, err } // Log with redaction if err := api.RedactSecrets(kcfg); err != nil { return kubeconfig{}, err }
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Fri Aug 11 01:19:03 GMT 2023 - 4.9K bytes - Viewed (0) -
istioctl/pkg/tag/generate.go
// TODO(Monkeyanator) once we stop using Helm templating remove this. ManifestsPath string // Generate determines whether we should just generate the webhooks without applying. This // applying is not done here, but we are looser with checks when doing generate. Generate bool // Overwrite removes analysis checks around existing webhooks. Overwrite bool // AutoInjectNamespaces controls, if the sidecars should be injected into all namespaces by default.
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Jan 16 17:43:49 GMT 2024 - 13.2K bytes - Viewed (0) -
src/archive/tar/writer.go
} n, err := tw.curr.ReadFrom(r) if err != nil && err != ErrWriteTooLong { tw.err = err } return n, err } // Close closes the tar archive by flushing the padding, and writing the footer. // If the current file (from a prior call to [Writer.WriteHeader]) is not fully written, // then this returns an error. func (tw *Writer) Close() error { if tw.err == ErrWriteAfterClose { return nil }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Oct 13 18:36:46 GMT 2023 - 19.6K bytes - Viewed (0) -
cmd/xl-storage.go
if err != nil && err != errFileNotFound { return err } defer metaDataPoolPut(buf) var xlMeta xlMetaV2 if !isXL2V1Format(buf) { // This is both legacy and without proper version. if err = xlMeta.AddVersion(fi); err != nil { return err } buf, err = xlMeta.AppendTo(metaDataPoolGet()) defer metaDataPoolPut(buf) if err != nil { return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0) -
cmd/xl-storage_unix_test.go
// returns file mode creation mask. func getUmask() int { mask := syscall.Umask(0) syscall.Umask(mask) return mask } // Tests if the directory and file creations happen with proper umask. func TestIsValidUmaskVol(t *testing.T) { tmpPath := t.TempDir() testCases := []struct { volName string expectedUmask int }{ {"is-this-valid", getUmask()}, } testCase := testCases[0]
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jul 25 19:37:26 GMT 2022 - 3.4K bytes - Viewed (0) -
cni/pkg/plugin/plugin.go
} return loggingOptions } // CmdAdd is called for ADD requests func CmdAdd(args *skel.CmdArgs) (err error) { // Defer a panic recover, so that in case if panic we can still return // a proper error to the runtime. defer func() { if e := recover(); e != nil { msg := fmt.Sprintf("istio-cni panicked during cmdAdd: %v\n%v", e, string(debug.Stack())) if err != nil {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 10.4K bytes - Viewed (0) -
cmd/object-handlers_test.go
}, // Test case - 10. // Case with proper components { bucketName: bucketName, objectName: "etc/path/proper/.../etc", byteRange: "", accessKey: credentials.AccessKey, secretKey: credentials.SecretKey, expectedContent: encodeResponse(getAPIErrorResponse(ctx, getAPIError(ErrNoSuchKey), getGetObjectURL("", bucketName, "etc/path/proper/.../etc"), "", "")),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 160K bytes - Viewed (0) -
internal/config/errors.go
`Use 'sudo setcap cap_net_bind_service=+ep /path/to/minio' to provide sufficient permissions`, ) ErrTLSReadError = newErrFn( "Cannot read the TLS certificate", "Please check if the certificate has the proper owner and read permissions", "", ) ErrTLSUnexpectedData = newErrFn( "Invalid TLS certificate", "Please check your certificate", "", ) ErrTLSNoPassword = newErrFn(
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 18 22:25:32 GMT 2024 - 9.1K bytes - Viewed (0) -
cmd/erasure-sets.go
func (s *erasureSets) Legacy() (ok bool) { return s.distributionAlgo == formatErasureVersionV2DistributionAlgoV1 } // connectDisks - attempt to connect all the endpoints, loads format // and re-arranges the disks in proper position. func (s *erasureSets) connectDisks() { defer func() { s.lastConnectDisksOpTime = time.Now() }() var wg sync.WaitGroup diskMap := s.getDiskMap()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 37.7K bytes - Viewed (5)