Search Options

Results per page
Sort
Preferred Languages
Advance

Results 681 - 690 of 1,384 for funcs (0.02 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. internal/lsync/lrwmutex.go

    func (lm *LRWMutex) RLock() {
    	const isWriteLock = false
    	lm.lockLoop(context.Background(), lm.id, lm.source, 1<<63-1, isWriteLock)
    }
    
    // GetRLock tries to get a read lock on lm before the timeout occurs.
    func (lm *LRWMutex) GetRLock(ctx context.Context, id string, source string, timeout time.Duration) (locked bool) {
    	const isWriteLock = false
    	return lm.lockLoop(ctx, id, source, timeout, isWriteLock)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 4.8K bytes
    - Viewed (0)
  9. cmd/last-minute.go

    	Size  int64
    	N     int64
    }
    
    // Add a duration to a single element.
    func (a *AccElem) add(dur time.Duration) {
    	if dur < 0 {
    		dur = 0
    	}
    	a.Total += int64(dur)
    	a.N++
    }
    
    // Merge b into a.
    func (a *AccElem) merge(b AccElem) {
    	a.N += b.N
    	a.Total += b.Total
    	a.Size += b.Size
    }
    
    // Avg returns average time spent.
    func (a AccElem) avg() time.Duration {
    	if a.N >= 1 && a.Total > 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 05 17:40:45 UTC 2023
    - 4.8K bytes
    - Viewed (0)
  10. clause/insert_test.go

    package clause_test
    
    import (
    	"fmt"
    	"testing"
    
    	"gorm.io/gorm/clause"
    )
    
    func TestInsert(t *testing.T) {
    	results := []struct {
    		Clauses []clause.Interface
    		Result  string
    		Vars    []interface{}
    	}{
    		{
    			[]clause.Interface{clause.Insert{}},
    			"INSERT INTO `users`", nil,
    		},
    		{
    			[]clause.Interface{clause.Insert{Modifier: "LOW_PRIORITY"}},
    			"INSERT LOW_PRIORITY INTO `users`", nil,
    		},
    		{
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Jun 02 01:18:01 UTC 2020
    - 737 bytes
    - Viewed (0)
Back to top