- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 238 for leaders (0.18 sec)
-
src/internal/trace/raw/reader.go
"fmt" "io" "internal/trace/event" "internal/trace/version" ) // Reader parses trace bytes with only very basic validation // into an event stream. type Reader struct { r *bufio.Reader v version.Version specs []event.Spec } // NewReader creates a new reader for the trace wire format. func NewReader(r io.Reader) (*Reader, error) { br := bufio.NewReader(r) v, err := version.ReadHeader(br)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 2.2K bytes - Viewed (0) -
cluster/addons/metrics-server/resource-reader.yaml
xin.li <******@****.***> 1716688621 +0800
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun May 26 01:57:01 UTC 2024 - 988 bytes - Viewed (0) -
samples/bookinfo/src/productpage/productpage.py
def getForwardHeaders(request): headers = {} # x-b3-*** headers can be populated using the OpenTelemetry span ctx = propagator.extract(carrier={k.lower(): v for k, v in request.headers}) propagator.inject(headers, ctx) # We handle other (non x-b3-***) headers manually if 'user' in session: headers['end-user'] = session['user']
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 14:35:54 UTC 2024 - 14.6K bytes - Viewed (1) -
cmd/erasure-decode.go
if !ok || p.readers[i] == nil { continue } if i == next { next++ continue } // Move reader with index i to index next. // Do this by swapping next and i p.readers[next], p.readers[i] = p.readers[i], p.readers[next] p.readerToBuf[next] = i p.readerToBuf[i] = next next++ } } // Returns if buf can be erasure decoded.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 21 14:36:21 UTC 2024 - 9.4K bytes - Viewed (0) -
samples/bookinfo/src/details/details.rb
'cookie', 'authorization', 'jwt' ] request.each do |header, value| if incoming_headers.include? header then headers[header] = value end end return headers end
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 14:35:54 UTC 2024 - 5.8K bytes - Viewed (0) -
pilot/pkg/features/experimental.go
EnableLeaderElection = env.Register("ENABLE_LEADER_ELECTION", true, "If enabled (default), starts a leader election client and gains leadership before executing controllers. "+ "If false, it assumes that only one instance of istiod is running and skips leader election.").Get() EnableSidecarServiceInboundListenerMerge = env.Register( "PILOT_ALLOW_SIDECAR_SERVICE_INBOUND_LISTENER_MERGE", false,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:02:38 UTC 2024 - 10.2K bytes - Viewed (0) -
src/encoding/pem/pem.go
// // The encoded form is: // // -----BEGIN Type----- // Headers // base64-encoded Bytes // -----END Type----- // // where [Block.Headers] is a possibly empty sequence of Key: Value lines. type Block struct { Type string // The type, taken from the preamble (i.e. "RSA PRIVATE KEY"). Headers map[string]string // Optional headers.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 7.6K bytes - Viewed (0) -
tests/integration/pilot/ingress_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 19.5K bytes - Viewed (0) -
cmd/signature-v4.go
) // getCanonicalHeaders generate a list of request headers with their values func getCanonicalHeaders(signedHeaders http.Header) string { var headers []string vals := make(http.Header) for k, vv := range signedHeaders { k = strings.ToLower(k) headers = append(headers, k) vals[k] = vv } sort.Strings(headers) var buf bytes.Buffer for _, k := range headers { buf.WriteString(k) buf.WriteByte(':')
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 16 23:13:47 UTC 2024 - 12.4K bytes - Viewed (0) -
src/sync/rwmutex.go
w Mutex // held if there are pending writers writerSem uint32 // semaphore for writers to wait for completing readers readerSem uint32 // semaphore for readers to wait for completing writers readerCount atomic.Int32 // number of pending readers readerWait atomic.Int32 // number of departing readers } const rwmutexMaxReaders = 1 << 30 // Happens-before relationships are indicated to the race detector via:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 7.2K bytes - Viewed (0)