Pool - Code Search

schema/interfaces.go

	Build() (sql string, vars []interface{})
}

// GormDataTypeInterface gorm data type interface
type GormDataTypeInterface interface {
	GormDataType() string
}

// FieldNewValuePool field new scan value pool
type FieldNewValuePool interface {
	Get() interface{}
	Put(interface{})
}

// CreateClausesInterface create clauses interface
type CreateClausesInterface interface {
	CreateClauses(*Field) []clause.Interface
}

Created: Sun Dec 28 09:35:17 GMT 2025

- Last Modified: Sun Feb 04 07:49:19 GMT 2024

- 980 bytes

- Click Count (0)

github.com/minio/minio

cmd/rebalstatus_string.go

// Code generated by "stringer -type=rebalStatus -trimprefix=rebal erasure-server-pool-rebalance.go"; DO NOT EDIT.

package cmd

import "strconv"

func _() {
	// An "invalid array index" compiler error signifies that the constant values have changed.
	// Re-run the stringer command to generate them again.
	var x [1]struct{}
	_ = x[rebalNone-0]
	_ = x[rebalStarted-1]
	_ = x[rebalCompleted-2]
	_ = x[rebalStopped-3]
	_ = x[rebalFailed-4]
}

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Tue Oct 25 19:36:57 GMT 2022

- 795 bytes

- Click Count (0)

github.com/go-gorm/gorm

tests/prepared_stmt_test.go

		t.Fatalf("Failed, got error: %v, rows affected: %v", result.Error, result.RowsAffected)
	}

	tx2.Commit()
	// Attempt to convert the connection pool of tx to the *gorm.PreparedStmtDB type.
	// If the conversion is successful, ok will be true and conn will be the converted object;
	// otherwise, ok will be false and conn will be nil.

Created: Sun Dec 28 09:35:17 GMT 2025

- Last Modified: Fri Apr 25 08:22:26 GMT 2025

- 8K bytes

- Click Count (0)

github.com/google/guava

android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

   *
   * <p><b>Warning:</b> If the input future does not already implement {@code ListenableFuture}, the
   * returned future will emulate {@link ListenableFuture#addListener} by taking a thread from an
   * internal, unbounded pool at the first call to {@code addListener} and holding it until the
   * future is {@linkplain Future#isDone() done}.
   *
   * <p>Prefer to create {@code ListenableFuture} instances with {@link SettableFuture}, {@link

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Thu Jul 17 15:26:41 GMT 2025

- 7.5K bytes

- Click Count (0)

github.com/minio/minio

.github/workflows/run-mint.sh

docker-compose -f minio-${MODE}.yaml up -d
sleep 1m

docker system prune -f || true
docker volume prune -f || true
docker volume rm $(docker volume ls -q -f dangling=true) || true

# Stop two nodes, one of each pool, to check that all S3 calls work while quorum is still there
[ "${MODE}" == "pools" ] && docker-compose -f minio-${MODE}.yaml stop minio2
[ "${MODE}" == "pools" ] && docker-compose -f minio-${MODE}.yaml stop minio6

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Mon Jan 20 14:49:07 GMT 2025

- 1.9K bytes

- Click Count (0)

github.com/minio/minio

cmd/bucket-replication.go

		priority:        priority,
		maxWorkers:      maxWorkers,
		maxLWorkers:     maxLWorkers,
	}

	pool.ResizeLrgWorkers(maxLWorkers, 0)
	pool.ResizeWorkers(workers, 0)
	pool.ResizeFailedWorkers(failedWorkers)
	go pool.resyncer.PersistToDisk(ctx, o)
	go pool.processMRF()
	go pool.persistMRF()
	return pool
}

// AddMRFWorker adds a pending/failed replication worker to handle requests that could not be queued

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Sun Sep 28 20:59:21 GMT 2025

- 118.2K bytes

- Click Count (0)

github.com/tensorflow/tensorflow

ci/official/utilities/generate_index_html.sh

cat > "$1" <<EOF
<html>
<head>
<title>$(basename "$KOKORO_JOB_NAME")</title>
</head>
<body>
<h1>TensorFlow Job Logs and Links</h1>
<h2>Job Details</h2>
<ul>
<li>Job name: $KOKORO_JOB_NAME</li>
<li>Job pool: $KOKORO_JOB_POOL</li>
<li>Job ID: $KOKORO_BUILD_ID</li>
<li>Current HEAD Piper Changelist, if any: cl/${KOKORO_PIPER_CHANGELIST:-not available}</li>

Created: Tue Dec 30 12:39:10 GMT 2025

- Last Modified: Fri Sep 29 20:26:13 GMT 2023

- 2.3K bytes

- Click Count (0)

github.com/minio/minio

cmd/object-api-interface.go

	LockEnabled       bool
	VersioningEnabled bool
	ForceCreate       bool      // Create buckets even if they are already created.
	CreatedAt         time.Time // only for site replication
	NoLock            bool      // does not lock the make bucket call if set to 'true'
}

// DeleteBucketOptions provides options for DeleteBucket calls.
type DeleteBucketOptions struct {

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Sun Sep 28 20:59:21 GMT 2025

- 17.5K bytes

- Click Count (0)

github.com/minio/minio

cmd/storage-rest-server.go

	globalLocalSetDrives = make([][][]StorageAPI, len(endpointServerPools))
	for pool := range globalLocalSetDrives {
		globalLocalSetDrives[pool] = make([][]StorageAPI, endpointServerPools[pool].SetCount)
		for set := range globalLocalSetDrives[pool] {
			globalLocalSetDrives[pool][set] = make([]StorageAPI, endpointServerPools[pool].DrivesPerSet)
		}
	}
	for _, serverPool := range endpointServerPools {

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Tue May 27 15:19:03 GMT 2025

- 45.7K bytes

- Click Count (0)

github.com/minio/minio

internal/grid/grid.go

	// Used if no deadline is provided on context.
	defaultSingleRequestTimeout = time.Minute
)

var internalByteBuffer = bpool.Pool[*[]byte]{
	New: func() *[]byte {
		m := make([]byte, 0, defaultBufferSize)
		return &m
	},
}

var internal32KByteBuffer = bpool.Pool[*[]byte]{
	New: func() *[]byte {
		m := make([]byte, 0, biggerBufMin)
		return &m
	},
}

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Sun Mar 30 00:56:02 GMT 2025

- 7K bytes

- Click Count (0)

Search Options