Search Options

Results per page
Sort
Preferred Languages
Advance

Results 261 - 270 of 2,090 for contexts (0.07 sec)

  1. istioctl/pkg/metrics/metrics_test.go

    func (client mockPromAPI) CleanTombstones(ctx context.Context) error {
    	return nil
    }
    
    func (client mockPromAPI) Config(ctx context.Context) (promv1.ConfigResult, error) {
    	return promv1.ConfigResult{}, nil
    }
    
    func (client mockPromAPI) DeleteSeries(ctx context.Context, matches []string, startTime time.Time, endTime time.Time) error {
    	return nil
    }
    
    func (client mockPromAPI) Flags(ctx context.Context) (promv1.FlagsResult, error) {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Aug 16 01:35:47 UTC 2024
    - 8K bytes
    - Viewed (0)
  2. cmd/iam.go

    // only via IAM notifications.
    func (sys *IAMSys) LoadGroup(ctx context.Context, objAPI ObjectLayer, group string) error {
    	if !sys.Initialized() {
    		return errServerNotInitialized
    	}
    
    	return sys.store.GroupNotificationHandler(ctx, group)
    }
    
    // LoadPolicy - reloads a specific canned policy from backend disks or etcd.
    func (sys *IAMSys) LoadPolicy(ctx context.Context, objAPI ObjectLayer, policyName string) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 29 16:01:48 UTC 2024
    - 74.6K bytes
    - Viewed (0)
  3. cmd/peer-rest-client.go

    func (client *peerRESTClient) GetLocks(ctx context.Context) (lockMap map[string][]lockRequesterInfo, err error) {
    	resp, err := getLocksRPC.Call(ctx, client.gridConn(), grid.NewMSS())
    	if err != nil || resp == nil {
    		return nil, err
    	}
    	return *resp, nil
    }
    
    // LocalStorageInfo - fetch server information for a remote node.
    func (client *peerRESTClient) LocalStorageInfo(ctx context.Context, metrics bool) (info StorageInfo, err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  4. compat/maven-model-builder/src/main/java/org/apache/maven/model/path/ProfileActivationFilePathInterpolator.java

                    return null;
                }
            });
    
            interpolator.addValueSource(new MapBasedValueSource(context.getProjectProperties()));
    
            interpolator.addValueSource(new MapBasedValueSource(context.getUserProperties()));
    
            interpolator.addValueSource(new MapBasedValueSource(context.getSystemProperties()));
    
            String absolutePath = interpolator.interpolate(path, "");
    
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  5. tests/serializer_test.go

    }
    
    func (es EncryptedString) Value(ctx context.Context, field *schema.Field, dst reflect.Value, fieldValue interface{}) (interface{}, error) {
    	return "hello" + string(es), nil
    }
    
    type CustomSerializer struct {
    	prefix []byte
    }
    
    func NewCustomSerializer(prefix string) *CustomSerializer {
    	return &CustomSerializer{prefix: []byte(prefix)}
    }
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Fri Apr 21 14:09:38 UTC 2023
    - 7.6K bytes
    - Viewed (0)
  6. cmd/metrics-v3-cache.go

    		nodesUpDown:         newNodesUpDownCache(),
    	}
    }
    
    type nodesOnline struct {
    	Online, Offline int
    }
    
    func newNodesUpDownCache() *cachevalue.Cache[nodesOnline] {
    	loadNodesUpDown := func(ctx context.Context) (v nodesOnline, err error) {
    		v.Online, v.Offline = globalNotificationSys.GetPeerOnlineCount()
    		return
    	}
    	return cachevalue.NewFromFunc(1*time.Minute,
    		cachevalue.Opts{ReturnLastGood: true},
    		loadNodesUpDown)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  7. manifests/charts/UPDATING-CHARTS.md

    <!-- markdown-toc start - Don't edit this section. Run M-x markdown-toc-refresh-toc -->
    # Table of Contents
    
    - [Updating charts and values.yaml](#updating-charts-and-valuesyaml)
        - [Acceptable Pull Requests](#acceptable-pull-requests)
        - [Making changes](#making-changes)
        - [Value deprecation](#value-deprecation)
    
    <!-- markdown-toc end -->
    
    # Updating charts and values.yaml
    
    ## Acceptable Pull Requests
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 15 16:31:46 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  8. cmd/admin-handlers-config-kv.go

    			// Logger webhook proxy deleted, apply the dynamic changes
    			applyDynamic(ctx, objectAPI, cfg, config.LoggerWebhookSubSys, r, w)
    		}
    	}
    }
    
    func applyDynamic(ctx context.Context, objectAPI ObjectLayer, cfg config.Config, subSys string,
    	r *http.Request, w http.ResponseWriter,
    ) {
    	// Apply dynamic values.
    	if err := applyDynamicConfigForSubSys(GlobalContext, objectAPI, cfg, subSys); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  9. cmd/object-api-utils.go

    	}
    }
    
    // getDiskInfos returns the disk information for the provided disks.
    // If a disk is nil or an error is returned the result will be nil as well.
    func getDiskInfos(ctx context.Context, disks ...StorageAPI) []*DiskInfo {
    	res := make([]*DiskInfo, len(disks))
    	opts := DiskInfoOptions{}
    	for i, disk := range disks {
    		if disk == nil {
    			continue
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  10. callbacks/update.go

    			for i := 0; i < stmt.ReflectValue.Len(); i++ {
    				if stmt.ReflectValue.CanAddr() {
    					field.Set(stmt.Context, stmt.ReflectValue.Index(i), value)
    				}
    			}
    		}
    	case reflect.Struct:
    		assignValue = func(field *schema.Field, value interface{}) {
    			if stmt.ReflectValue.CanAddr() {
    				field.Set(stmt.Context, stmt.ReflectValue, value)
    			}
    		}
    	default:
    		assignValue = func(field *schema.Field, value interface{}) {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Mar 18 05:44:55 UTC 2024
    - 9.4K bytes
    - Viewed (0)
Back to top