- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for remotehost (0.19 sec)
-
internal/logger/reqinfo.go
tags []KeyVal // Any additional info not accommodated by above fields sync.RWMutex } // NewReqInfo : func NewReqInfo(remoteHost, userAgent, deploymentID, requestID, api, bucket, object string) *ReqInfo { return &ReqInfo{ RemoteHost: remoteHost, UserAgent: userAgent, API: api, DeploymentID: deploymentID, RequestID: requestID, BucketName: bucket, ObjectName: object,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 4.4K bytes - Viewed (0) -
internal/logger/target/console/console.go
} var requestID string if entry.RequestID != "" { requestID = "\nRequestID: " + entry.RequestID } var remoteHost string if entry.RemoteHost != "" { remoteHost = "\nRemoteHost: " + entry.RemoteHost } var host string if entry.Host != "" { host = "\nHost: " + entry.Host } var userAgent string if entry.UserAgent != "" {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 3.9K bytes - Viewed (0) -
internal/grid/grid_test.go
} grid, err := SetupTestGrid(2) errFatal(err) t.Cleanup(grid.Cleanup) local := grid.Managers[0] localHost := grid.Hosts[0] remote := grid.Managers[1] remoteHost := grid.Hosts[1] connLocalToRemote := local.Connection(remoteHost) connRemoteLocal := remote.Connection(localHost) t.Run("testStreamRoundtrip", func(t *testing.T) { defer timeout(5 * time.Second)() testStreamRoundtrip(t, local, remote)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
internal/grid/connection_test.go
t.Logf("Got a %s request for: %v", r.Method, r.URL) handler.ServeHTTP(w, r) }) } connReady := make(chan struct{}) // We fake a local and remote server. localHost := hosts[0] remoteHost := hosts[1] local, err := NewManager(context.Background(), ManagerOptions{ Dialer: dialer.DialContext, Local: localHost, Hosts: hosts, AddAuth: func(aud string) string { return aud },
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 6K bytes - Viewed (0) -
internal/logger/logger.go
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) -
internal/logger/message/audit/entry.go
// ToEntry - constructs an audit entry from a http request func ToEntry(w http.ResponseWriter, r *http.Request, reqClaims map[string]interface{}, deploymentID string) audit.Entry { entry := NewEntry(deploymentID) entry.RemoteHost = handlers.GetSourceIP(r) entry.UserAgent = r.UserAgent() entry.ReqClaims = reqClaims entry.ReqHost = r.Host entry.ReqPath = r.URL.Path q := r.URL.Query() reqQuery := make(map[string]string, len(q))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 2.2K bytes - Viewed (0) -
docs/logging/README.md
"api": { "name": "PutObject", "bucket": "testbucket", "object": "hosts", "status": "OK", "statusCode": 200, "rx": 380, "tx": 476, "timeToResponse": "257694819ns" }, "remotehost": "127.0.0.1", "requestID": "16ABE7A785E7AC2C", "userAgent": "MinIO (linux; amd64) minio-go/v7.0.15 mc/DEVELOPMENT.2021-10-06T23-39-34Z", "requestHeader": {
Plain Text - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Aug 15 23:04:20 GMT 2023 - 9.9K bytes - Viewed (0) -
cmd/admin-heal-ops.go
// objPrefix are already validated. func newHealSequence(ctx context.Context, bucket, objPrefix, clientAddr string, hs madmin.HealOpts, forceStart bool, ) *healSequence { reqInfo := &logger.ReqInfo{RemoteHost: clientAddr, API: "Heal", BucketName: bucket} reqInfo.AppendTags("prefix", objPrefix) ctx, cancel := context.WithCancel(logger.SetReqInfo(ctx, reqInfo)) clientToken := mustGetUUID() return &healSequence{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
cmd/erasure-healing.go
// The top level handler might not have this information. reqInfo := logger.GetReqInfo(ctx) var newReqInfo *logger.ReqInfo if reqInfo != nil { newReqInfo = logger.NewReqInfo(reqInfo.RemoteHost, reqInfo.UserAgent, reqInfo.DeploymentID, reqInfo.RequestID, reqInfo.API, bucket, object) } else { newReqInfo = logger.NewReqInfo("", "", globalDeploymentID(), "", "Heal", bucket, object) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 33.1K bytes - Viewed (0) -
cmd/utils.go
vars := mux.Vars(r) bucket := vars["bucket"] object := likelyUnescapeGeneric(vars["object"], url.PathUnescape) reqInfo := &logger.ReqInfo{ DeploymentID: globalDeploymentID(), RequestID: reqID, RemoteHost: handlers.GetSourceIP(r), Host: getHostName(r), UserAgent: r.UserAgent(), API: api, BucketName: bucket, ObjectName: object,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 15:18:21 GMT 2024 - 31.4K bytes - Viewed (0)