Search Options

Results per page
Sort
Preferred Languages
Advance

Results 771 - 780 of 1,423 for Func (0.06 sec)

  1. internal/s3select/sql/timestampfuncs.go

    	layoutDay,
    	layoutMinute,
    	layoutSecond,
    	layoutNanosecond,
    }
    
    func parseSQLTimestamp(s string) (t time.Time, err error) {
    	for _, f := range tformats {
    		t, err = time.Parse(f, s)
    		if err == nil {
    			break
    		}
    	}
    	return
    }
    
    // FormatSQLTimestamp - returns the a string representation of the
    // timestamp as used in S3 Select
    func FormatSQLTimestamp(t time.Time) string {
    	_, zoneOffset := t.Zone()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 4.8K bytes
    - Viewed (0)
  2. cmd/local-locker_test.go

    	}
    }
    
    func Test_localLocker_expireOldLocksExpire(t *testing.T) {
    	rng := rand.New(rand.NewSource(0))
    	quorum := 0
    	// Numbers of unique locks
    	for _, locks := range []int{100, 1000, 1e6} {
    		if testing.Short() && locks > 100 {
    			continue
    		}
    		t.Run(fmt.Sprintf("%d-locks", locks), func(t *testing.T) {
    			// Number of readers per lock...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  3. internal/event/target/amqp.go

    func (target *AMQPTarget) IsActive() (bool, error) {
    	if err := target.init(); err != nil {
    		return false, err
    	}
    
    	return target.isActive()
    }
    
    func (target *AMQPTarget) isActive() (bool, error) {
    	ch, _, err := target.channel()
    	if err != nil {
    		return false, err
    	}
    	defer func() {
    		ch.Close()
    	}()
    	return true, nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
  4. internal/store/queuestore_test.go

    	testItemExt = ".test"
    )
    
    // Initialize the queue store.
    func setUpQueueStore(directory string, limit uint64) (Store[TestItem], error) {
    	queueStore := NewQueueStore[TestItem](queueDir, limit, testItemExt)
    	if oErr := queueStore.Open(); oErr != nil {
    		return nil, oErr
    	}
    	return queueStore, nil
    }
    
    // Tear down queue store.
    func tearDownQueueStore() error {
    	return os.RemoveAll(queueDir)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  5. cmd/net.go

    func mustSplitHostPort(hostPort string) (host, port string) {
    	xh, err := xnet.ParseHost(hostPort)
    	if err != nil {
    		logger.FatalIf(err, "Unable to split host port %s", hostPort)
    	}
    	return xh.Name, xh.Port.String()
    }
    
    // mustGetLocalIPs returns IPs of local interface
    func mustGetLocalIPs() (ipList []net.IP) {
    	ifs, err := net.Interfaces()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 14:34:00 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  6. cmd/object-api-datatypes_gen.go

    	"github.com/tinylib/msgp/msgp"
    )
    
    // MarshalMsg implements msgp.Marshaler
    func (z BackendType) MarshalMsg(b []byte) (o []byte, err error) {
    	o = msgp.Require(b, z.Msgsize())
    	o = msgp.AppendInt(o, int(z))
    	return
    }
    
    // UnmarshalMsg implements msgp.Unmarshaler
    func (z *BackendType) UnmarshalMsg(bts []byte) (o []byte, err error) {
    	{
    		var zb0001 int
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 70.1K bytes
    - Viewed (0)
  7. cmd/globals.go

    )
    
    var globalAuthPluginMutex sync.Mutex
    
    func newGlobalAuthNPluginFn() *idplugin.AuthNPlugin {
    	globalAuthPluginMutex.Lock()
    	defer globalAuthPluginMutex.Unlock()
    	return globalAuthNPlugin
    }
    
    func newGlobalAuthZPluginFn() *polplugin.AuthZPlugin {
    	globalAuthPluginMutex.Lock()
    	defer globalAuthPluginMutex.Unlock()
    	return globalAuthZPlugin
    }
    
    func setGlobalAuthNPlugin(authn *idplugin.AuthNPlugin) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  8. cmd/mrf_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgPartialOperation(b *testing.B) {
    	v := PartialOperation{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgPartialOperation(b *testing.B) {
    	v := PartialOperation{}
    	bts := make([]byte, 0, v.Msgsize())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  9. cmd/tier_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgTierConfigMgr(b *testing.B) {
    	v := TierConfigMgr{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgTierConfigMgr(b *testing.B) {
    	v := TierConfigMgr{}
    	bts := make([]byte, 0, v.Msgsize())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 2.3K bytes
    - Viewed (0)
  10. cmd/metacache-set_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsglistPathOptions(b *testing.B) {
    	v := listPathOptions{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsglistPathOptions(b *testing.B) {
    	v := listPathOptions{}
    	bts := make([]byte, 0, v.Msgsize())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 19 22:54:46 UTC 2024
    - 2.4K bytes
    - Viewed (0)
Back to top