- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 131 for Messages (0.17 sec)
-
cmd/object-api-errors.go
Err string } func (e BackendDown) Error() string { return e.Err } // NotImplemented If a feature is not implemented type NotImplemented struct { Message string } func (e NotImplemented) Error() string { return e.Message } // UnsupportedMetadata - unsupported metadata type UnsupportedMetadata struct{} func (e UnsupportedMetadata) Error() string {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 21.3K bytes - Viewed (0) -
cmd/object_api_suite_test.go
} if isErrObjectNotFound(err) { if err.Error() != "Object not found: bucket/dir1" { t.Errorf("%s: Expected the Error message to be `%s`, but instead found `%s`", instanceType, "Object not found: bucket/dir1", err.Error()) } } else { if err.Error() != "fails" { t.Errorf("%s: Expected the Error message to be `%s`, but instead found it to be `%s`", instanceType, "fails", err.Error()) } } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 32.3K bytes - Viewed (0) -
cmd/server_test.go
data, err := io.ReadAll(response.Body) c.Assert(err, nil) errorResponse := APIErrorResponse{} err = xml.Unmarshal(data, &errorResponse) c.Assert(err, nil) c.Assert(errorResponse.Code, code) c.Assert(errorResponse.Message, description) c.Assert(response.StatusCode, statusCode) } func runAllTests(suite *TestSuiteCommon, c *check) { suite.SetUpSuite(c) suite.TestCors(c) suite.TestObjectDir(c) suite.TestBucketPolicy(c)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 108K bytes - Viewed (0) -
cmd/peer-rest-server.go
} if err != nil { return np, grid.NewRemoteErr(err) } default: return np, grid.NewRemoteErr(errUnsupportedSignal) } return np, nil } // ListenHandler sends http trace messages back to peer rest client func (s *peerRESTServer) ListenHandler(ctx context.Context, v *grid.URLValues, out chan<- *grid.Bytes) *grid.RemoteErr { values := v.Values() defer v.Recycle() var prefix string
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0) -
cmd/metacache-set_gen.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 19 20:23:12 GMT 2024 - 13.8K bytes - Viewed (0) -
cmd/object-handlers.go
s3Select, err := s3select.NewS3Select(r.Body) if err != nil { if serr, ok := err.(s3select.SelectError); ok { encodedErrorResponse := encodeResponse(APIErrorResponse{ Code: serr.ErrorCode(), Message: serr.ErrorMessage(), BucketName: bucket, Key: object, Resource: r.URL.Path, RequestID: w.Header().Get(xhttp.AmzRequestID), HostID: globalDeploymentID(), })
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 20:15:54 GMT 2024 - 125.2K bytes - Viewed (0) -
internal/grid/handlers.go
// StatelessHandler is handlers for one to many requests, // where responses may be dropped. // Stateless requests provide no incoming stream and there is no flow control // on outgoing messages. StatelessHandler struct { Handle StatelessHandlerFn // OutCapacity is the output capacity on the caller. // If <= 0 capacity will be 1. OutCapacity int }
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) -
cmd/metrics-v3-cluster-audit.go
"Number of unsent messages in queue for target", targetID) auditTotalMessagesMD = NewCounterMD(auditTotalMessages, "Total number of messages sent since start", targetID) ) // loadClusterAuditMetrics - `MetricsLoaderFn` for cluster audit // such as failed messages and total messages. func loadClusterAuditMetrics(_ context.Context, m MetricValues, c *metricsCache) error { audit := logger.CurrentStats() for id, st := range audit {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 09:18:02 GMT 2024 - 1.9K bytes - Viewed (0) -
cmd/api-response.go
// but accepts the error message directly (this allows messages to be // dynamically generated.) func writeCustomErrorResponseJSON(ctx context.Context, w http.ResponseWriter, err APIError, errBody string, reqURL *url.URL, ) { reqInfo := logger.GetReqInfo(ctx) errorResponse := APIErrorResponse{ Code: err.Code, Message: errBody, Resource: reqURL.Path,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 33.3K bytes - Viewed (2) -
internal/logger/target/types/types.go
) // TargetStats contains statistics for a target. type TargetStats struct { // QueueLength is the queue length if any messages are queued. QueueLength int // TotalMessages is the total number of messages sent in the lifetime of the target TotalMessages int64 // FailedMessages should log message count that failed to send. FailedMessages int64
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Nov 10 18:20:21 GMT 2022 - 1.4K bytes - Viewed (0)