- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 212 for copts (0.03 sec)
-
internal/cachevalue/cache.go
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 // guaranteed to be called only once. func (t *Cache[T]) InitOnce(ttl time.Duration, opts Opts, update func(ctx context.Context) (T, error)) {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 24 12:50:46 UTC 2024 - 4.4K bytes - Viewed (0) -
internal/http/dial_linux.go
// Enable custom socket send/recv buffers. if opts.SendBufSize > 0 { _ = unix.SetsockoptInt(fd, unix.SOL_SOCKET, unix.SO_SNDBUF, opts.SendBufSize) } if opts.RecvBufSize > 0 { _ = unix.SetsockoptInt(fd, unix.SOL_SOCKET, unix.SO_RCVBUF, opts.RecvBufSize) } if opts.NoDelay { _ = syscall.SetsockoptInt(fd, syscall.IPPROTO_TCP, unix.TCP_NODELAY, 1)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Jul 23 10:53:03 UTC 2024 - 5K bytes - Viewed (3) -
istioctl/pkg/tag/generate.go
func Generate(ctx context.Context, client kube.Client, opts *GenerateOptions, istioNS string) (string, error) { // abort if there exists a revision with the target tag name revWebhookCollisions, err := GetWebhooksWithRevision(ctx, client.Kube(), opts.Tag) if err != nil { return "", err } if !opts.Generate && !opts.Overwrite && len(revWebhookCollisions) > 0 && opts.Tag != DefaultRevisionName {
Registered: Wed Oct 30 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 13.3K bytes - Viewed (0) -
internal/bucket/bandwidth/reader.go
return } r.m.updateMeasurement(r.opts.BucketOptions, uint64(tokens)) return } // NewMonitoredReader returns reference to a monitored reader that throttles reads to configured bandwidth for the // bucket. func NewMonitoredReader(ctx context.Context, m *Monitor, r io.Reader, opts *MonitorReaderOptions) *MonitoredReader { reader := MonitoredReader{ r: r, throttle: m.throttle(opts.BucketOptions), m: m,
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Jul 12 14:57:31 UTC 2024 - 3.2K bytes - Viewed (0) -
tensorflow/c/eager/c_api_test.cc
return; #else TF_Status* status = TF_NewStatus(); TFE_ContextOptions* opts = TFE_NewContextOptions(); TFE_ContextOptionsSetTfrt(opts, tfrt); TFE_ContextOptionsSetAsync(opts, static_cast<unsigned char>(async)); TFE_Context* ctx = TFE_NewContext(opts, status); CHECK_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status); TFE_DeleteContextOptions(opts); TFE_TensorHandle* n = TestMatrixTensorHandle100x100(ctx);
Registered: Tue Oct 29 12:39:09 UTC 2024 - Last Modified: Thu Aug 03 20:50:20 UTC 2023 - 94.6K bytes - Viewed (0) -
internal/bucket/bandwidth/monitor.go
} } func (m *Monitor) init(opts BucketOptions) { m.mlock.Lock() defer m.mlock.Unlock() _, ok := m.bucketsMeasurement[opts] if !ok { m.bucketsMeasurement[opts] = newBucketMeasurement(time.Now()) } } // DeleteBucket deletes monitoring the 'bucket' func (m *Monitor) DeleteBucket(bucket string) { m.tlock.Lock() for opts := range m.bucketsThrottle { if opts.Name == bucket {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Feb 19 22:54:46 UTC 2024 - 6K bytes - Viewed (0) -
tensorflow/c/eager/parallel_device/parallel_device_lib_test.cc
std::unique_ptr<TFE_ContextOptions, decltype(&TFE_DeleteContextOptions)> opts( TFE_NewContextOptions(), TFE_DeleteContextOptions); std::unique_ptr<TF_Buffer, decltype(&TF_DeleteBuffer)> config( TF_CreateConfig( /*xla*/ false, /* gpu_memory_allow_growth */ true, /* num_cpu_devices */ 2), TF_DeleteBuffer); TFE_ContextOptionsSetConfig(opts.get(), config->data, config->length,
Registered: Tue Oct 29 12:39:09 UTC 2024 - Last Modified: Mon Oct 21 04:14:14 UTC 2024 - 15.6K bytes - Viewed (0) -
cmd/object_api_suite_test.go
} var bytesBuffer1 bytes.Buffer var opts ObjectOptions _, err = obj.PutObject(context.Background(), "bucket", "object", mustGetPutObjReader(t, readerEOF, length, "", ""), opts) if err != nil { t.Fatalf("%s: <ERROR> %s", instanceType, err) } err = GetObject(context.Background(), obj, "bucket", "object", 0, length, &bytesBuffer1, "", opts) if err != nil { t.Fatalf("%s: <ERROR> %s", instanceType, err)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Jul 02 15:13:05 UTC 2024 - 33.3K bytes - Viewed (0) -
tensorflow/c/eager/c_api_debug_test.cc
#include "tensorflow/core/platform/test.h" TEST(CApiDebug, ScalarCPU) { TF_Status* status = TF_NewStatus(); TFE_ContextOptions* opts = TFE_NewContextOptions(); TFE_Context* ctx = TFE_NewContext(opts, status); CHECK_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status); TFE_DeleteContextOptions(opts); TFE_TensorHandle* h = TestScalarTensorHandle(ctx, 1.0f); TFE_TensorDebugInfo* debug_info = TFE_TensorHandleTensorDebugInfo(h, status);
Registered: Tue Oct 29 12:39:09 UTC 2024 - Last Modified: Mon Apr 06 22:10:09 UTC 2020 - 2.3K bytes - Viewed (0) -
cmd/naughty-disk_test.go
func (d *naughtyDisk) UpdateMetadata(ctx context.Context, volume, path string, fi FileInfo, opts UpdateMetadataOpts) (err error) { if err := d.calcError(); err != nil { return err } return d.disk.UpdateMetadata(ctx, volume, path, fi, opts) } func (d *naughtyDisk) DeleteVersion(ctx context.Context, volume, path string, fi FileInfo, forceDelMarker bool, opts DeleteOptions) (err error) { if err := d.calcError(); err != nil { return err
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Aug 12 08:38:15 UTC 2024 - 10.1K bytes - Viewed (0)