Search Options

Results per page
Sort
Preferred Languages
Advance

Results 671 - 680 of 1,423 for Func (0.06 sec)

  1. cmd/test-utils_test.go

    func resetGlobalEndpoints() {
    	globalEndpoints = EndpointServerPools{}
    }
    
    func resetGlobalIsErasure() {
    	globalIsErasure = false
    }
    
    // reset global heal state
    func resetGlobalHealState() {
    	// Init global heal state
    	if globalAllHealState == nil {
    		globalAllHealState = newHealState(GlobalContext, false)
    	} else {
    		globalAllHealState.Lock()
    		for _, v := range globalAllHealState.healSeqMap {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  2. istioctl/pkg/version/version.go

    		return remInfo, err
    	}
    }
    
    func getProxyInfoWrapper(ctx cli.Context, opts *clioptions.ControlPlaneOptions) func() (*[]istioVersion.ProxyInfo, error) {
    	return func() (*[]istioVersion.ProxyInfo, error) {
    		client, err := ctx.CLIClientWithRevision(opts.Revision)
    		if err != nil {
    			return nil, err
    		}
    		return proxy.GetProxyInfo(client, ctx.IstioNamespace())
    	}
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 29 21:11:35 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  3. api/go1.16.txt

    pkg os, const ModeType fs.FileMode
    pkg os, func Chmod(string, fs.FileMode) error
    pkg os, func CreateTemp(string, string) (*File, error)
    pkg os, func DirFS(string) fs.FS
    pkg os, func Lstat(string) (fs.FileInfo, error)
    pkg os, func Mkdir(string, fs.FileMode) error
    pkg os, func MkdirAll(string, fs.FileMode) error
    pkg os, func MkdirTemp(string, string) (string, error)
    pkg os, func OpenFile(string, int, fs.FileMode) (*File, error)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Dec 02 16:30:41 UTC 2022
    - 479.2K bytes
    - Viewed (0)
  4. docs/iam/identity-manager-plugin.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package main
    
    import (
    	"encoding/json"
    	"errors"
    	"fmt"
    	"log"
    	"net/http"
    )
    
    func writeErrorResponse(w http.ResponseWriter, err error) {
    	w.WriteHeader(http.StatusBadRequest)
    	json.NewEncoder(w).Encode(map[string]string{
    		"reason": fmt.Sprintf("%v", err),
    	})
    }
    
    type Resp struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 01 21:31:13 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  5. istioctl/pkg/cli/mock_test.go

    	"net/http"
    
    	"k8s.io/cli-runtime/pkg/resource"
    	"k8s.io/client-go/rest/fake"
    	cmdtesting "k8s.io/kubectl/pkg/cmd/testing"
    	"k8s.io/kubectl/pkg/cmd/util"
    
    	"istio.io/istio/pkg/kube"
    )
    
    func init() {
    	MakeKubeFactory = func(k kube.CLIClient) util.Factory {
    		tf := cmdtesting.NewTestFactory()
    		_, _, codec := cmdtesting.NewExternalScheme()
    		tf.UnstructuredClient = &fake.RESTClient{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jun 15 15:02:17 UTC 2023
    - 1.3K bytes
    - Viewed (0)
  6. api/go1.8.txt

    pkg plugin, func Open(string) (*Plugin, error)
    pkg plugin, method (*Plugin) Lookup(string) (Symbol, error)
    pkg plugin, type Plugin struct
    pkg plugin, type Symbol interface {}
    pkg reflect, func Swapper(interface{}) func(int, int)
    pkg runtime, func MutexProfile([]BlockProfileRecord) (int, bool)
    pkg runtime, func SetMutexProfileFraction(int) int
    pkg runtime, type MemStats struct, NumForcedGC uint32
    pkg sort, func Slice(interface{}, func(int, int) bool)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Dec 21 05:25:57 UTC 2016
    - 16.3K bytes
    - Viewed (0)
  7. cmd/metrics-v3-types.go

    // a function to unlock the buckets.
    func (mg *MetricsGroup) LockAndSetBuckets(buckets []string) func() {
    	mg.bucketsLock.Lock()
    	mg.buckets = buckets
    	return func() {
    		mg.bucketsLock.Unlock()
    	}
    }
    
    // MetricFQN - returns the fully qualified name for the given metric name.
    func (mg *MetricsGroup) MetricFQN(name MetricName) string {
    	v, ok := mg.descriptorMap[name]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 30 22:28:46 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  8. cmd/copy-part-range.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"context"
    	"net/http"
    	"net/url"
    )
    
    // Writes S3 compatible copy part range error.
    func writeCopyPartErr(ctx context.Context, w http.ResponseWriter, err error, url *url.URL) {
    	switch err {
    	case errInvalidRange:
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrInvalidCopyPartRange), url)
    		return
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 18 03:27:04 UTC 2021
    - 2.5K bytes
    - Viewed (0)
  9. cmd/data-usage-cache.go

    // tiers.
    type allTierStats struct {
    	Tiers map[string]tierStats `msg:"ts"`
    }
    
    func newAllTierStats() *allTierStats {
    	return &allTierStats{
    		Tiers: make(map[string]tierStats),
    	}
    }
    
    func (ats *allTierStats) addSizes(tiers map[string]tierStats) {
    	for tier, st := range tiers {
    		ats.Tiers[tier] = ats.Tiers[tier].add(st)
    	}
    }
    
    func (ats *allTierStats) merge(other *allTierStats) {
    	for tier, st := range other.Tiers {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  10. cmd/handler-api.go

    		default: // in case the channel is blocked...
    		}
    	}
    }
    
    func (t *apiConfig) odirectEnabled() bool {
    	t.mu.RLock()
    	defer t.mu.RUnlock()
    
    	return t.enableODirect
    }
    
    func (t *apiConfig) shouldGzipObjects() bool {
    	t.mu.RLock()
    	defer t.mu.RUnlock()
    
    	return t.gzipObjects
    }
    
    func (t *apiConfig) permitRootAccess() bool {
    	t.mu.RLock()
    	defer t.mu.RUnlock()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 17:07:10 UTC 2024
    - 10.4K bytes
    - Viewed (0)
Back to top