Dealer - Code Search

staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset.go

	// was last non-zero (if ever).
	qCfg fq.QueuingConfig

	// the current dispatching configuration.
	dCfg fq.DispatchingConfig

	// If `qCfg.DesiredNumQueues` is non-zero then dealer is not nil
	// and is good for `qCfg`.
	dealer *shufflesharding.Dealer

	// queues may be longer than the desired number, while the excess
	// queues are still draining.
	queues []*queue

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Thu Jan 04 16:59:21 UTC 2024

- 42.4K bytes

- Viewed (0)

github.com/minio/minio

internal/hash/reader.go

)

// A Reader wraps an io.Reader and computes the MD5 checksum
// of the read content as ETag. Optionally, it also computes
// the SHA256 checksum of the content.
//
// If the reference values for the ETag and content SHA26
// are not empty then it will check whether the computed
// match the reference values.
type Reader struct {
	src         io.Reader
	bytesRead   int64
	expectedMin int64

Registered: Sun Jun 16 00:44:34 UTC 2024

- Last Modified: Mon Sep 18 17:00:54 UTC 2023

- 10.8K bytes

- Viewed (0)

github.com/golang/go

src/archive/tar/reader.go

	"strconv"
	"strings"
	"time"
)

// Reader provides sequential access to the contents of a tar archive.
// Reader.Next advances to the next file in the archive (including the first),
// and then Reader can be treated as an io.Reader to access the file's data.
type Reader struct {
	r    io.Reader
	pad  int64      // Amount of padding (ignored) after current file entry
	curr fileReader // Reader for current file entry

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Fri Mar 08 01:59:14 UTC 2024

- 26.8K bytes

- Viewed (0)

github.com/golang/go

src/net/textproto/reader.go

// the size of responses.
func NewReader(r *bufio.Reader) *Reader {
	return &Reader{R: r}
}

// ReadLine reads a single line from r,
// eliding the final \n or \r\n from the returned string.
func (r *Reader) ReadLine() (string, error) {
	line, err := r.readLineSlice(-1)
	return string(line), err
}

// ReadLineBytes is like [Reader.ReadLine] but returns a []byte instead of a string.

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Wed May 15 19:57:43 UTC 2024

- 22.1K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/documentation/docs/src/main/resources/header.html

<div class="layout">
    <header class="site-layout__header site-header" itemscope="itemscope" itemtype="https://schema.org/WPHeader">
        <nav class="site-header__navigation" itemscope="itemscope" itemtype="https://schema.org/SiteNavigationElement">
            <div class="site-header__navigation-header">
                <a target="_top" class="logo" href="https://docs.gradle.org" title="Gradle Docs">

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Sat May 25 05:15:02 UTC 2024

- 35.6K bytes

- Viewed (0)

github.com/golang/go

src/image/gif/reader.go

	errTooMuch   = errors.New("gif: too much image data")
	errBadPixel  = errors.New("gif: invalid pixel value")
)

// If the io.Reader does not also have ReadByte, then decode will introduce its own buffering.
type reader interface {
	io.Reader
	io.ByteReader
}

// Masks etc.
const (
	// Fields.
	fColorTable         = 1 << 7
	fInterlace          = 1 << 6
	fColorTableBitsMask = 7

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Thu Apr 11 16:15:54 UTC 2024

- 17.5K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

staging/src/k8s.io/apimachinery/pkg/util/proxy/transport_test.go

			forwardedURI: "/proxy/node/node1:10250/logs/log.log",
		},
		"full document": {
			input:        `<html><header></header><body><pre><a href="kubelet.log">kubelet.log</a><a href="/google.log">google.log</a></pre></body></html>`,
			sourceURL:    "http://mynode.com/logs/log.log",
			transport:    testTransport,

Registered: Sat Jun 15 01:39:40 UTC 2024

- Last Modified: Wed May 10 07:29:34 UTC 2023

- 13.8K bytes

- Viewed (0)

github.com/golang/go

src/go/doc/reader.go

// AST reader

// reader accumulates documentation for a single package.
// It modifies the AST: Comments (declaration documentation)
// that have been collected by the reader are set to nil
// in the respective AST nodes so that they are not printed
// twice (once when printing the documentation and once when
// printing the corresponding AST node).
type reader struct {
	mode Mode

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Thu May 23 01:00:11 UTC 2024

- 27.5K bytes

- Viewed (0)

github.com/golang/go

src/encoding/csv/reader.go

}

// A Reader reads records from a CSV-encoded file.
//
// As returned by [NewReader], a Reader expects input conforming to RFC 4180.
// The exported fields can be changed to customize the details before the
// first call to [Reader.Read] or [Reader.ReadAll].
//
// The Reader converts all \r\n sequences in its input to plain \n,

Registered: Wed Jun 12 16:32:35 UTC 2024

- Last Modified: Mon May 13 21:32:28 UTC 2024

- 14.2K bytes

- Viewed (0)

github.com/apache/maven

src/mdo/reader.vm

    }

    /**
     *
     * @param reader a reader object.
     * @param strict a strict object.
     * @throws IOException IOException if any.
     * @throws XMLStreamException XMLStreamException if
     * any.
     * @return ${root.name}
     */
    public ${root.name} read(Reader reader, boolean strict) throws IOException, XMLStreamException {

Registered: Wed Jun 12 09:55:16 UTC 2024

- Last Modified: Fri Dec 15 06:33:11 UTC 2023

- 42.1K bytes

- Viewed (0)

Search Options