- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for Exchange (0.3 sec)
-
istioctl/pkg/util/configdump/wrapper.go
typ, err := r.Types.FindMessageByURL(url) if err != nil { // Here we ignore the error since we want istioctl to ignore unknown types due to the Envoy version change msg := exprpb.Type{TypeKind: &exprpb.Type_Dyn{Dyn: &emptypb.Empty{}}} return msg.ProtoReflect().Type(), nil } return typ, nil } // Wrapper is a wrapper around the Envoy ConfigDump
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/dial_dnscache.go
// // You can use returned dial function for `http.Transport.DialContext`. // // In this function, it uses functions from `rand` package. To make it really random, // you MUST call `rand.Seed` and change the value from the default in your application func DialContextWithLookupHost(lookupHost LookupHost, baseDialCtx DialContext) DialContext { if lookupHost == nil { lookupHost = net.DefaultResolver.LookupHost }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jul 03 19:30:51 GMT 2023 - 2.6K bytes - Viewed (0) -
operator/cmd/mesh/profile-diff_test.go
args: "profile diff default openshift", // This is just one of the many differences expectedString: "+ profile: openshift", // The profile doesn't change istiocoredns, so we shouldn't see this in the diff notExpected: "- istiocoredns:", // 'profile diff' "fails" so that the error level `$?` is 1, not 0, if there is a diff shouldFail: false, }, }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Jan 10 05:10:03 GMT 2024 - 3.6K bytes - Viewed (1) -
internal/grid/msg.go
DeadlineMS uint32 // If non-zero, milliseconds until deadline (max 1193h2m47.295s, ~49 days) Handler HandlerID // ID of handler if invoking a remote handler. Op Op // Operation. Other fields change based on this value. Flags Flags // Optional flags. Payload []byte // Optional payload. } // Flags is a set of flags set on a message. type Flags uint8 func (m message) String() string {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 28 19:22:29 GMT 2023 - 7.3K bytes - Viewed (0) -
internal/grid/manager.go
) // Manager will contain all the connections to the grid. // It also handles incoming requests and routes them to the appropriate connection. type Manager struct { // ID is an instance ID, that will change whenever the server restarts. // This allows remotes to keep track of whether state is preserved. ID uuid.UUID // Immutable after creation, so no locks. targets map[string]*Connection // serverside handlers.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.5K bytes - Viewed (0) -
internal/config/api/help.go
}, config.HelpKV{ Key: apiStaleUploadsCleanupInterval, Description: `set to change intervals when stale multipart uploads are expired` + defaultHelpPostfix(apiStaleUploadsCleanupInterval), Optional: true, Type: "duration", }, config.HelpKV{ Key: apiDeleteCleanupInterval,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 15 01:07:19 GMT 2024 - 4.7K bytes - Viewed (0) -
internal/amztime/parse.go
// Package amztime implements AWS specific time parsing and deviations package amztime import ( "errors" "net/http" "time" ) // Supported amz date formats. var amzDateFormats = []string{ // Do not change this order, x-amz-date format is usually in // iso8601Format rest are meant for relaxed handling of other // odd SDKs that might be out there. "20060102T150405Z", time.RFC1123, time.RFC1123Z,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 2.5K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
pod.Name, wasAnnotated, isAnnotated, shouldBeEnabled, changeNeeded, oldPod, newPod) if !changeNeeded { log.Debugf("Pod %s update event skipped, no change needed", pod.Name) return nil } if !shouldBeEnabled { log.Debugf("Pod %s no longer matches, removing from mesh", newPod.Name) err := s.dataplane.RemovePodFromMesh(s.ctx, pod)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 9.6K bytes - Viewed (0) -
cmd/veeam-sos-api.go
// specific system recommendations based on current support case statistics and storage performance possibilities. // Vendors might change the settings based on the configuration and scale out of the solution (more storage nodes => // higher task limit). // // <S3ConcurrentTaskLimit> //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 18:43:58 GMT 2024 - 8.2K bytes - Viewed (2) -
cmd/erasure-decode.go
// preferReaders can mark readers as preferred. // These will be chosen before others. func (p *parallelReader) preferReaders(prefer []bool) { if len(prefer) != len(p.orgReaders) { return } // Copy so we don't change our input. tmp := make([]io.ReaderAt, len(p.orgReaders)) copy(tmp, p.orgReaders) p.readers = tmp // next is the next non-preferred index. next := 0 for i, ok := range prefer { if !ok || p.readers[i] == nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 9.4K bytes - Viewed (0)