- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 453 for ctx_ (0.03 sec)
-
internal/logger/logger.go
logIf(ctx, subsystem, err) } func errToEntry(ctx context.Context, subsystem string, err error, errKind ...interface{}) log.Entry { var l string if anonFlag { l = reflect.TypeOf(err).String() } else { l = fmt.Sprintf("%v (%T)", err, err) } return buildLogEntry(ctx, subsystem, l, getTrace(3), errKind...) } func logToEntry(ctx context.Context, subsystem, message string, errKind ...interface{}) log.Entry {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 22 09:43:48 UTC 2024 - 12.4K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher.go
handlers K8sHandlers dataplane MeshDataplane sockAddress string ctx context.Context } func startCniPluginServer(ctx context.Context, pluginSocket string, handlers K8sHandlers, dataplane MeshDataplane, ) *CniPluginServer { ctx, cancel := context.WithCancel(ctx) mux := http.NewServeMux() s := &CniPluginServer{ handlers: handlers, dataplane: dataplane,
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Tue Jul 02 18:48:50 UTC 2024 - 6.7K bytes - Viewed (0) -
internal/dsync/drwmutex.go
func (dm *DRWMutex) lockBlocking(ctx context.Context, lockLossCallback func(), id, source string, isReadLock bool, opts Options) (locked bool) { restClnts, _ := dm.clnt.GetLockers() // Create lock array to capture the successful lockers locks := make([]string, len(restClnts)) // Add total timeout ctx, cancel := context.WithTimeout(ctx, opts.Timeout) defer cancel()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 15:49:49 UTC 2024 - 20.4K bytes - Viewed (0) -
interfaces.go
} type ParamsFilter interface { ParamsFilter(ctx context.Context, sql string, params ...interface{}) (string, []interface{}) } // ConnPool db conns pool interface type ConnPool interface { PrepareContext(ctx context.Context, query string) (*sql.Stmt, error) ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error) QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Sat Aug 19 13:33:31 UTC 2023 - 2.2K bytes - Viewed (0) -
cmd/bucket-object-lock.go
return mode, retainDate, legalHold, ErrNone } opts, err := getOpts(ctx, rq, bucket, object) if err != nil { return mode, retainDate, legalHold, toAPIErrorCode(ctx, err) } replica := rq.Header.Get(xhttp.AmzBucketReplicationStatus) == replication.Replica.String() if opts.VersionID != "" && !replica { if objInfo, err := getObjectInfoFn(ctx, bucket, object, opts); err == nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 13.2K bytes - Viewed (0) -
cmd/bucket-metadata.go
func readBucketMetadata(ctx context.Context, api ObjectLayer, name string) (BucketMetadata, error) { if name == "" { internalLogIf(ctx, errors.New("bucket name cannot be empty"), logger.WarningKind) return BucketMetadata{}, errInvalidArgument } b := newBucketMetadata(name) configFile := path.Join(bucketMetaPrefix, name, bucketMetadataFile) data, err := readConfig(ctx, api, configFile) if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Aug 28 15:32:18 UTC 2024 - 18.2K bytes - Viewed (0) -
cmd/warm-backend.go
type WarmBackend interface { Put(ctx context.Context, object string, r io.Reader, length int64) (remoteVersionID, error) PutWithMeta(ctx context.Context, object string, r io.Reader, length int64, meta map[string]string) (remoteVersionID, error) Get(ctx context.Context, object string, rv remoteVersionID, opts WarmBackendGetOpts) (io.ReadCloser, error) Remove(ctx context.Context, object string, rv remoteVersionID) error
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 4K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTreeConnection.java
private static final Random RAND = new Random(); protected SmbTreeConnection ( CIFSContext ctx ) { this.ctx = ctx; this.delegate = null; } protected SmbTreeConnection ( SmbTreeConnection treeConnection ) { this.ctx = treeConnection.ctx; this.delegate = treeConnection; } static SmbTreeConnection create ( CIFSContext c ) {
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Tue Jul 07 10:50:16 UTC 2020 - 31K bytes - Viewed (0) -
tensorflow/c/eager/c_api_debug_test.cc
TFE_DeleteContext(ctx); TF_DeleteStatus(status); } TEST(CApiDebug, 2DCPU) { 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 = TestMatrixTensorHandle3X2(ctx);
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Mon Apr 06 22:10:09 UTC 2020 - 2.3K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
) var ztunnelConnected = monitoring.NewGauge("ztunnel_connected", "number of connections to ztunnel") type ZtunnelServer interface { Run(ctx context.Context) PodDeleted(ctx context.Context, uid string) error PodAdded(ctx context.Context, pod *v1.Pod, netns Netns) error Close() error } /* To clean up stale ztunnels we may need to ztunnel to send its (uid, bootid / boot time) to us
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Jul 29 16:08:35 UTC 2024 - 13.2K bytes - Viewed (0)