Search Options

Results per page
Sort
Preferred Languages
Advance

Results 491 - 500 of 1,425 for Func (0.25 sec)

  1. cni/pkg/nodeagent/podcgroupns.go

    	"istio.io/istio/pkg/util/sets"
    )
    
    type PodToNetns map[string]WorkloadInfo
    
    func (p PodToNetns) Close() {
    	for _, wl := range p {
    		wl.Netns.Close()
    	}
    }
    
    type PodNetnsFinder interface {
    	FindNetnsForPods(filter map[types.UID]*corev1.Pod) (PodToNetns, error)
    }
    
    type PodNetnsProcFinder struct {
    	proc fs.FS
    }
    
    func NewPodNetnsProcFinder(proc fs.FS) *PodNetnsProcFinder {
    	return &PodNetnsProcFinder{proc: proc}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Apr 12 21:47:31 UTC 2024
    - 11K bytes
    - Viewed (0)
  2. internal/s3select/json/preader.go

    func (r *PReader) startReaders() {
    	r.bufferPool.New = func() interface{} {
    		return make([]byte, jsonSplitSize+1024)
    	}
    
    	// Create queue
    	r.queue = make(chan *queueItem, runtime.GOMAXPROCS(0))
    	r.input = make(chan *queueItem, runtime.GOMAXPROCS(0))
    	r.readerWg.Add(1)
    
    	// Start splitter
    	go func() {
    		defer close(r.input)
    		defer close(r.queue)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  3. internal/event/name.go

    }
    
    // Mask returns the type as mask.
    // Compound "All" types are expanded.
    func (name Name) Mask() uint64 {
    	if name < objectSingleTypesEnd {
    		return 1 << (name - 1)
    	}
    	var mask uint64
    	for _, n := range name.Expand() {
    		mask |= 1 << (n - 1)
    	}
    	return mask
    }
    
    // String - returns string representation of event type.
    func (name Name) String() string {
    	switch name {
    	case BucketCreated:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 01 01:11:10 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  4. internal/logger/config.go

    }
    
    // NewConfig - initialize new logger config.
    func NewConfig() Config {
    	cfg := Config{
    		// Console logging is on by default
    		Console: Console{
    			Enabled: true,
    		},
    		HTTP:         make(map[string]http.Config),
    		AuditWebhook: make(map[string]http.Config),
    		AuditKafka:   make(map[string]kafka.Config),
    	}
    
    	return cfg
    }
    
    func getCfgVal(envName, key, defaultValue string) string {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 20 16:02:50 UTC 2024
    - 18.3K bytes
    - Viewed (0)
  5. clause/group_by.go

    package clause
    
    // GroupBy group by clause
    type GroupBy struct {
    	Columns []Column
    	Having  []Expression
    }
    
    // Name from clause name
    func (groupBy GroupBy) Name() string {
    	return "GROUP BY"
    }
    
    // Build build group by clause
    func (groupBy GroupBy) Build(builder Builder) {
    	for idx, column := range groupBy.Columns {
    		if idx > 0 {
    			builder.WriteByte(',')
    		}
    
    		builder.WriteQuoted(column)
    	}
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Mar 30 10:28:09 UTC 2021
    - 1K bytes
    - Viewed (0)
  6. cmd/erasure-object_test.go

    	}
    	gr.Close()
    	if !bytes.Equal(output.Bytes(), bigData) {
    		t.Fatalf("Corrupted data found")
    	}
    }
    
    func TestObjectQuorumFromMeta(t *testing.T) {
    	ExecObjectLayerTestWithDirs(t, testObjectQuorumFromMeta)
    }
    
    func testObjectQuorumFromMeta(obj ObjectLayer, instanceType string, dirs []string, t TestErrHandler) {
    	bucket := getRandomBucketName()
    
    	var opts ObjectOptions
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  7. istioctl/pkg/injector/injector-list_test.go

    				},
    			},
    			expectedRevision: "test-anno",
    		},
    	}
    	for i, c := range cases {
    		t.Run(fmt.Sprintf("case %d %s", i, c.name), func(t *testing.T) {
    			assert.Equal(t, c.expectedRevision, extractRevisionFromPod(c.pod))
    		})
    	}
    }
    
    func Test_getNamespaces(t *testing.T) {
    	createNamespace := func(name string, labels map[string]string) *corev1.Namespace {
    		return &corev1.Namespace{
    			ObjectMeta: metav1.ObjectMeta{
    				Name:   name,
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  8. schema/callbacks_test.go

    import (
    	"reflect"
    	"sync"
    	"testing"
    
    	"gorm.io/gorm"
    	"gorm.io/gorm/schema"
    )
    
    type UserWithCallback struct{}
    
    func (UserWithCallback) BeforeSave(*gorm.DB) error {
    	return nil
    }
    
    func (UserWithCallback) AfterCreate(*gorm.DB) error {
    	return nil
    }
    
    func TestCallback(t *testing.T) {
    	user, err := schema.Parse(&UserWithCallback{}, &sync.Map{}, schema.NamingStrategy{})
    	if err != nil {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Jan 06 07:02:53 UTC 2022
    - 939 bytes
    - Viewed (0)
  9. cmd/last-minute_gen.go

    	}
    	o = bts
    	return
    }
    
    // Msgsize returns an upper bound estimate of the number of bytes occupied by the serialized message
    func (z AccElem) Msgsize() (s int) {
    	s = 1 + 6 + msgp.Int64Size + 5 + msgp.Int64Size + 2 + msgp.Int64Size
    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *LastMinuteHistogram) DecodeMsg(dc *msgp.Reader) (err error) {
    	var zb0001 uint32
    	zb0001, err = dc.ReadArrayHeader()
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 05 21:45:49 UTC 2022
    - 17.2K bytes
    - Viewed (0)
  10. docs/debugging/pprofgoparser/main.go

    	goTime, less, margin time.Duration
    )
    
    func init() {
    	flag.DurationVar(&less, "less", 0, "goroutine waiting less than the specified time")
    	flag.DurationVar(&goTime, "time", 0, "goroutine waiting for exactly the specified time")
    	flag.DurationVar(&margin, "margin", 0, "margin time")
    	flag.StringVar(&searchText, "search", "", "Regex to search for a text in one goroutine stacktrace")
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Mar 06 11:43:16 UTC 2024
    - 3.4K bytes
    - Viewed (0)
Back to top