Search Options

Results per page
Sort
Preferred Languages
Advance

Results 971 - 980 of 1,384 for funcs (0.05 sec)

  1. internal/kms/dek_test.go

    		},
    	},
    }
    
    func TestEncodeDecodeDEK(t *testing.T) {
    	for i, test := range dekEncodeDecodeTests {
    		text, err := test.Key.MarshalText()
    		if err != nil {
    			t.Fatalf("Test %d: failed to marshal DEK: %v", i, err)
    		}
    
    		var key DEK
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 07 23:55:37 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  2. internal/logger/legacy.go

    const (
    	legacyEnvAuditLoggerHTTPEndpoint = "MINIO_AUDIT_LOGGER_HTTP_ENDPOINT"
    	legacyEnvLoggerHTTPEndpoint      = "MINIO_LOGGER_HTTP_ENDPOINT"
    )
    
    // SetLoggerHTTPAudit - helper for migrating older config to newer KV format.
    func SetLoggerHTTPAudit(scfg config.Config, k string, args http.Config) {
    	if !args.Enabled {
    		// Do not enable audit targets, if not enabled
    		return
    	}
    	scfg[config.AuditWebhookSubSys][k] = config.KVS{
    		config.KV{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 03 09:47:07 UTC 2023
    - 2K bytes
    - Viewed (0)
  3. callbacks/callbacks.go

    type Config struct {
    	LastInsertIDReversed bool
    	CreateClauses        []string
    	QueryClauses         []string
    	UpdateClauses        []string
    	DeleteClauses        []string
    }
    
    func RegisterDefaultCallbacks(db *gorm.DB, config *Config) {
    	enableTransaction := func(db *gorm.DB) bool {
    		return !db.SkipDefaultTransaction
    	}
    
    	if len(config.CreateClauses) == 0 {
    		config.CreateClauses = createClauses
    	}
    	if len(config.QueryClauses) == 0 {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Oct 27 23:56:55 UTC 2021
    - 3.3K bytes
    - Viewed (0)
  4. cni/pkg/nodeagent/healthServer_test.go

    // limitations under the License.
    
    package nodeagent
    
    import (
    	"net/http"
    	"net/http/httptest"
    	"testing"
    
    	"istio.io/istio/cni/pkg/constants"
    	"istio.io/istio/pkg/test/util/assert"
    )
    
    func TestServer(t *testing.T) {
    	router := http.NewServeMux()
    	installReady, watchReady := initRouter(router)
    
    	assert.Equal(t, installReady.Load(), false)
    	assert.Equal(t, watchReady.Load(), false)
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jan 26 20:34:28 UTC 2024
    - 2K bytes
    - Viewed (0)
  5. istioctl/pkg/tag/generate.go

    }
    
    // Create applies the given tag manifests.
    func Create(client kube.CLIClient, manifests, ns string) error {
    	if err := client.ApplyYAMLContents(ns, manifests); err != nil {
    		return fmt.Errorf("failed to apply tag manifests to cluster: %v", err)
    	}
    	return nil
    }
    
    // generateValidatingWebhook renders a validating webhook configuration from the given tagWebhookConfig.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  6. docs/sts/custom-token-identity.go

    	// Role ARN to use
    	roleArn string
    
    	// Display credentials flag
    	displayCreds bool
    
    	// Credential expiry duration
    	expiryDuration time.Duration
    
    	// Bucket to list
    	bucketToList string
    )
    
    func init() {
    	flag.StringVar(&stsEndpoint, "sts-ep", "http://localhost:9000", "STS endpoint")
    	flag.StringVar(&token, "t", "", "Token to use with AssumeRoleWithCustomToken STS API (required)")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 27 00:58:09 UTC 2022
    - 3.4K bytes
    - Viewed (0)
  7. internal/bucket/bandwidth/reader.go

    }
    
    // MonitorReaderOptions provides configurable options for monitor reader implementation.
    type MonitorReaderOptions struct {
    	BucketOptions
    	HeaderSize int
    }
    
    // Read implements a throttled read
    func (r *MonitoredReader) Read(buf []byte) (n int, err error) {
    	if r.throttle == nil {
    		return r.r.Read(buf)
    	}
    	if r.lastErr != nil {
    		err = r.lastErr
    		return
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 14:57:31 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  8. cmd/metacache_gen.go

    	return
    }
    
    // DecodeMsg implements msgp.Decodable
    func (z *scanStatus) DecodeMsg(dc *msgp.Reader) (err error) {
    	{
    		var zb0001 uint8
    		zb0001, err = dc.ReadUint8()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = scanStatus(zb0001)
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z scanStatus) EncodeMsg(en *msgp.Writer) (err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Nov 08 18:26:08 UTC 2021
    - 10K bytes
    - Viewed (0)
  9. cmd/object-api-datatypes.go

    // ExpiresStr returns a stringified version of Expires header in http.TimeFormat
    func (o ObjectInfo) ExpiresStr() string {
    	var expires string
    	if !o.Expires.IsZero() {
    		expires = o.Expires.UTC().Format(http.TimeFormat)
    	}
    	return expires
    }
    
    // ArchiveInfo returns any saved zip archive meta information.
    // It will be decrypted if needed.
    func (o *ObjectInfo) ArchiveInfo(h http.Header) []byte {
    	if len(o.UserDefined) == 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  10. cmd/handler-utils_test.go

    	"bytes"
    	"context"
    	"encoding/xml"
    	"io"
    	"net/http"
    	"net/textproto"
    	"os"
    	"reflect"
    	"testing"
    
    	"github.com/minio/minio/internal/config"
    )
    
    // Tests validate bucket LocationConstraint.
    func TestIsValidLocationConstraint(t *testing.T) {
    	ctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	obj, fsDir, err := prepareFS(ctx)
    	if err != nil {
    		t.Fatal(err)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 6.1K bytes
    - Viewed (0)
Back to top