- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 1,425 for Func (0.04 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)