- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 335 for initiatives (0.67 sec)
-
internal/cachevalue/cache.go
} // NewFromFunc allocates a new cached value instance and initializes it with an // update function, making it ready for use. func NewFromFunc[T any](ttl time.Duration, opts Opts, update func(ctx context.Context) (T, error)) *Cache[T] { return &Cache[T]{ ttl: ttl, updateFn: update, opts: opts, } } // InitOnce initializes the cache with a TTL and an update function. It is
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 12:50:46 UTC 2024 - 4.4K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/queuesort/priority_sort.go
p1 := corev1helpers.PodPriority(pInfo1.Pod) p2 := corev1helpers.PodPriority(pInfo2.Pod) return (p1 > p2) || (p1 == p2 && pInfo1.Timestamp.Before(pInfo2.Timestamp)) } // New initializes a new plugin and returns it. func New(_ context.Context, _ runtime.Object, handle framework.Handle) (framework.Plugin, error) { return &PrioritySort{}, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 20 09:49:54 UTC 2023 - 1.7K bytes - Viewed (0) -
okhttp-sse/src/main/kotlin/okhttp3/sse/EventSource.kt
* the event source has already been closed or canceled. */ fun cancel() fun interface Factory { /** * Creates a new event source and immediately returns it. Creating an event source initiates an * asynchronous process to connect the socket. Once that succeeds or fails, `listener` will be * notified. The caller must cancel the returned event source when it is no longer in use. */ fun newEventSource(
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.4K bytes - Viewed (0) -
cmd/erasure-sets_test.go
defer cancel() nDisks := 16 // Maximum disks. var erasureDisks []string for i := 0; i < nDisks; i++ { // Do not attempt to create this path, the test validates // so that newErasureSets initializes non existing paths // and successfully returns initialized object layer. disk := filepath.Join(globalTestTmpDir, "minio-"+nextSuffix()) erasureDisks = append(erasureDisks, disk) defer os.RemoveAll(disk) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Feb 12 07:21:56 UTC 2024 - 6.9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/examples/prebind/prebind.go
} if pod.Namespace != "foo" { return framework.NewStatus(framework.Unschedulable, "only pods from 'foo' namespace are allowed") } return nil } // New initializes a new plugin and returns it. func New(_ context.Context, _ *runtime.Unknown, _ framework.Handle) (framework.Plugin, error) { return &StatelessPreBindExample{}, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 09 03:43:17 UTC 2023 - 1.8K bytes - Viewed (0) -
internal/hash/sha256/sh256.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package sha256 import ( "crypto/sha256" "hash" ) // New initializes a new sha256.New() func New() hash.Hash { return sha256.New() } // Sum256 returns the SHA256 checksum of the data. func Sum256(data []byte) [sha256.Size]byte { return sha256.Sum256(data) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Apr 26 06:31:35 UTC 2024 - 1.1K bytes - Viewed (0) -
platforms/ide/tooling-api/src/test/groovy/org/gradle/tooling/internal/consumer/SynchronizedLoggingTest.groovy
import java.util.concurrent.CopyOnWriteArraySet public class SynchronizedLoggingTest extends ConcurrentSpec { def logging = new SynchronizedLogging(Stub(Clock), Stub(BuildOperationIdFactory)) def "initialises on first usage"() { expect: logging.listenerManager != null logging.listenerManager == logging.listenerManager logging.progressLoggerFactory != null
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 1.7K bytes - Viewed (0) -
subprojects/diagnostics/src/integTest/groovy/org/gradle/api/tasks/diagnostics/TaskReportTaskIntegrationTest.groovy
settingsFile << "rootProject.name = '$projectName'" when: succeeds tasks then: output.contains(""" Build Setup tasks ----------------- init - Initializes a new Gradle build. updateDaemonJvm - Generates or updates the Gradle Daemon JVM criteria. wrapper - Generates Gradle wrapper files. Help tasks ----------
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 15:00:02 UTC 2024 - 18.6K bytes - Viewed (0) -
src/crypto/tls/tls.go
func (timeoutError) Timeout() bool { return true } func (timeoutError) Temporary() bool { return true } // DialWithDialer connects to the given network address using dialer.Dial and // then initiates a TLS handshake, returning the resulting TLS connection. Any // timeout or deadline given in the dialer apply to connection and TLS // handshake as a whole. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 12.2K bytes - Viewed (0) -
src/runtime/rt0_js_wasm.s
TEXT _rt0_wasm_js(SB),NOSPLIT,$0 I32Const $wasm_export_run(SB) Drop I32Const $wasm_export_resume(SB) Drop I32Const $wasm_export_getsp(SB) Drop // wasm_export_run gets called from JavaScript. It initializes the Go runtime and executes Go code until it needs // to wait for an event. It does NOT follow the Go ABI. It has two WebAssembly parameters: // R0: argc (i32) // R1: argv (i32) TEXT wasm_export_run(SB),NOSPLIT,$0
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 05 19:28:25 UTC 2023 - 1.5K bytes - Viewed (0)