- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 135 for sendLog (0.05 seconds)
-
internal/logger/logger.go
entry := errToEntry(ctx, subsystem, err, errKind...) sendLog(ctx, entry) } func sendLog(ctx context.Context, entry log.Entry) { systemTgts := SystemTargets() if len(systemTgts) == 0 { return } // Iterate over all logger targets to send the log entry for _, t := range systemTgts { if err := t.Send(ctx, entry); err != nil { if consoleTgt != nil { // Sending to the console never fails
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 12.4K bytes - Click Count (0) -
cmd/consolelogger.go
last = defaultLogBufferCount } lastN = make([]log.Info, last) sys.RLock() sys.logBuf.Do(func(p any) { if p != nil { lg, ok := p.(log.Info) if ok && lg.SendLog(node, logKind) { lastN[cnt%last] = lg cnt++ } } }) sys.RUnlock() // send last n console log messages in order filtered by node if cnt > 0 { for i := range last {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 5.4K bytes - Click Count (0) -
cmd/peer-rest-server.go
} var buf bytes.Buffer enc := json.NewEncoder(&buf) for { select { case entry, ok := <-ch: if !ok { return grid.NewRemoteErrString("console log channel closed") } if !entry.SendLog("", madmin.LogMask(mask)) { continue } buf.Reset() if err := enc.Encode(entry); err != nil { return grid.NewRemoteErr(err) } out <- grid.NewBytesWithCopyOf(buf.Bytes())
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 53.6K bytes - Click Count (0) -
cmd/admin-handlers.go
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 99.7K bytes - Click Count (0) -
.github/pull_request_template.md
https://github.com/google/guava/wiki/HowToContribute#code-contributions and https://github.com/google/guava/blob/master/CONTRIBUTING.md before sending a pull request. We generally welcome PRs for fixing trivial bugs or typos, but please refrain from sending a PR with significant changes unless explicitly requested.
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Oct 27 19:53:41 GMT 2023 - 371 bytes - Click Count (0) -
docs/en/docs/tutorial/background-tasks.md
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 05 18:13:19 GMT 2026 - 4.7K bytes - Click Count (0) -
internal/grid/connection.go
return err } if msg.Flags&FlagCRCxxh3 != 0 { h := xxh3.Hash(dst) dst = binary.LittleEndian.AppendUint32(dst, uint32(h)) } return c.send(c.ctx, dst) } // sendMsg will send func (c *Connection) sendMsg(conn net.Conn, msg message, payload msgp.MarshalSizer) error { if payload != nil { if sz := payload.Msgsize(); cap(msg.Payload) < sz { PutByteBuffer(msg.Payload)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 46.9K bytes - Click Count (0) -
docs/en/docs/advanced/json-base64-bytes.md
## Base64 vs Files { #base64-vs-files } Consider first if you can use [Request Files](../tutorial/request-files.md) for uploading binary data and [Custom Response - FileResponse](./custom-response.md#fileresponse--fileresponse-) for sending binary data, instead of encoding it in JSON. JSON can only contain UTF-8 encoded strings, so it can't contain raw bytes.Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 05 18:13:19 GMT 2026 - 2.4K bytes - Click Count (0) -
fastapi/security/oauth2.py
"items:read items:write users:read profile openid" client_id: optional string. OAuth2 recommends sending the client_id and client_secret (if any) using HTTP Basic auth, as: client_id:client_secret client_secret: optional string. OAuth2 recommends sending the client_id and client_secret (if any) using HTTP Basic auth, as: client_id:client_secret """ def __init__(
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Tue Mar 24 16:32:10 GMT 2026 - 23.6K bytes - Click Count (0) -
internal/grid/muxclient.go
func (m *muxClient) sendLocked(msg message) error { dst := GetByteBufferCap(msg.Msgsize()) msg.Seq = m.SendSeq msg.MuxID = m.MuxID msg.Flags |= m.BaseFlags if debugPrint { fmt.Println("Client sending", &msg, "to", m.parent.Remote) } m.SendSeq++ dst, err := msg.MarshalMsg(dst) if err != nil { return err } if msg.Flags&FlagSubroute != 0 { if m.subroute == nil {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 15.9K bytes - Click Count (0)