Search Options

Results per page
Sort
Preferred Languages
Advance

Results 261 - 270 of 1,100 for Utime (0.05 sec)

  1. guava/src/com/google/common/util/concurrent/FakeTimeLimiter.java

    /**
     * A TimeLimiter implementation which actually does not attempt to limit time at all. This may be
     * desirable to use in some unit tests. More importantly, attempting to debug a call which is
     * time-limited would be extremely annoying, so this gives you a time-limiter you can easily swap in
     * for your real time-limiter while you're debugging.
     *
     * @author Kevin Bourrillion
     * @author Jens Nyman
     * @since 1.0
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 14 20:35:03 UTC 2023
    - 3.5K bytes
    - Viewed (0)
  2. internal/s3select/sql/value_contrib.go

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    
    package sql
    
    import "time"
    
    func timestampCompare(op string, left, right time.Time) bool {
    	switch op {
    	case opLt:
    		return left.Before(right)
    	case opLte:
    		return left.Before(right) || left.Equal(right)
    	case opGt:
    		return left.After(right)
    	case opGte:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 1K bytes
    - Viewed (0)
  3. cmd/postpolicyform.go

    }
    
    // PostPolicyForm provides strict static type conversion and validation for Amazon S3's POST policy JSON string.
    type PostPolicyForm struct {
    	Expiration time.Time // Expiration date and time of the POST policy.
    	Conditions struct {  // Conditional policy structure.
    		Policies []struct {
    			Operator string
    			Key      string
    			Value    string
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  4. internal/event/target/mqtt.go

    	"errors"
    	"fmt"
    	"net/url"
    	"os"
    	"path/filepath"
    	"time"
    
    	mqtt "github.com/eclipse/paho.mqtt.golang"
    	"github.com/minio/minio/internal/event"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/minio/internal/once"
    	"github.com/minio/minio/internal/store"
    	xnet "github.com/minio/pkg/v3/net"
    )
    
    const (
    	reconnectInterval = 5 * time.Second
    	storePrefix       = "minio"
    )
    
    // MQTT input constants
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  5. manifests/addons/dashboards/lib/dashboard.libsonnet

    local variables = import './variables.libsonnet';
    
    {
      new(name):
        g.dashboard.new(name)
        + g.dashboard.graphTooltip.withSharedCrosshair()
        + g.dashboard.withRefresh('15s')
        + g.dashboard.time.withFrom('now-30m')
        + g.dashboard.time.withTo('now')
        + g.dashboard.withVariables([variables.datasource]),
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Jun 12 20:46:28 UTC 2024
    - 354 bytes
    - Viewed (0)
  6. cmd/bootstrap-peer-server.go

    		select {
    		case <-ctx.Done():
    			return ctx.Err()
    		default:
    			// Sleep and stagger to avoid blocked CPU and thundering
    			// herd upon start up sequence.
    			time.Sleep(25*time.Millisecond + time.Duration(rand.Int63n(int64(100*time.Millisecond))))
    			retries++
    			// after 20 retries start logging that servers are not reachable yet
    			if retries >= 20 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  7. gorm.go

    	}
    
    	if config.Logger == nil {
    		config.Logger = logger.Default
    	}
    
    	if config.NowFunc == nil {
    		config.NowFunc = func() time.Time { return time.Now().Local() }
    	}
    
    	if dialector != nil {
    		config.Dialector = dialector
    	}
    
    	if config.Plugins == nil {
    		config.Plugins = map[string]Plugin{}
    	}
    
    	if config.cacheStore == nil {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Oct 09 11:29:48 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  8. internal/http/dial_linux.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package http
    
    import (
    	"context"
    	"net"
    	"syscall"
    	"time"
    
    	"github.com/minio/minio/internal/deadlineconn"
    	"golang.org/x/sys/unix"
    )
    
    func setTCPParametersFn(opts TCPOptions) func(network, address string, c syscall.RawConn) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 23 10:53:03 UTC 2024
    - 5K bytes
    - Viewed (0)
  9. cmd/erasure-metadata.go

    	}
    
    	// objProps represents properties that go beyond a single version
    	type objProps struct {
    		succModTime time.Time
    		numVersions int
    	}
    	// Find the successor mod time and numVersions in quorum, otherwise leave the
    	// candidate as found
    	otherPropsMap := make(counterMap[objProps])
    	var candidate FileInfo
    	var found bool
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  10. tests/update_test.go

    	// update with struct
    	time.Sleep(1 * time.Second)
    	DB.Table("users").Where("name in ?", []string{users[1].Name}).Updates(User{Name: "updates_02_newname"})
    
    	var user3 User
    	if err := DB.First(&user3, "name = ?", "updates_02_newname").Error; err != nil {
    		t.Errorf("User2's name should be updated")
    	}
    
    	if user2.UpdatedAt.Format(time.RFC1123Z) == user3.UpdatedAt.Format(time.RFC1123Z) {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Dec 04 03:50:58 UTC 2023
    - 30.3K bytes
    - Viewed (0)
Back to top