Search Options

Results per page
Sort
Preferred Languages
Advance

Results 771 - 780 of 1,349 for Struct (0.05 sec)

  1. cmd/admin-handler-utils.go

    			return nil, cred
    		}
    	}
    	writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrAccessDenied), r.URL)
    	return nil, auth.Credentials{}
    }
    
    // AdminError - is a generic error for all admin APIs.
    type AdminError struct {
    	Code       string
    	Message    string
    	StatusCode int
    }
    
    func (ae AdminError) Error() string {
    	return ae.Message
    }
    
    func toAdminAPIErr(ctx context.Context, err error) APIError {
    	if err == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 03 07:17:20 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  2. internal/event/target/kafka_scram_client_contrib.go

    // XDGSCRAMClient implements the client-side of an authentication
    // conversation with a server.  A new conversation must be created for
    // each authentication attempt.
    type XDGSCRAMClient struct {
    	*scram.Client
    	*scram.ClientConversation
    	scram.HashGeneratorFcn
    }
    
    // Begin constructs a SCRAM client component based on a given hash.Hash
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Nov 09 04:04:01 UTC 2023
    - 3.2K bytes
    - Viewed (0)
  3. cmd/ftp-server.go

    	ftp "goftp.io/server/v2"
    )
    
    var globalRemoteFTPClientTransport = NewRemoteTargetHTTPTransport(true)()
    
    // minioLogger use an instance of this to log in a standard format
    type minioLogger struct{}
    
    // Print implement Logger
    func (log *minioLogger) Print(sessionID string, message interface{}) {
    	if serverDebugLog {
    		fmt.Printf("%s %s\n", sessionID, message)
    	}
    }
    
    // Printf implement Logger
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Mar 09 03:07:08 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  4. schema/naming_test.go

    	}
    
    	columdName := ns.ColumnName("", "NameCID")
    	if columdName != "name_cid" {
    		t.Errorf("invalid column name generated, got %v", columdName)
    	}
    }
    
    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.",
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue May 30 02:00:48 UTC 2023
    - 7K bytes
    - Viewed (0)
  5. cmd/erasure-object_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    }
    
    func TestErasureDeleteObjectBasic(t *testing.T) {
    	testCases := []struct {
    		bucket      string
    		object      string
    		expectedErr error
    	}{
    		{".test", "dir/obj", BucketNameInvalid{Bucket: ".test"}},
    		{"----", "dir/obj", BucketNameInvalid{Bucket: "----"}},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  6. cmd/object-api-putobject_test.go

    		data        = []byte("hello")
    		fiveMBBytes = bytes.Repeat([]byte("a"), 5*humanize.MiByte)
    	)
    	invalidMD5 := getMD5Hash([]byte("meh"))
    	invalidMD5Header := md5Header([]byte("meh"))
    
    	testCases := []struct {
    		bucketName    string
    		objName       string
    		inputData     []byte
    		inputMeta     map[string]string
    		inputSHA256   string
    		inputDataSize int64
    		// expected error output.
    		expectedMd5   string
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 25.8K bytes
    - Viewed (0)
  7. cmd/leak-detect_test.go

    	// pause time (in milliseconds) between each snapshot at the end of the go routine leak detection.
    	leakDetectPauseTimeMs = 50
    )
    
    // LeakDetect - type with  methods for go routine leak detection.
    type LeakDetect struct {
    	relevantRoutines map[string]bool
    }
    
    // NewLeakDetect - Initialize a LeakDetector with the snapshot of relevant Go routines.
    func NewLeakDetect() LeakDetect {
    	snapshot := LeakDetect{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  8. internal/http/transports.go

    	ReadBufferSize  = 64 << 10 // ReadBufferSize 64KiB moving up from 4KiB default
    )
    
    // ConnSettings - contains connection settings.
    type ConnSettings struct {
    	DialContext DialContext // Custom dialContext, DialTimeout is ignored if this is already setup.
    	LookupHost  LookupHost  // Custom lookupHost, is nil on containerized deployments.
    	DialTimeout time.Duration
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  9. internal/arn/arn.go

    const (
    	arnPrefixArn        = "arn"
    	arnPartitionMinio   = "minio"
    	arnServiceIAM       = "iam"
    	arnResourceTypeRole = "role"
    )
    
    // ARN - representation of resources based on AWS ARNs.
    type ARN struct {
    	Partition    string
    	Service      string
    	Region       string
    	ResourceType string
    	ResourceID   string
    }
    
    // Allows english letters, numbers, '.', '-', '_' and '/'. Starts with a
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 08:31:34 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  10. internal/config/crypto_test.go

    package config
    
    import (
    	"bytes"
    	"encoding/hex"
    	"io"
    	"testing"
    
    	"github.com/minio/minio/internal/kms"
    )
    
    var encryptDecryptTests = []struct {
    	Data    []byte
    	Context kms.Context
    }{
    	{
    		Data:    nil,
    		Context: nil,
    	},
    	{
    		Data:    []byte{1},
    		Context: nil,
    	},
    	{
    		Data:    []byte{1},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 07 23:55:37 UTC 2024
    - 3.2K bytes
    - Viewed (0)
Back to top