Search Options

Results per page
Sort
Preferred Languages
Advance

Results 361 - 370 of 1,214 for Func (0.04 sec)

  1. internal/logger/target/kafka/kafka_scram_client_contrib.go

    	"strings"
    
    	"github.com/IBM/sarama"
    	"github.com/xdg/scram"
    
    	"github.com/minio/minio/internal/hash/sha256"
    )
    
    func initScramClient(cfg Config, config *sarama.Config) {
    	switch strings.ToLower(cfg.SASL.Mechanism) {
    	case "sha512":
    		config.Net.SASL.SCRAMClientGeneratorFunc = func() sarama.SCRAMClient { return &XDGSCRAMClient{HashGeneratorFcn: KafkaSHA512} }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Nov 09 04:04:01 UTC 2023
    - 3.3K bytes
    - Viewed (0)
  2. cmd/admin-handlers-config-kv.go

    }
    
    type badConfigErr struct {
    	Err error
    }
    
    // Error - return the error message
    func (bce badConfigErr) Error() string {
    	return bce.Err.Error()
    }
    
    // Unwrap the error to its underlying error.
    func (bce badConfigErr) Unwrap() error {
    	return bce.Err
    }
    
    type setConfigResult struct {
    	Cfg                     config.Config
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  3. schema/naming_test.go

    	}
    }
    
    type CustomReplacer struct {
    	f func(string) string
    }
    
    func (r CustomReplacer) Replace(name string) string {
    	return r.f(name)
    }
    
    func TestCustomReplacer(t *testing.T) {
    	ns := NamingStrategy{
    		TablePrefix:   "public.",
    		SingularTable: true,
    		NameReplacer: CustomReplacer{
    			func(name string) string {
    				replaced := "REPLACED_" + strings.ToUpper(name)
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue May 30 02:00:48 UTC 2023
    - 7K bytes
    - Viewed (0)
  4. cmd/erasure-multipart.go

    }
    
    func (er erasureObjects) getMultipartSHADir(bucket, object string) string {
    	return getSHA256Hash([]byte(pathJoin(bucket, object)))
    }
    
    // checkUploadIDExists - verify if a given uploadID exists and is valid.
    func (er erasureObjects) checkUploadIDExists(ctx context.Context, bucket, object, uploadID string, write bool) (fi FileInfo, metArr []FileInfo, err error) {
    	defer func() {
    		if errors.Is(err, errFileNotFound) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  5. cmd/handler-utils.go

    	}
    	return path, nil
    }
    
    var regexVersion = regexp.MustCompile(`^/minio.*/(v\d+)/.*`)
    
    func extractAPIVersion(r *http.Request) string {
    	if matches := regexVersion.FindStringSubmatch(r.URL.Path); len(matches) > 1 {
    		return matches[1]
    	}
    	return "unknown"
    }
    
    func methodNotAllowedHandler(api string) func(w http.ResponseWriter, r *http.Request) {
    	return errorResponseHandler
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  6. cmd/tier.go

    	}, []string{"tier"}),
    }
    
    func (t *tierMetrics) Observe(tier string, dur time.Duration) {
    	t.histogram.With(prometheus.Labels{"tier": tier}).Observe(dur.Seconds())
    }
    
    func (t *tierMetrics) logSuccess(tier string) {
    	t.Lock()
    	defer t.Unlock()
    
    	stat := t.requestsCount[tier]
    	stat.success++
    	t.requestsCount[tier] = stat
    }
    
    func (t *tierMetrics) logFailure(tier string) {
    	t.Lock()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:44:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  7. internal/bucket/replication/rule.go

    	Status Status `xml:"Status"` // should be set to "Disabled" by default
    }
    
    // IsEmpty returns true if DeleteMarkerReplication is not set
    func (d DeleteMarkerReplication) IsEmpty() bool {
    	return len(d.Status) == 0
    }
    
    // Validate validates whether the status is disabled.
    func (d DeleteMarkerReplication) Validate() error {
    	if d.IsEmpty() {
    		return errDeleteMarkerReplicationMissing
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jan 24 23:22:20 UTC 2022
    - 8.3K bytes
    - Viewed (0)
  8. internal/bucket/replication/tag.go

    	errInvalidTagValue = Errorf("The TagValue you have provided is invalid")
    )
    
    func (tag Tag) String() string {
    	return tag.Key + "=" + tag.Value
    }
    
    // IsEmpty returns whether this tag is empty or not.
    func (tag Tag) IsEmpty() bool {
    	return tag.Key == ""
    }
    
    // Validate checks this tag.
    func (tag Tag) Validate() error {
    	if len(tag.Key) == 0 || utf8.RuneCountInString(tag.Key) > 128 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 1.6K bytes
    - Viewed (0)
  9. clause/insert.go

    package clause
    
    type Insert struct {
    	Table    Table
    	Modifier string
    }
    
    // Name insert clause name
    func (insert Insert) Name() string {
    	return "INSERT"
    }
    
    // Build build insert clause
    func (insert Insert) Build(builder Builder) {
    	if insert.Modifier != "" {
    		builder.WriteString(insert.Modifier)
    		builder.WriteByte(' ')
    	}
    
    	builder.WriteString("INTO ")
    	if insert.Table.Name == "" {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Mar 09 09:07:00 UTC 2020
    - 767 bytes
    - Viewed (0)
  10. cmd/erasure-server-pool.go

    	}
    
    	var unlockOnDefer bool
    	nsUnlocker := func() {}
    	defer func() {
    		if unlockOnDefer {
    			nsUnlocker()
    		}
    	}()
    
    	// Acquire lock
    	if !opts.NoLock {
    		lock := z.NewNSLock(bucket, object)
    		lkctx, err := lock.GetRLock(ctx, globalOperationTimeout)
    		if err != nil {
    			return nil, err
    		}
    		ctx = lkctx.Context()
    		nsUnlocker = func() { lock.RUnlock(lkctx) }
    		unlockOnDefer = true
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
Back to top