Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 1,425 for Func (0.05 sec)

  1. cmd/net_test.go

    			}
    			if !found {
    				t.Fatalf("host: expected = %v, got = %v", testCase.expectedIPList, ipList)
    			}
    		}
    	}
    }
    
    // Tests finalize api endpoints.
    func TestGetAPIEndpoints(t *testing.T) {
    	host, port := globalMinioHost, globalMinioPort
    	defer func() {
    		globalMinioHost, globalMinioPort = host, port
    	}()
    	testCases := []struct {
    		host, port     string
    		expectedResult string
    	}{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 19 08:43:09 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  2. internal/grid/msg.go

    		res = append(res, "SUB")
    	}
    	return "[" + strings.Join(res, ",") + "]"
    }
    
    // Set one or more flags on f.
    func (f *Flags) Set(flags Flags) {
    	*f |= flags
    }
    
    // Clear one or more flags on f.
    func (f *Flags) Clear(flags Flags) {
    	*f &^= flags
    }
    
    // parse an incoming message.
    func (m *message) parse(b []byte) (*subHandlerID, []byte, error) {
    	var sub *subHandlerID
    	if m.Payload == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jul 25 21:07:21 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  3. istioctl/pkg/writer/envoy/configdump/route.go

    	Verbose bool
    }
    
    // Verify returns true if the passed route matches the filter fields
    func (r *RouteFilter) Verify(route *route.RouteConfiguration) bool {
    	if r.Name != "" && r.Name != route.Name {
    		return false
    	}
    	return true
    }
    
    // PrintRouteSummary prints a summary of the relevant routes in the config dump to the ConfigWriter stdout
    func (c *ConfigWriter) PrintRouteSummary(filter RouteFilter) error {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 08 20:44:50 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  4. cmd/server-main.go

    		bootstrapTrace("initBackgroundExpiry", func() {
    			initBackgroundExpiry(GlobalContext, newObject)
    		})
    
    		bootstrapTrace("globalTransitionState.Init", func() {
    			globalTransitionState.Init(newObject)
    		})
    
    		go func() {
    			// Initialize transition tier configuration manager
    			bootstrapTrace("globalTierConfigMgr.Init", func() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 21:50:11 UTC 2024
    - 35.2K bytes
    - Viewed (2)
  5. gorm.go

    	Context                  context.Context
    	Logger                   logger.Interface
    	NowFunc                  func() time.Time
    	CreateBatchSize          int
    }
    
    // Open initialize db session based on dialector
    func Open(dialector Dialector, opts ...Option) (db *DB, err error) {
    	config := &Config{}
    
    	sort.Slice(opts, func(i, j int) bool {
    		_, isConfig := opts[i].(*Config)
    		_, isConfig2 := opts[j].(*Config)
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Oct 09 11:29:48 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  6. cni/pkg/ipset/nldeps_unspecified.go

    import (
    	"errors"
    	"net/netip"
    )
    
    func RealNlDeps() NetlinkIpsetDeps {
    	return &realDeps{}
    }
    
    type realDeps struct{}
    
    func (m *realDeps) ipsetIPHashCreate(name string, v6 bool) error {
    	return errors.New("not implemented on this platform")
    }
    
    func (m *realDeps) destroySet(name string) error {
    	return errors.New("not implemented on this platform")
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Apr 30 22:24:38 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  7. internal/s3select/sql/value_test.go

    // Values should match if type is the same.
    var valueBuilders = []func() *Value{
    	FromNull,
    	func() *Value {
    		return FromBool(true)
    	},
    	func() *Value {
    		return FromBytes([]byte("byte contents"))
    	},
    	func() *Value {
    		return FromFloat(math.Pi)
    	},
    	func() *Value {
    		return FromInt(0x1337)
    	},
    	func() *Value {
    		t, err := time.Parse(time.RFC3339, "2006-01-02T15:04:05Z")
    		if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 12.5K bytes
    - Viewed (0)
  8. internal/dsync/lock-args_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgLockArgs(b *testing.B) {
    	v := LockArgs{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgLockArgs(b *testing.B) {
    	v := LockArgs{}
    	bts := make([]byte, 0, v.Msgsize())
    	bts, _ = v.MarshalMsg(bts[0:0])
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 21 01:09:35 UTC 2023
    - 4.4K bytes
    - Viewed (0)
  9. cni/pkg/nodeagent/pod_cache.go

    type podNetnsCache struct {
    	openNetns func(nspath string) (NetnsCloser, error)
    
    	currentPodCache map[string]WorkloadInfo
    	mu              sync.RWMutex
    }
    
    type WorkloadInfo struct {
    	Workload *zdsapi.WorkloadInfo
    	Netns    NetnsCloser
    }
    
    var _ PodNetnsCache = &podNetnsCache{}
    
    func newPodNetnsCache(openNetns func(nspath string) (NetnsCloser, error)) *podNetnsCache {
    	return &podNetnsCache{
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri May 31 17:18:11 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  10. internal/s3select/jstream/scratch.go

    	fill int
    }
    
    // reset scratch buffer
    func (s *scratch) reset() { s.fill = 0 }
    
    // bytes returns the written contents of scratch buffer
    func (s *scratch) bytes() []byte { return s.data[0:s.fill] }
    
    // grow scratch buffer
    func (s *scratch) grow() {
    	ndata := make([]byte, cap(s.data)*2)
    	copy(ndata, s.data)
    	s.data = ndata
    }
    
    // append single byte to scratch buffer
    func (s *scratch) add(c byte) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 758 bytes
    - Viewed (0)
Back to top