Search Options

Results per page
Sort
Preferred Languages
Advance

Results 551 - 560 of 710 for jconst (0.05 sec)

  1. cmd/batch-handlers.go

    	"github.com/minio/pkg/v3/console"
    	"github.com/minio/pkg/v3/env"
    	"github.com/minio/pkg/v3/policy"
    	"github.com/minio/pkg/v3/workers"
    	"gopkg.in/yaml.v3"
    )
    
    var globalBatchConfig batch.Config
    
    const (
    	// Keep the completed/failed job stats 3 days before removing it
    	oldJobsExpiration = 3 * 24 * time.Hour
    )
    
    // BatchJobRequest this is an internal data structure not for external consumption.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  2. src/archive/tar/writer_test.go

    	"errors"
    	"io"
    	"io/fs"
    	"maps"
    	"os"
    	"path"
    	"slices"
    	"sort"
    	"strings"
    	"testing"
    	"testing/fstest"
    	"testing/iotest"
    	"time"
    )
    
    func bytediff(a, b []byte) string {
    	const (
    		uniqueA  = "-  "
    		uniqueB  = "+  "
    		identity = "   "
    	)
    	var ss []string
    	sa := strings.Split(strings.TrimSpace(hex.Dump(a)), "\n")
    	sb := strings.Split(strings.TrimSpace(hex.Dump(b)), "\n")
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Sep 23 14:32:33 UTC 2024
    - 39.4K bytes
    - Viewed (0)
  3. internal/grid/handlers.go

    // HandlerID is a handler identifier.
    // It is used to determine request routing on the server.
    // Handlers can be registered with a static subroute.
    // Do NOT remove or change the order of existing handlers.
    const (
    	// handlerInvalid is reserved to check for uninitialized values.
    	handlerInvalid HandlerID = iota
    	HandlerLockLock
    	HandlerLockRLock
    	HandlerLockUnlock
    	HandlerLockRUnlock
    	HandlerLockRefresh
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 27.7K bytes
    - Viewed (0)
  4. okhttp-tls/src/main/kotlin/okhttp3/tls/HeldCertificate.kt

          return KeyPairGenerator.getInstance(keyAlgorithm).run {
            initialize(keySize, SecureRandom())
            generateKeyPair()
          }
        }
    
        companion object {
          private const val DEFAULT_DURATION_MILLIS = 1000L * 60 * 60 * 24 // 24 hours.
        }
      }
    
      companion object {
        private val PEM_REGEX = Regex("""-----BEGIN ([!-,.-~ ]*)-----([^-]*)-----END \1-----""")
    
        /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 21.6K bytes
    - Viewed (0)
  5. istioctl/pkg/writer/envoy/configdump/listener.go

    	"istio.io/istio/istioctl/pkg/util/proto"
    	"istio.io/istio/pilot/pkg/networking/util"
    	"istio.io/istio/pilot/pkg/util/protoconv"
    	v3 "istio.io/istio/pilot/pkg/xds/v3"
    	"istio.io/istio/pkg/wellknown"
    )
    
    const (
    	// HTTPListener identifies a listener as being of HTTP type by the presence of an HTTP connection manager filter
    	HTTPListener = wellknown.HTTPConnectionManager
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Nov 29 12:37:14 UTC 2023
    - 18.1K bytes
    - Viewed (0)
  6. internal/s3select/genmessage.go

    // ====================
    // Header specification
    // --------------------
    // Continuation messages contain two headers, as follows:
    // https://docs.aws.amazon.com/AmazonS3/latest/API/images/s3select-frame-diagram-cont.png
    //
    // Payload specification
    // ---------------------
    // Continuation messages have no payload.
    func genContinuationMessage() {
    	buf := new(bytes.Buffer)
    
    	buf.WriteByte(13)
    	buf.WriteString(":message-type")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 19 01:35:22 UTC 2021
    - 4.4K bytes
    - Viewed (0)
  7. cmd/sftp-server-driver.go

    	"github.com/minio/pkg/v3/mimedb"
    	"github.com/pkg/sftp"
    	"golang.org/x/crypto/ssh"
    )
    
    // Maximum write offset for incoming SFTP blocks.
    // Set to 100MiB to prevent hostile DOS attacks.
    const ftpMaxWriteOffset = 100 << 20
    
    type sftpDriver struct {
    	permissions *ssh.Permissions
    	endpoint    string
    }
    
    //msgp:ignore sftpMetrics
    type sftpMetrics struct{}
    
    var globalSftpMetrics sftpMetrics
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 05 07:51:13 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb/NtlmContext.java

            }
        }
    
    
        private static byte[] deriveKey ( byte[] masterKey, String cnst ) {
            MessageDigest md5 = Crypto.getMD5();
            md5.update(masterKey);
            md5.update(cnst.getBytes(StandardCharsets.US_ASCII));
            md5.update((byte) 0);
            return md5.digest();
        }
    
    
        @Override
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Tue Jul 07 12:07:20 UTC 2020
    - 15.7K bytes
    - Viewed (0)
  9. internal/s3select/csv/reader.go

    	dst = append(dst, in...)
    	return dst, err
    }
    
    // csvSplitSize is the size of each block.
    // Blocks will read this much and find the first following newline.
    // 128KB appears to be a very reasonable default.
    const csvSplitSize = 128 << 10
    
    // startReaders will read the header if needed and spin up a parser
    // and a number of workers based on GOMAXPROCS.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  10. internal/event/target/amqp.go

    	QueueDir          string   `json:"queueDir"`
    	QueueLimit        uint64   `json:"queueLimit"`
    }
    
    //lint:file-ignore ST1003 We cannot change these exported names.
    
    // AMQP input constants.
    const (
    	AmqpQueueDir   = "queue_dir"
    	AmqpQueueLimit = "queue_limit"
    
    	AmqpURL               = "url"
    	AmqpExchange          = "exchange"
    	AmqpRoutingKey        = "routing_key"
    	AmqpExchangeType      = "exchange_type"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 10K bytes
    - Viewed (0)
Back to top