Search Options

Results per page
Sort
Preferred Languages
Advance

Results 361 - 370 of 710 for jconst (0.04 sec)

  1. internal/config/batch/batch.go

    package batch
    
    import (
    	"sync"
    	"time"
    
    	"github.com/minio/minio/internal/config"
    	"github.com/minio/pkg/v3/env"
    )
    
    // Batch job environment variables
    const (
    	ReplicationWorkersWait = "replication_workers_wait"
    	KeyRotationWorkersWait = "keyrotation_workers_wait"
    	ExpirationWorkersWait  = "expiration_workers_wait"
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  2. internal/config/certs.go

    	"github.com/minio/pkg/v3/env"
    )
    
    // EnvCertPassword is the environment variable which contains the password used
    // to decrypt the TLS private key. It must be set if the TLS private key is
    // password protected.
    const EnvCertPassword = "MINIO_CERT_PASSWD"
    
    // ParsePublicCertFile - parses public cert into its *x509.Certificate equivalent.
    func ParsePublicCertFile(certFile string) (x509Certs []*x509.Certificate, err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  3. cmd/metrics-v3-cluster-iam.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"context"
    	"sync/atomic"
    	"time"
    )
    
    const (
    	lastSyncDurationMillis                 = "last_sync_duration_millis"
    	pluginAuthnServiceFailedRequestsMinute = "plugin_authn_service_failed_requests_minute"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 02 08:20:42 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  4. internal/store/batch.go

    package store
    
    import (
    	"context"
    	"errors"
    	"sync"
    	"time"
    )
    
    // ErrBatchFull indicates that the batch is full
    var ErrBatchFull = errors.New("batch is full")
    
    const defaultCommitTimeout = 30 * time.Second
    
    // Batch represents an ordered batch
    type Batch[I any] struct {
    	items  []I
    	limit  uint32
    	store  Store[I]
    	quitCh chan struct{}
    
    	sync.Mutex
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  5. internal/s3select/select.go

    	// dst is optional but will be used if valid.
    	Read(dst sql.Record) (sql.Record, error)
    	Close() error
    }
    
    const (
    	csvFormat     = "csv"
    	jsonFormat    = "json"
    	parquetFormat = "parquet"
    )
    
    // CompressionType - represents value inside <CompressionType/> in request XML.
    type CompressionType string
    
    const (
    	noneType  CompressionType = "none"
    	gzipType  CompressionType = "GZIP"
    	bzip2Type CompressionType = "BZIP2"
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  6. cmd/os_unix.go

    		if osIsExist(err) {
    			return nil
    		}
    		return err
    	}
    
    	return nil
    }
    
    // The buffer must be at least a block long.
    // refer https://github.com/golang/go/issues/24015
    const blockSize = 8 << 10 // 8192
    
    // By default at least 128 entries in single getdents call (1MiB buffer)
    var (
    	direntPool = sync.Pool{
    		New: func() interface{} {
    			buf := make([]byte, blockSize*128)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  7. .teamcity/src/main/kotlin/common/extensions.kt

    import jetbrains.buildServer.configs.kotlin.failureConditions.BuildFailureOnText
    import jetbrains.buildServer.configs.kotlin.failureConditions.failOnText
    import jetbrains.buildServer.configs.kotlin.ui.add
    import java.util.Locale
    
    const val pluginPortalUrlOverride = "-Dorg.gradle.internal.plugins.portal.url.override=%gradle.plugins.portal.url%"
    
    fun BuildSteps.customGradle(init: GradleBuildStep.() -> Unit, custom: GradleBuildStep.() -> Unit): GradleBuildStep =
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Thu Oct 10 03:25:26 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  8. cmd/xl-storage-format-utils_test.go

    				xhttp.AmzBucketReplicationStatus: "",
    				xhttp.ContentType:                "application/json",
    			},
    		},
    	}
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			const n = 100
    			want := hashDeterministicString(tt.arg)
    			m := tt.arg
    			for i := 0; i < n; i++ {
    				if got := hashDeterministicString(m); got != want {
    					t.Errorf("hashDeterministicString() = %v, want %v", got, want)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  9. internal/http/server.go

    )
    
    var (
    	// GlobalMinIOVersion - is sent in the header to all http targets
    	GlobalMinIOVersion string
    
    	// GlobalDeploymentID - is sent in the header to all http targets
    	GlobalDeploymentID string
    )
    
    const (
    	// DefaultIdleTimeout for idle inactive connections
    	DefaultIdleTimeout = 30 * time.Second
    
    	// DefaultReadHeaderTimeout for very slow inactive connections
    	DefaultReadHeaderTimeout = 30 * time.Second
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 19 18:42:47 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  10. internal/crypto/metadata.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package crypto
    
    import (
    	xhttp "github.com/minio/minio/internal/http"
    )
    
    const (
    	// MetaMultipart indicates that the object has been uploaded
    	// in multiple parts - via the S3 multipart API.
    	MetaMultipart = "X-Minio-Internal-Encrypted-Multipart"
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 17:40:33 UTC 2024
    - 6.4K bytes
    - Viewed (0)
Back to top