- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 133 for Message (0.22 sec)
-
cmd/site-replication-utils_gen.go
if err != nil { err = msgp.WrapError(err) return } } } o = bts return } // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message func (z *SiteResyncStatus) Msgsize() (s int) { s = 1 + 2 + msgp.IntSize + 3 + z.Status.Msgsize() + 4 + msgp.StringPrefixSize + len(z.DeplID) + 5 + msgp.MapHeaderSize if z.BucketStatuses != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 14 15:16:40 GMT 2022 - 7.2K bytes - Viewed (0) -
cmd/peer-rest-client.go
conn := client.gridConn() if conn == nil { return nil } _, err := reloadSiteReplicationConfigRPC.Call(ctx, conn, grid.NewMSS()) return err } // VerifyBinary - sends verify binary message to remote peers. func (client *peerRESTClient) VerifyBinary(ctx context.Context, u *url.URL, sha256Sum []byte, releaseInfo string, reader io.Reader) error { values := make(url.Values) values.Set(peerRESTURL, u.String())
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/grid/benchmark_test.go
select { case <-ctx.Done(): return nil case out <- toSend: } } return nil }, Subroute: "some-subroute", OutCapacity: 1, // Only one message buffered. InCapacity: 0, })) errFatal(err) } const payloadSize = 512 rng := rand.New(rand.NewSource(time.Now().UnixNano())) payload := make([]byte, payloadSize) _, err = rng.Read(payload)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 12.2K bytes - Viewed (0) -
cmd/net.go
// prefer CIDRs with higher octets, this in-turn skips the // localhost/loopback address to be not preferred as the // first ip on the list. Subsequently this list helps us print // a user friendly message with appropriate values. func sortIPs(ipList []string) []string { if len(ipList) == 1 { return ipList } var ipV4s []net.IP var nonIPs []string for _, ip := range ipList {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 26 15:00:38 GMT 2024 - 9.3K bytes - Viewed (0) -
cmd/api-response.go
// but accepts the error message directly (this allows messages to be // dynamically generated.) func writeCustomErrorResponseJSON(ctx context.Context, w http.ResponseWriter, err APIError, errBody string, reqURL *url.URL, ) { reqInfo := logger.GetReqInfo(ctx) errorResponse := APIErrorResponse{ Code: err.Code, Message: errBody, Resource: reqURL.Path,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 33.3K bytes - Viewed (2) -
cmd/listen-notification-handlers.go
mergeCh := make(chan []byte, globalAPIConfig.getRequestsPoolCapacity()*len(globalEndpoints.Hostnames())) localCh := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity()) // Convert local messages to JSON and send to mergeCh go func() { buf := bytes.NewBuffer(grid.GetByteBuffer()[:0]) enc := json.NewEncoder(buf) tmpEvt := struct{ Records []event.Event }{[]event.Event{{}}} for { select {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
cmd/metrics-v2.go
kmsRequestsFail = "request_failure" kmsUptime = "uptime" webhookOnline = "online" webhookQueueLength = "queue_length" webhookTotalMessages = "total_messages" webhookFailedMessages = "failed_messages" ) const ( serverName = "server" ) // MetricTypeV2 for the types of metrics supported type MetricTypeV2 string const ( gaugeMetric = "gaugeMetric"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 22:01:31 GMT 2024 - 132.6K bytes - Viewed (0) -
cmd/iam.go
// authZ plugin is set, role policies are just claims sent to // the plugin and they need not exist. // // If some mapped policies do not exist, we print some error // messages but continue any way - they can be fixed in the // running server by creating the policies after start up. for arn, rolePolicies := range m { specifiedPoliciesSet := newMappedPolicy(rolePolicies).policySet()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1) -
internal/logger/target/kafka/kafka.go
} return nil } // IsOnline returns true if the target is online. func (h *Target) IsOnline(_ context.Context) bool { return atomic.LoadInt32(&h.status) == statusOnline } // Send log message 'e' to kafka target. func (h *Target) Send(ctx context.Context, entry interface{}) error { if h.store != nil { // save the entry to the queue store which will be replayed to the target. return h.store.Put(entry) }
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/test-utils_test.go
) { anonTestStr := "Anonymous HTTP request test" unknownSignTestStr := "Unknown HTTP signature test" // simple function which returns a message which gives the context of the test // and then followed by the actual error message. failTestStr := func(testType, failMsg string) string { return fmt.Sprintf("MinIO %s: %s fail for \"%s\": \n<Error> %s", instanceType, testType, testName, failMsg) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0)