- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 140 for listener (0.1 sec)
-
manifests/addons/dashboards/ztunnel-dashboard.gen.json
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Fri Jul 26 23:54:32 UTC 2024 - 17.3K bytes - Viewed (0) -
cmd/consolelogger.go
if err != nil { logger.FatalIf(err, "Unable to start console logging subsystem") } sys.nodeName = host.Name } // HasLogListeners returns true if console log listeners are registered // for this node or peers func (sys *HTTPConsoleLoggerSys) HasLogListeners() bool { return sys != nil && sys.pubsub.Subscribers() > 0 } // Subscribe starts console logging for this node.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.5K bytes - Viewed (0) -
docs/auditlog/auditlog-echo.go
package main import ( "bytes" "encoding/json" "flag" "fmt" "io" "log" "net/http" ) var port int func init() { flag.IntVar(&port, "port", 8080, "Port to listen on") } func mainHandler(w http.ResponseWriter, r *http.Request) { body, err := io.ReadAll(r.Body) defer r.Body.Close() if err != nil { log.Printf("Error reading request body: %v", err)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed May 01 21:31:13 UTC 2024 - 1.5K bytes - Viewed (0) -
docs_src/response_change_status_code/tutorial001.py
from fastapi import FastAPI, Response, status app = FastAPI() tasks = {"foo": "Listen to the Bar Fighters"} @app.put("/get-or-create-task/{task_id}", status_code=200) def get_or_create_task(task_id: str, response: Response): if task_id not in tasks: tasks[task_id] = "This didn't exist before" response.status_code = status.HTTP_201_CREATED
Registered: Sun Oct 27 07:19:11 UTC 2024 - Last Modified: Thu Mar 26 19:09:53 UTC 2020 - 391 bytes - Viewed (0) -
docs/auditlog/auditlog-echo.md
# `auditlog-echo`: A tool to view MinIO Audit logs on the console 1. Run the tool with: ``` go run docs/auditlog/auditlog-echo.go ``` The listen port has a default value (8080), but can be set with the `-port` flag. 2. Configure audit logging in MinIO with for example: ``` mc admin config set myminio audit_webhook enable=on endpoint=http://localhost:8080 ```
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed May 01 21:31:13 UTC 2024 - 447 bytes - Viewed (0) -
istioctl/pkg/kubeinject/testdata/mesh-config.yaml
# and manipulation. # The "TPROXY" mode also configures the sidecar to run with the # CAP_NET_ADMIN capability, which is required to use TPROXY. #interceptionMode: REDIRECT # # Port where Envoy listens (on local host) for admin commands # You can exec into the istio-proxy container in a pod and # curl the admin port (curl http://localhost:15000/) to obtain # diagnostic information from Envoy. See
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Thu Jun 15 15:02:17 UTC 2023 - 2.2K bytes - Viewed (0) -
docs/sts/dex.yaml
# The base path of dex and the external name of the OpenID Connect service. # This is the canonical URL that all clients MUST use to refer to dex. If a # path is provided, dex's HTTP service will listen at a non-root URL. issuer: http://127.0.0.1:5556/dex # The storage configuration determines where dex stores its state. Supported # options include SQL flavors and Kubernetes third party resources. #
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Jul 15 11:55:55 UTC 2020 - 2.7K bytes - Viewed (0) -
docs/metrics/prometheus/alerts.md
target_match: severity: 'warning' equal: ['alertname', 'dev', 'instance'] ``` This sample configuration uses a `webhook` at http://127.0.0.1:8010/webhook to post the alerts. Start the AlertManager and it listens on port `9093` by default. Make sure your webhook is up and listening for the alerts. ## Configure Prometheus to use AlertManager Add below section to your `prometheus.yml` ```yaml alerting: alertmanagers:
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sun Jan 28 20:53:59 UTC 2024 - 4.4K bytes - Viewed (0) -
cni/pkg/install/install_test.go
} // Copy a valid config file into tempDir if err := file.AtomicCopy(filepath.Join("testdata", c.validConfigFilename), tempDir, c.cniConfigFilename); err != nil { t.Fatal(err) } // Listen for isReady to be set to true ticker := time.NewTicker(500 * time.Millisecond) defer ticker.Stop() readyChan := make(chan bool) go func(ctx context.Context, tick <-chan time.Time) { for {
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Fri Jan 26 20:34:28 UTC 2024 - 11.1K bytes - Viewed (0) -
cmd/mrf.go
localDrive.Delete(GlobalContext, minioMetaBucket, pathJoin(healMRFDir, "list.bin"), DeleteOptions{}) break } return } var healSleeper = newDynamicSleeper(5, time.Second, false) // healRoutine listens to new disks reconnection events and // issues healing requests for queued objects belonging to the // corresponding erasure set func (m *mrfState) healRoutine(z *erasureServerPools) { for { select {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Aug 13 22:26:05 UTC 2024 - 6.5K bytes - Viewed (0)