- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 35 for withPanels (0.12 sec)
-
pkg/test/echo/server/endpoint/grpc.go
echo.HostnameField.Write(&body, hostname) } epLog.WithLabels("id", id).Infof("GRPC Response") return &proto.EchoResponse{Message: body.String()}, nil } func (h *EchoGrpcHandler) ForwardEcho(ctx context.Context, req *proto.ForwardEchoRequest) (*proto.ForwardEchoResponse, error) { id := uuid.New() l := epLog.WithLabels("url", req.Url, "id", id) l.Infof("ForwardEcho request") t0 := time.Now()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Sep 25 17:30:37 UTC 2023 - 8.7K bytes - Viewed (0) -
pkg/hbone/dialer.go
return fmt.Errorf("round trip failed: %v", resp.Status) } log.WithLabels("host", r.Host, "remote", remoteID).Info("CONNECT established") go func() { defer conn.Close() defer resp.Body.Close() wg := sync.WaitGroup{} wg.Add(1) go func() { // handle upstream (hbone server) --> downstream (app) copyBuffered(conn, resp.Body, log.WithLabels("name", "body to conn")) wg.Done() }()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 24 15:56:41 UTC 2023 - 5.1K bytes - Viewed (0) -
pkg/test/echo/server/endpoint/udp.go
epLog.Warn("UDP read failed: " + err.Error()) return } id := uuid.New() epLog.WithLabels("remote", remote, "id", id).Infof("UDP Request") responseFields := s.getResponseFields(remote) if _, err := listener.WriteTo([]byte(responseFields), remote); err != nil { epLog.WithLabels("id", id).Warnf("UDP failed writing echo response: %v", err) } } }()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 16:20:31 UTC 2023 - 3.4K bytes - Viewed (0) -
security/pkg/nodeagent/cache/helper.go
// limitations under the License. package cache import ( "fmt" "istio.io/istio/pkg/log" ) func resourceLog(resourceName string) *log.Scope { return cacheLog.WithLabels("resource", resourceName) } // cacheLogPrefix returns a unified log prefix. func cacheLogPrefix(resourceName string) string { lPrefix := fmt.Sprintf("resource:%s", resourceName) return lPrefix
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 924 bytes - Viewed (0) -
pkg/log/default_test.go
} }) } } func TestDefaultWithLabel(t *testing.T) { lines, err := captureStdout(func() { Configure(DefaultOptions()) funcs.Store(funcs.Load().(patchTable)) WithLabels("foo", "bar").WithLabels("baz", 123, "qux", 0.123).Error("Hello") _ = Sync() }) if err != nil { t.Errorf("Got error '%v', expected success", err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Mar 26 20:38:10 UTC 2024 - 7.4K bytes - Viewed (0) -
pilot/pkg/server/instance.go
t0 := time.Now() if err := next.task(stop); err != nil { // Startup error: terminate and return the error. shutdown() return err } runtime := time.Since(t0) log := log.WithLabels("name", next.name, "runtime", runtime) log.Debugf("started task") if runtime > time.Second { log.Warnf("slow startup task") } default: // We've drained all of the initial tasks.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 4.6K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
// don't return error here, as this is purely informational. } return retErr } func (s *meshDataplane) RemovePodFromMesh(ctx context.Context, pod *corev1.Pod) error { log := log.WithLabels("ns", pod.Namespace, "name", pod.Name) err := s.netServer.RemovePodFromMesh(ctx, pod) if err != nil { log.Errorf("failed to remove pod from mesh: %v", err) return err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 21:45:18 UTC 2024 - 7.2K bytes - Viewed (0) -
src/runtime/pprof/runtime.go
// The augmented label map will be set for the duration of the call to f // and restored once f returns. func Do(ctx context.Context, labels LabelSet, f func(context.Context)) { defer SetGoroutineLabels(ctx) ctx = WithLabels(ctx, labels) SetGoroutineLabels(ctx) f(ctx)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 08 16:59:11 UTC 2023 - 1.8K bytes - Viewed (0) -
pilot/pkg/networking/apigen/apigen.go
for _, c := range cfg { // Right now model.Config is not a proto - until we change it, mcp.Resource. // This also helps migrating MCP users. b, err := config.PilotConfigToResource(&c) if err != nil { log.WithLabels("resource", c.NamespacedName()).Warnf("resource error: %v", err) continue } resp = append(resp, &discovery.Resource{ Name: c.Namespace + "/" + c.Name, Resource: protoconv.MessageToAny(b), })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Oct 05 19:01:38 UTC 2023 - 5K bytes - Viewed (0) -
pkg/structured/structured.go
lbls = append(lbls, "action", e.Action) } if e.LikelyCause != "" { lbls = append(lbls, "likelyCause", e.LikelyCause) } if e.Err != nil { lbls = append(lbls, "err", e.Err.Error()) } return s.WithLabels(lbls...) } func (e *Error) Error() string { if e == nil { return "" } return fmt.Sprintf("\tmoreInfo=%s impact=%s action=%s likelyCause=%s err=%v", e.MoreInfo, e.Impact, e.Action, e.LikelyCause, e.Err)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Jul 15 23:58:50 UTC 2023 - 2.5K bytes - Viewed (0)