- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 87 for fmtF (0.18 sec)
-
internal/grid/connection.go
var r connectResp err = c.receive(conn, &r) if err != nil { if debugPrint { fmt.Println(c.Local, "receive err:", err, "side:", c.side) } retry(err) continue } if debugPrint { fmt.Println(c.Local, "Got connectResp:", r) } if !r.Accepted { retry(fmt.Errorf("connection rejected: %s", r.RejectedReason)) continue } c.reconnectMu.Lock()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 44.8K bytes - Viewed (0) -
internal/grid/manager.go
defer func() { if debugPrint { fmt.Printf("grid: Handler returning from: %v %v\n", req.Method, req.URL) } if r := recover(); r != nil { debug.PrintStack() err := fmt.Errorf("grid: panic: %v\n", r) gridLogIf(context.Background(), err, err.Error()) w.WriteHeader(http.StatusInternalServerError) } }() if debugPrint { fmt.Printf("grid: Got a %s request for: %v\n", req.Method, req.URL)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 17:40:33 UTC 2024 - 9.8K bytes - Viewed (0) -
internal/grid/muxclient.go
func (m *muxClient) response(seq uint32, r Response) { if debugReqs { fmt.Println(m.MuxID, m.parent.String(), "RESP") } if debugPrint { fmt.Printf("mux %d: got msg seqid %d, payload length: %d, err:%v\n", m.MuxID, seq, len(r.Msg), r.Err) } if !m.checkSeq(seq) { if debugReqs { fmt.Println(m.MuxID, m.parent.String(), "CHECKSEQ FAIL", m.RecvSeq, seq) } PutByteBuffer(r.Msg)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.9K bytes - Viewed (0) -
cmd/signature-v4_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "fmt" "net/http" "net/url" "os" "testing" "time" ) func niceError(code APIErrorCode) string { // Special-handle ErrNone if code == ErrNone { return "ErrNone" } return fmt.Sprintf("%s (%s)", errorCodes[code].Code, errorCodes[code].Description) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 10.5K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/phases/init/certs.go
} func newCertSubPhase(certSpec *certsphase.KubeadmCert, run func(c workflow.RunData) error) workflow.Phase { phase := workflow.Phase{ Name: certSpec.Name, Short: fmt.Sprintf("Generate the %s", certSpec.LongName), Long: fmt.Sprintf( genericLongDesc, certSpec.LongName, certSpec.BaseName, getSANDescription(certSpec), ), Run: run, InheritFlags: getCertPhaseFlags(certSpec.Name),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 06:35:45 UTC 2024 - 9.8K bytes - Viewed (0) -
internal/kms/config.go
case kmsPresent: if !isPresent(EnvKMSEndpoint) { return false, fmt.Errorf("kms: incomplete configuration for MinIO KMS: missing '%s'", EnvKMSEndpoint) } if !isPresent(EnvKMSEnclave) { return false, fmt.Errorf("kms: incomplete configuration for MinIO KMS: missing '%s'", EnvKMSEnclave) } if !isPresent(EnvKMSDefaultKey) { return false, fmt.Errorf("kms: incomplete configuration for MinIO KMS: missing '%s'", EnvKMSDefaultKey)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Jun 12 14:31:26 UTC 2024 - 13.9K bytes - Viewed (0) -
tests/integration/telemetry/api/dashboard_test.go
Start: time.Now().Add(-time.Minute), End: time.Now(), Step: time.Second, }) if err != nil { return fmt.Errorf("failure executing query (%s): %v", query, err) } if value == nil { return fmt.Errorf("returned value should not be nil for '%s'", query) } numSamples := 0 switch v := value.(type) { case model.Vector: numSamples = v.Len()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 20:46:28 UTC 2024 - 11.4K bytes - Viewed (0) -
cmd/object-api-options.go
if err != nil { return opts, fmt.Errorf("Unable to parse %s, failed with %w", xhttp.MinIOSourceMTime, err) } } retaintimeStr := strings.TrimSpace(hdr.Get(xhttp.MinIOSourceObjectRetentionTimestamp)) var retaintimestmp time.Time if retaintimeStr != "" { retaintimestmp, err = time.Parse(time.RFC3339, retaintimeStr) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 14.3K bytes - Viewed (0) -
pkg/log/options.go
s = DefaultScopeName l = pieces[0] } else if len(pieces) == 2 { s = pieces[0] l = pieces[1] } else { return "", NoneLevel, fmt.Errorf("invalid output level format '%s'", sl) } level, ok := stringToLevel[l] if !ok { return "", NoneLevel, fmt.Errorf("invalid output level '%s'", sl) } return s, level, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 07 04:04:34 UTC 2024 - 10.6K bytes - Viewed (0) -
pilot/pkg/bootstrap/certcontroller.go
certChain, keyPEM, err = s.CA.GenKeyCert(s.dnsNames, SelfSignedCACertTTL.Get(), false) if err != nil { return fmt.Errorf("failed generating istiod key cert %v", err) } log.Infof("Generating istiod-signed cert for %v:\n %s", s.dnsNames, certChain) fileBundle, err := detectSigningCABundle() if err != nil { return fmt.Errorf("unable to determine signing file format %v", err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 11.3K bytes - Viewed (0)