- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 144 for message (0.22 sec)
-
internal/s3select/message.go
207, 151, 211, 146, // message crc. } // newErrorMessage - creates new Request Level Error Message. S3 sends this message if the request failed for any reason. // It contains the error code and error message for the failure. If S3 sends a RequestLevelError message, // it doesn't send an End message. // // Header specification: // Request-level error messages contain three headers, as follows:
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 15.2K bytes - Viewed (0) -
internal/event/errors.go
Queue Queue } func (err ErrDuplicateQueueConfiguration) Error() string { var message string if data, xerr := xml.Marshal(err.Queue); xerr != nil { message = fmt.Sprintf("%+v", err.Queue) } else { message = string(data) } return fmt.Sprintf("duplicate queue configuration %v", message) } // ErrUnknownRegion - unknown region error. type ErrUnknownRegion struct { Region string
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 4.1K bytes - Viewed (0) -
cmd/ftp-server.go
// minioLogger use an instance of this to log in a standard format type minioLogger struct{} // Print implement Logger func (log *minioLogger) Print(sessionID string, message interface{}) { if serverDebugLog { fmt.Printf("%s %s\n", sessionID, message) } } // Printf implement Logger func (log *minioLogger) Printf(sessionID string, format string, v ...interface{}) { if serverDebugLog { if sessionID != "" {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Mar 09 03:07:08 GMT 2024 - 4.8K bytes - Viewed (2) -
internal/deadlineconn/deadlineconn_test.go
t.Errorf("failed to read from client. %v", terr) return } received = string(b) if received != "message two\n" { t.Errorf(`server: expected: "message two\n", got: %v`, received) return } // Send a response. _, terr = io.WriteString(deadlineconn, "messages received\n") if terr != nil { t.Errorf("failed to write to client. %v", terr) return } }() c, err := net.Dial("tcp", serverAddr)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Nov 05 18:09:21 GMT 2022 - 3K bytes - Viewed (0) -
internal/config/errors-utils.go
msg: u.msg, detail: u.detail, action: u.action, hint: u.hint, } } // Error returns the error message func (u Err) Error() string { if u.detail == "" { if u.msg != "" { return u.msg } return "<nil>" } return u.detail } // Msg - Replace the current error's message func (u Err) Msg(m string, args ...interface{}) Err { e := u.Clone() e.msg = fmt.Sprintf(m, args...) return e }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Mar 06 16:56:10 GMT 2023 - 3.7K bytes - Viewed (0) -
internal/logger/logger.go
VersionID: req.VersionID, Objects: objects, }, }, } if trace != nil { entry.Trace = &log.Trace{ Message: message, Source: trace, Variables: tags, } } else { entry.Message = message } if anonFlag { entry.API.Args.Bucket = HashString(entry.API.Args.Bucket) entry.API.Args.Object = HashString(entry.API.Args.Object)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 12.2K bytes - Viewed (0) -
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 Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Nov 10 18:20:21 GMT 2022 - 1.4K bytes - Viewed (0) -
cmd/object-api-datatypes_gen.go
if err != nil { err = msgp.WrapError(err) return } (*z) = BackendType(zb0001) } o = bts return } // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message func (z BackendType) Msgsize() (s int) { s = msgp.IntSize return } // MarshalMsg implements msgp.Marshaler func (z *BucketInfo) MarshalMsg(b []byte) (o []byte, err error) { o = msgp.Require(b, z.Msgsize())
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Mar 08 19:08:18 GMT 2024 - 69.8K bytes - Viewed (0) -
internal/grid/muxserver.go
return false } m.RecvSeq++ return true } func (m *muxServer) message(msg message) { if debugPrint { fmt.Printf("muxServer: received message %d, length %d\n", msg.Seq, len(msg.Payload)) } m.recvMu.Lock() defer m.recvMu.Unlock() if cap(m.inbound) == 0 { m.disconnect("did not expect inbound message") return } if !m.checkSeq(msg.Seq) { return }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.1K bytes - Viewed (0) -
cmd/server-startup-msg.go
logger.Info(color.Blue("\nCLI: ") + mcQuickStartGuide) mcMessage := fmt.Sprintf("$ mc alias set '%s' '%s' '%s' '%s'", alias, endPoint, cred.AccessKey, cred.SecretKey) logger.Info(fmt.Sprintf(getFormatStr(len(mcMessage), 3), mcMessage)) } } // Get formatted disk/storage info message. func getStorageInfoMsg(storageInfo StorageInfo) string { var msg string var mcMessage string
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Mar 09 03:07:08 GMT 2024 - 6.8K bytes - Viewed (0)