- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for logs (0.12 sec)
-
internal/logger/target/kafka/kafka.go
return ctx.Err() } return nil default: // log channel is full, do not wait and return // an error immediately to the caller atomic.AddInt64(&h.totalMessages, 1) atomic.AddInt64(&h.failedMessages, 1) return errors.New("log buffer full") } return nil } // SendFromStore - reads the log from store and sends it to kafka. func (h *Target) SendFromStore(key store.Key) (err error) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 10.1K bytes - Viewed (1) -
cmd/admin-router.go
// HTTP Trace adminRouter.Methods(http.MethodGet).Path(adminVersion + "/trace").HandlerFunc(adminMiddleware(adminAPI.TraceHandler, noObjLayerFlag)) // Console Logs adminRouter.Methods(http.MethodGet).Path(adminVersion + "/log").HandlerFunc(adminMiddleware(adminAPI.ConsoleLogHandler, traceAllFlag)) // -- KMS APIs -- //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 21:09:36 GMT 2024 - 25.5K bytes - Viewed (0) -
cmd/config-current.go
Description: "send server logs to webhook endpoints", MultipleTargets: true, }, config.HelpKV{ Key: config.AuditWebhookSubSys, Description: "send audit logs to webhook endpoints", MultipleTargets: true, }, config.HelpKV{ Key: config.AuditKafkaSubSys, Description: "send audit logs to kafka endpoints", MultipleTargets: true, },
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 30.8K bytes - Viewed (0) -
cmd/api-router.go
// behavior modification via flags. // // This middleware always calls `collectAPIStats` to collect API stats. // // The passed in handler function must be a method of `objectAPIHandlers` for // the name displayed in logs and trace to be accurate. The name is extracted // via reflection. // // When **no** flags are passed, the behavior is to trace both headers and body,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 04 18:05:56 GMT 2024 - 22.8K bytes - Viewed (0) -
cmd/peer-rest-client.go
select { case logCh <- *b: default: consoleLogRPC.PutResponse(b) // Do not block on slow receivers. } return nil }) } // ConsoleLog - sends request to peer nodes to get console logs func (client *peerRESTClient) ConsoleLog(ctx context.Context, kind madmin.LogMask, logCh chan<- []byte) { go func() { for { client.doConsoleLog(ctx, kind, logCh) select { case <-ctx.Done():
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
internal/logger/logger.go
if req.DeploymentID == "" { deploymentID = xhttp.GlobalDeploymentID } objects := make([]log.ObjectVersion, 0, len(req.Objects)) for _, ov := range req.Objects { objects = append(objects, log.ObjectVersion{ ObjectName: ov.ObjectName, VersionID: ov.VersionID, }) } entry := log.Entry{ DeploymentID: deploymentID, Level: logKind, RemoteHost: req.RemoteHost,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat May 04 00:17:57 GMT 2024 - 12.4K bytes - Viewed (0) -
cmd/globals.go
// global Listen system to send S3 API events to registered listeners globalHTTPListen = pubsub.New[event.Event, pubsub.Mask](0) // global console system to send console logs to // registered listeners globalConsoleSys *HTTPConsoleLoggerSys // All unique drives for this deployment globalEndpoints EndpointServerPools // All unique nodes for this deployment globalNodes []Node
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 16.5K bytes - Viewed (0) -
istioctl/pkg/ztunnelconfig/ztunnelconfig.go
istioctl x ztunnel-config log <pod-name[.namespace]> --level off # Update levels of the specified loggers for all Ztunnl pods istioctl x ztunnel-config log --level access:debug,info # Reset levels of all the loggers to default value (warning) for a specific Ztunnel pod. istioctl x ztunnel-config log <pod-name[.namespace]> -r `, Aliases: []string{"o"}, Args: func(cmd *cobra.Command, args []string) error {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 01 13:11:40 GMT 2024 - 22.2K bytes - Viewed (0) -
internal/logger/target/http/http.go
LogOnceIf func(ctx context.Context, err error, id string, errKind ...interface{}) `json:"-"` } // Target implements logger.Target and sends the json // format of a log entry to the configured http endpoint. // An internal buffer of logs is maintained but when the // buffer is full, new logs are just ignored and an error // is returned to the caller. type Target struct { totalMessages int64 failedMessages int64 status int32
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 25 16:44:20 GMT 2024 - 14.9K bytes - Viewed (0) -
src/cmd/asm/internal/asm/parse.go
// "<>", yielding (true, obj.ABI0) // "<ABI0>" yielding (false, obj.ABI0) // "<ABIInternal>" yielding (false, obj.ABIInternal) // // Anything else beginning with "<" logs an error if issueError is // true, otherwise returns (false, obj.ABI0). func (p *Parser) symRefAttrs(name string, issueError bool) (bool, obj.ABI) { abi := obj.ABI0 isStatic := false if p.peek() != '<' {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Feb 21 14:34:57 GMT 2024 - 36.9K bytes - Viewed (0)