Search Options

Results per page
Sort
Preferred Languages
Advance

Results 231 - 240 of 710 for jconst (0.05 sec)

  1. internal/disk/directio_unix.go

    package disk
    
    import (
    	"os"
    	"syscall"
    
    	"github.com/ncw/directio"
    	"golang.org/x/sys/unix"
    )
    
    // ODirectPlatform indicates if the platform supports O_DIRECT
    const ODirectPlatform = true
    
    // OpenFileDirectIO - bypass kernel cache.
    func OpenFileDirectIO(filePath string, flag int, perm os.FileMode) (*os.File, error) {
    	return directio.OpenFile(filePath, flag, perm)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 17 14:31:36 UTC 2023
    - 1.6K bytes
    - Viewed (0)
  2. istioctl/pkg/ztunnelconfig/ztunnelconfig.go

    		"Filter workloads by namespace field")
    
    	return cmd
    }
    
    // Level is an enumeration of all supported log levels.
    type Level int
    
    const (
    	defaultLoggerName = "level"
    )
    
    const (
    	// OffLevel disables logging
    	OffLevel Level = iota
    	// CriticalLevel enables critical level logging
    	CriticalLevel
    	// ErrorLevel enables error level logging
    	ErrorLevel
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 19:17:45 UTC 2024
    - 22.2K bytes
    - Viewed (0)
  3. internal/config/policy/opa/legacy.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package opa
    
    import (
    	"github.com/minio/minio/internal/config"
    )
    
    // Legacy OPA envs
    const (
    	EnvIamOpaURL       = "MINIO_IAM_OPA_URL"
    	EnvIamOpaAuthToken = "MINIO_IAM_OPA_AUTHTOKEN"
    )
    
    // SetPolicyOPAConfig - One time migration code needed, for migrating from older config to new for PolicyOPAConfig.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 1.4K bytes
    - Viewed (0)
  4. .teamcity/src/main/kotlin/model/FunctionalTestBucketGenerator.kt

    import common.Arch
    import common.Os
    import common.VersionedSettingsBranch
    import configurations.ParallelizationMethod
    import java.io.File
    import java.util.LinkedList
    
    const val MASTER_CHECK_CONFIGURATION = "Gradle_Master_Check"
    const val MAX_PROJECT_NUMBER_IN_BUCKET = 11
    
    /**
     * Process test-class-data.json and generates test-buckets.json
     *
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Thu Aug 29 11:04:49 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  5. cmd/metrics-v3-system-drive.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"context"
    	"strconv"
    
    	"github.com/minio/madmin-go/v3"
    )
    
    // label constants
    const (
    	driveL      = "drive"
    	poolIndexL  = "pool_index"
    	setIndexL   = "set_index"
    	driveIndexL = "drive_index"
    
    	apiL = "api"
    
    	sectorSize = uint64(512)
    	kib        = float64(1 << 10)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun May 12 17:23:50 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  6. cmd/signals.go

    import (
    	"context"
    	"errors"
    	"net/http"
    	"os"
    	"strings"
    	"time"
    
    	"github.com/coreos/go-systemd/v22/daemon"
    	"github.com/minio/minio/internal/logger"
    )
    
    func shutdownHealMRFWithTimeout() {
    	const shutdownTimeout = time.Minute
    
    	finished := make(chan struct{})
    	go func() {
    		globalMRFState.shutdown()
    		close(finished)
    	}()
    	select {
    	case <-time.After(shutdownTimeout):
    	case <-finished:
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 04 17:02:39 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  7. internal/logger/target/types/types.go

    package types
    
    // TargetType indicates type of the target e.g. console, http, kafka
    type TargetType uint8
    
    //go:generate stringer -type=TargetType -trimprefix=Target $GOFILE
    
    // Constants for target types
    const (
    	_ TargetType = iota
    	TargetConsole
    	TargetHTTP
    	TargetKafka
    )
    
    // TargetStats contains statistics for a target.
    type TargetStats struct {
    	// QueueLength is the queue length if any messages are queued.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Nov 10 18:20:21 UTC 2022
    - 1.4K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/UrlComponentEncodingTester.kt

        private const val UNICODE_2 = 0x1a5
    
        /** Arbitrary code point that's 3 bytes in UTF-8 and valid in IdnaMappingTable.txt. */
        private const val UNICODE_3 = 0x2202
    
        /** Arbitrary code point that's 4 bytes in UTF-8 and valid in IdnaMappingTable.txt. */
        private const val UNICODE_4 = 0x1d11e
    
        /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 12.3K bytes
    - Viewed (0)
  9. internal/hash/sha256/sh256.go

    func New() hash.Hash { return sha256.New() }
    
    // Sum256 returns the SHA256 checksum of the data.
    func Sum256(data []byte) [sha256.Size]byte { return sha256.Sum256(data) }
    
    // Size is the size of a SHA256 checksum in bytes.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 26 06:31:35 UTC 2024
    - 1.1K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/internal/tls/OkHostnameVerifier.kt

     * A HostnameVerifier consistent with [RFC 2818][rfc_2818].
     *
     * [rfc_2818]: http://www.ietf.org/rfc/rfc2818.txt
     */
    @Suppress("NAME_SHADOWING")
    object OkHostnameVerifier : HostnameVerifier {
      private const val ALT_DNS_NAME = 2
      private const val ALT_IPA_NAME = 7
    
      override fun verify(
        host: String,
        session: SSLSession,
      ): Boolean {
        return if (!host.isAscii()) {
          false
        } else {
          try {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 15 14:55:09 UTC 2024
    - 7.7K bytes
    - Viewed (0)
Back to top