Search Options

Results per page
Sort
Preferred Languages
Advance

Results 931 - 940 of 1,405 for rfunc (0.08 sec)

  1. istioctl/pkg/writer/envoy/configdump/secret_test.go

    import (
    	"bytes"
    	"fmt"
    	"io"
    	"os"
    	"testing"
    
    	"istio.io/istio/pkg/test/util/assert"
    )
    
    func TestSDSWriter_ValidCert(t *testing.T) {
    	testCases := []struct{ sds string }{
    		{sds: "istio"},
    		{sds: "spire"},
    	}
    	for _, tc := range testCases {
    		t.Run(tc.sds, func(t *testing.T) {
    			configDumpFile, err := os.Open(fmt.Sprintf("testdata/secret/%s/config_dump.json", tc.sds))
    			if err != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Oct 28 19:52:53 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  2. cmd/object-api-interface.go

    // CheckPreconditionFn returns true if precondition check failed.
    type CheckPreconditionFn func(o ObjectInfo) bool
    
    // EvalMetadataFn validates input objInfo and GetObjectInfo error and returns an updated metadata and replication decision if any
    type EvalMetadataFn func(o *ObjectInfo, gerr error) (ReplicateDecision, error)
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. clause/values.go

    package clause
    
    type Values struct {
    	Columns []Column
    	Values  [][]interface{}
    }
    
    // Name from clause name
    func (Values) Name() string {
    	return "VALUES"
    }
    
    // Build build from clause
    func (values Values) Build(builder Builder) {
    	if len(values.Columns) > 0 {
    		builder.WriteByte('(')
    		for idx, column := range values.Columns {
    			if idx > 0 {
    				builder.WriteByte(',')
    			}
    			builder.WriteQuoted(column)
    		}
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sun May 24 03:35:19 UTC 2020
    - 849 bytes
    - Viewed (0)
  6. schema/field_test.go

    package schema_test
    
    import (
    	"context"
    	"database/sql"
    	"reflect"
    	"sync"
    	"testing"
    	"time"
    
    	"gorm.io/gorm"
    	"gorm.io/gorm/schema"
    	"gorm.io/gorm/utils/tests"
    )
    
    func TestFieldValuerAndSetter(t *testing.T) {
    	var (
    		userSchema, _ = schema.Parse(&tests.User{}, &sync.Map{}, schema.NamingStrategy{})
    		user          = tests.User{
    			Model: gorm.Model{
    				ID:        10,
    				CreatedAt: time.Now(),
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Sat Feb 19 09:02:53 UTC 2022
    - 12.7K bytes
    - Viewed (0)
  7. cmd/batch-expire.go

    )
    
    type objInfoCache map[string]*ObjectInfo
    
    func newObjInfoCache() objInfoCache {
    	return objInfoCache(make(map[string]*ObjectInfo))
    }
    
    func (oiCache objInfoCache) Add(toDel ObjectToDelete, oi *ObjectInfo) {
    	oiCache[fmt.Sprintf("%s-%s", toDel.ObjectName, toDel.VersionID)] = oi
    }
    
    func (oiCache objInfoCache) Get(toDel ObjectToDelete) (*ObjectInfo, bool) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  8. cmd/osmetric_string.go

    // Code generated by "stringer -type=osMetric -trimprefix=osMetric os-instrumented.go"; DO NOT EDIT.
    
    package cmd
    
    import "strconv"
    
    func _() {
    	// An "invalid array index" compiler error signifies that the constant values have changed.
    	// Re-run the stringer command to generate them again.
    	var x [1]struct{}
    	_ = x[osMetricRemoveAll-0]
    	_ = x[osMetricMkdirAll-1]
    	_ = x[osMetricMkdir-2]
    	_ = x[osMetricRename-3]
    	_ = x[osMetricOpenFileW-4]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Feb 15 01:09:38 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  9. internal/bucket/object/lock/lock_test.go

    package lock
    
    import (
    	"encoding/xml"
    	"errors"
    	"fmt"
    	"net/http"
    	"reflect"
    	"strings"
    	"testing"
    	"time"
    
    	xhttp "github.com/minio/minio/internal/http"
    )
    
    func TestParseMode(t *testing.T) {
    	testCases := []struct {
    		value        string
    		expectedMode RetMode
    	}{
    		{
    			value:        "governance",
    			expectedMode: RetGovernance,
    		},
    		{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Jun 29 01:20:27 UTC 2024
    - 17.1K bytes
    - Viewed (0)
  10. cmd/xl-storage-format-v1_gen.go

    	"github.com/tinylib/msgp/msgp"
    )
    
    // DecodeMsg implements msgp.Decodable
    func (z *BitrotAlgorithm) DecodeMsg(dc *msgp.Reader) (err error) {
    	{
    		var zb0001 uint
    		zb0001, err = dc.ReadUint()
    		if err != nil {
    			err = msgp.WrapError(err)
    			return
    		}
    		(*z) = BitrotAlgorithm(zb0001)
    	}
    	return
    }
    
    // EncodeMsg implements msgp.Encodable
    func (z BitrotAlgorithm) EncodeMsg(en *msgp.Writer) (err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 41.2K bytes
    - Viewed (0)
Back to top