- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for handling (0.15 sec)
-
istioctl/pkg/util/configdump/wrapper.go
return msg.ProtoReflect().Type(), nil } return typ, nil } // Wrapper is a wrapper around the Envoy ConfigDump // It has extra helper functions for handling any/struct/marshal protobuf pain type Wrapper struct { *admin.ConfigDump } // UnmarshalJSON is a custom unmarshaller to handle protobuf pain func (w *Wrapper) UnmarshalJSON(b []byte) error {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sun Apr 21 17:42:54 GMT 2024 - 1.8K bytes - Viewed (0) -
internal/http/listener.go
"net" "syscall" "time" "github.com/minio/minio/internal/deadlineconn" ) type acceptResult struct { conn net.Conn err error lidx int } // httpListener - HTTP listener capable of handling multiple server addresses. type httpListener struct { opts TCPOptions listeners []net.Listener // underlying TCP listeners.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
log.Debug("listener closed - returning") return } log.Errorf("failed to accept conn: %v", err) continue } log.Debug("connection accepted") go func() { log.Debug("handling conn") if err := z.handleConn(ctx, conn); err != nil { log.Errorf("failed to handle conn: %v", err) } }() } } // ZDS protocol is very simple, for every message sent, and ack is sent.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
cmd/object-api-utils.go
// string. // // See: // http://docs.aws.amazon.com/AmazonS3/latest/dev/UsingMetadata.html // // You should avoid the following characters in a key name because of // significant special handling for consistency across all // applications. // // Rejects strings with following characters. // // - Backslash ("\") // // additionally minio does not support object names with trailing SlashSeparator.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Mar 11 11:55:34 GMT 2024 - 35.6K bytes - Viewed (1) -
cmd/bucket-replication.go
} } } } // ActiveWorkers returns the number of active workers handling replication traffic. func (p *ReplicationPool) ActiveWorkers() int { return int(atomic.LoadInt32(&p.activeWorkers)) } // ActiveMRFWorkers returns the number of active workers handling replication failures. func (p *ReplicationPool) ActiveMRFWorkers() int { return int(atomic.LoadInt32(&p.activeMRFWorkers))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
cmd/site-replication.go
// be cleaned to recover. partial := madmin.ReplicateAddStatus{ Status: madmin.ReplicateAddStatusPartial, ErrDetail: peerAddErr.Error(), } return partial, nil } // Other than handling existing buckets, we can now save the cluster // replication configuration state. state := srState{ Name: sites[selfIdx].Name, Peers: joinReq.Peers,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1) -
src/cmd/asm/internal/asm/parse.go
p.errorf("expected g or R0 through R15; found %s", name) return 0 } return uint16(reg) } // Note: There are two changes in the expression handling here // compared to the old yacc/C implementations. Neither has // much practical consequence because the expressions we // see in assembly code are simple, but for the record: //
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) -
cmd/iam-store.go
// Delete this user account and its policy mapping store.deleteMappedPolicy(ctx, user, userType, false) cache.iamUserPolicyMap.Delete(user) // we are only logging errors, not handling them. err := store.deleteUserIdentity(ctx, user, userType) iamLogIf(GlobalContext, err) delete(cache.iamUsersMap, user) deleted = true } } if deleted {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Apr 27 10:04:10 GMT 2024 - 75.2K bytes - Viewed (2) -
internal/grid/connection.go
case OpUnblockClMux: c.handleUnblockClMux(m) case OpDisconnectServerMux: c.handleDisconnectServerMux(m) case OpDisconnectClientMux: c.handleDisconnectClientMux(m) case OpPing: c.handlePing(ctx, m) case OpPong: c.handlePong(ctx, m) case OpRequest: c.handleRequest(ctx, m, subID) case OpAckMux: c.handleAckMux(ctx, m) case OpConnectMux: c.handleConnectMux(ctx, m, subID)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
cmd/generic-handlers.go
h.ServeHTTP(w, r) return } remote, self := globalSiteReplicationSys.getPeerForUpload(deplID) if self { h.ServeHTTP(w, r) return } // forward request to peer handling this upload if globalBucketTargetSys.isOffline(remote.EndpointURL) { defer logger.AuditLog(r.Context(), w, r, mustGetClaimsFromToken(r))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:08:52 GMT 2024 - 20.7K bytes - Viewed (0)