- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 128 for Mets (0.16 sec)
-
internal/jwt/parser.go
func NewStandardClaims() *StandardClaims { return &StandardClaims{} } // SetIssuer sets issuer for these claims func (c *StandardClaims) SetIssuer(issuer string) { c.Issuer = issuer } // SetAudience sets audience for these claims func (c *StandardClaims) SetAudience(aud string) { c.Audience = aud } // SetExpiry sets expiry in unix epoch secs func (c *StandardClaims) SetExpiry(t time.Time) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue May 09 07:53:08 GMT 2023 - 13.9K bytes - Viewed (0) -
internal/s3select/simdj/record.go
"github.com/minio/minio/internal/s3select/sql" "github.com/minio/simdjson-go" ) // Record - is JSON record. type Record struct { // object object simdjson.Object } // Get - gets the value for a column name. func (r *Record) Get(name string) (*sql.Value, error) { elem := r.object.FindKey(name, nil) if elem == nil { return nil, nil } return iterToValue(elem.Iter) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jun 01 21:59:40 GMT 2021 - 5.4K bytes - Viewed (0) -
cmd/bucket-targets.go
sys.hMutex.RLock() defer sys.hMutex.RUnlock() if h, ok := sys.hc[ep.Host]; ok { return !h.Online } go sys.initHC(ep) return false } // markOffline sets endpoint to offline if network i/o timeout seen. func (sys *BucketTargetSys) markOffline(ep *url.URL) { sys.hMutex.Lock() defer sys.hMutex.Unlock() if h, ok := sys.hc[ep.Host]; ok { h.Online = false
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 20.9K bytes - Viewed (0) -
buildscripts/verify-build.sh
} function run_test_erasure_sets() { start_minio_erasure_sets (cd "$WORK_DIR" && "$FUNCTIONAL_TESTS") rv=$? pkill minio sleep 3 if [ "$rv" -ne 0 ]; then cat "$WORK_DIR/erasure-minio-sets.log" fi rm -f "$WORK_DIR/erasure-minio-sets.log" return "$rv" } function run_test_pool_erasure_sets() { start_minio_pool_erasure_sets
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 26 05:07:25 GMT 2023 - 6.5K bytes - Viewed (0) -
cmd/iam.go
if !sys.Initialized() { return nil, errServerNotInitialized } return sys.store.ListPolicyDocs(ctx, bucketName) } // SetPolicy - sets a new named policy. func (sys *IAMSys) SetPolicy(ctx context.Context, policyName string, p policy.Policy) (time.Time, error) { if !sys.Initialized() { return time.Time{}, errServerNotInitialized }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1) -
cmd/erasure-object_test.go
if err != nil { t.Fatal(err) } // Cleanup backend directories. defer obj.Shutdown(context.Background()) defer removeRoots(fsDirs) z := obj.(*erasureServerPools) sets := z.serverPools[0] xl := sets.sets[0] origErasureDisks := xl.getDisks() testCases := []struct { bucket string versioned bool object string content []byte }{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 36.8K bytes - Viewed (0) -
docs/debugging/reorder-disks/main.go
"flag" "fmt" "log" "net/url" "os" "path/filepath" "strings" "syscall" "github.com/minio/pkg/v2/ellipses" ) type xl struct { This string `json:"this"` Sets [][]string `json:"sets"` } type format struct { ID string `json:"id"` XL xl `json:"xl"` } func getMountMap() (map[string]string, error) { result := make(map[string]string)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.4K bytes - Viewed (0) -
cmd/erasure-server-pool.go
// Return the disks belonging to the poolIdx, and setIdx. func (z *erasureServerPools) GetDisks(poolIdx, setIdx int) ([]StorageAPI, error) { if poolIdx < len(z.serverPools) && setIdx < len(z.serverPools[poolIdx].sets) { return z.serverPools[poolIdx].sets[setIdx].getDisks(), nil } return nil, fmt.Errorf("Matching pool %s, set %s not found", humanize.Ordinal(poolIdx+1), humanize.Ordinal(setIdx+1)) } // Return the count of disks in each pool
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
cmd/data-usage_test.go
}, { // Gets compacted... path: "bucket/dir1", size: 1302010, objs: 5, oSizes: sizeHistogram{0: 1, 1: 1, 2: 2, 4: 1}, }, { // Gets compacted at this level... path: "bucket/dirwithalot/0", size: filesBelowT, objs: filesBelowT, oSizes: sizeHistogram{0: filesBelowT}, }, { // Gets compacted at this level (below obj threshold)...
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Mar 27 15:10:40 GMT 2024 - 14.1K bytes - Viewed (0) -
internal/kms/policy-manager.go
// DescribePolicy describes a policy by returning its metadata. // e.g. who created the policy at which point in time. DescribePolicy(ctx context.Context, policy string) (*kes.PolicyInfo, error) // GetPolicy gets a policy from KMS. GetPolicy(ctx context.Context, policy string) (*kes.Policy, error) // ListPolicies lists all policies. ListPolicies(ctx context.Context) (*kes.ListIter[string], error)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 01 21:09:42 GMT 2024 - 1.3K bytes - Viewed (0)