Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 1,387 for funcs (0.03 sec)

  1. cmd/erasure-healing-common.go

    		return checkPartDiskNotFound
    	default:
    		return checkPartUnknown
    	}
    }
    
    func partNeedsHealing(partErrs []int) bool {
    	return slices.IndexFunc(partErrs, func(i int) bool { return i != checkPartSuccess && i != checkPartUnknown }) > -1
    }
    
    func hasPartErr(partErrs []int) bool {
    	return slices.IndexFunc(partErrs, func(i int) bool { return i != checkPartSuccess }) > -1
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  2. tests/serializer_test.go

    	}
    	return nil
    }
    
    func (es EncryptedString) Value(ctx context.Context, field *schema.Field, dst reflect.Value, fieldValue interface{}) (interface{}, error) {
    	return "hello" + string(es), nil
    }
    
    type CustomSerializer struct {
    	prefix []byte
    }
    
    func NewCustomSerializer(prefix string) *CustomSerializer {
    	return &CustomSerializer{prefix: []byte(prefix)}
    }
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Fri Apr 21 14:09:38 UTC 2023
    - 7.6K bytes
    - Viewed (0)
  3. internal/store/batch_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package store
    
    import (
    	"context"
    	"sync"
    	"testing"
    	"time"
    )
    
    func TestBatchCommit(t *testing.T) {
    	defer func() {
    		if err := tearDownQueueStore(); err != nil {
    			t.Fatalf("Failed to tear down store; %v", err)
    		}
    	}()
    	store, err := setUpQueueStore(queueDir, 100)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  4. schema/field.go

    	Schema                 *Schema
    	EmbeddedSchema         *Schema
    	OwnerSchema            *Schema
    	ReflectValueOf         func(context.Context, reflect.Value) reflect.Value
    	ValueOf                func(context.Context, reflect.Value) (value interface{}, zero bool)
    	Set                    func(context.Context, reflect.Value, interface{}) error
    	Serializer             SerializerInterface
    	NewValuePool           FieldNewValuePool
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Apr 15 03:20:20 UTC 2024
    - 32K bytes
    - Viewed (0)
  5. cmd/erasure-metadata.go

    // GetChecksumInfo - get checksum of a part.
    func (e ErasureInfo) GetChecksumInfo(partNumber int) (ckSum ChecksumInfo) {
    	for _, sum := range e.Checksums {
    		if sum.PartNumber == partNumber {
    			// Return the checksum
    			return sum
    		}
    	}
    	return ChecksumInfo{Algorithm: DefaultBitrotAlgorithm}
    }
    
    // ShardFileSize - returns final erasure size from original size.
    func (e ErasureInfo) ShardFileSize(totalLength int64) int64 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 21.3K bytes
    - Viewed (0)
  6. internal/dsync/dsync-server_test.go

    	responseDelay int64
    }
    
    func (l *lockServer) setRefreshReply(refreshed bool) {
    	l.mutex.Lock()
    	defer l.mutex.Unlock()
    	l.lockNotFound = !refreshed
    }
    
    func (l *lockServer) setResponseDelay(responseDelay time.Duration) {
    	atomic.StoreInt64(&l.responseDelay, int64(responseDelay))
    }
    
    func (l *lockServer) Lock(args *LockArgs) (reply bool, err error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jan 23 16:46:37 UTC 2023
    - 8.3K bytes
    - Viewed (0)
  7. utils/utils_test.go

    	"errors"
    	"math"
    	"strings"
    	"testing"
    	"time"
    )
    
    func TestIsValidDBNameChar(t *testing.T) {
    	for _, db := range []string{"db", "dbName", "db_name", "db1", "1dbname", "db$name"} {
    		if fields := strings.FieldsFunc(db, IsValidDBNameChar); len(fields) != 1 {
    			t.Fatalf("failed to parse db name %v", db)
    		}
    	}
    }
    
    func TestCheckTruth(t *testing.T) {
    	checkTruthTests := []struct {
    		v   string
    		out bool
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Aug 22 11:03:42 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  8. internal/config/identity/openid/provider/keycloak.go

    func WithAdminURL(url string) Option {
    	return func(p *KeycloakProvider) {
    		p.adminURL = url
    	}
    }
    
    // WithRealm provide realm configuration for Keycloak
    func WithRealm(realm string) Option {
    	return func(p *KeycloakProvider) {
    		p.realm = realm
    	}
    }
    
    // KeyCloak initializes a new keycloak provider
    func KeyCloak(opts ...Option) (Provider, error) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jul 14 18:12:07 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  9. cni/test/install_cni.go

    	}
    	t.Logf("Created temporary dir: %v", tempDir)
    	return tempDir
    }
    
    func ls(dir string, t *testing.T) []string {
    	files, err := os.ReadDir(dir)
    	t.Helper()
    	if err != nil {
    		t.Fatalf("Failed to list files, err: %v", err)
    	}
    	return slices.Map(files, func(e os.DirEntry) string {
    		return e.Name()
    	})
    }
    
    func cp(src, dest string, t *testing.T) {
    	t.Helper()
    	data, err := os.ReadFile(src)
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 18:38:14 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  10. internal/bucket/replication/replication.go

    	ExistingObjectReplicationType
    	ResyncReplicationType
    	AllReplicationType
    )
    
    // Valid returns true if replication type is set
    func (t Type) Valid() bool {
    	return t > 0
    }
    
    // IsDataReplication returns true if content being replicated
    func (t Type) IsDataReplication() bool {
    	switch t {
    	case ObjectReplicationType, HealReplicationType, ExistingObjectReplicationType:
    		return true
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Mar 28 17:44:56 UTC 2024
    - 8.9K bytes
    - Viewed (0)
Back to top