- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 94 for State (0.16 sec)
-
src/bytes/reader_test.go
t.Errorf("%d. got error = %v; want %v", i, err, tt.wanterr) } } } func TestReaderAtConcurrent(t *testing.T) { // Test for the race detector, to verify ReadAt doesn't mutate // any state. r := NewReader([]byte("0123456789")) var wg sync.WaitGroup for i := 0; i < 5; i++ { wg.Add(1) go func(i int) { defer wg.Done() var buf [1]byte r.ReadAt(buf[:], int64(i)) }(i) }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Dec 13 18:45:54 GMT 2021 - 8K bytes - Viewed (0) -
cmd/erasure-server-pool.go
serverPools[i] = poolAvailableSpace{ Index: i, Available: available, MaxUsedPct: maxUsedPct, } } return serverPools } // PoolObjInfo represents the state of current object version per pool type PoolObjInfo struct { Index int ObjInfo ObjectInfo Err error } type poolErrs struct { Index int Err error }
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/erasure-healing.go
switch err { case nil: hr.Before.Drives[i] = madmin.HealDriveInfo{Endpoint: drive, State: madmin.DriveStateOk} hr.After.Drives[i] = madmin.HealDriveInfo{Endpoint: drive, State: madmin.DriveStateOk} case errDiskNotFound: hr.Before.Drives[i] = madmin.HealDriveInfo{State: madmin.DriveStateOffline} hr.After.Drives[i] = madmin.HealDriveInfo{State: madmin.DriveStateOffline} case errVolumeNotFound, errFileNotFound:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 33.1K bytes - Viewed (0) -
cmd/streaming-signature-v4.go
region: region, chunkSHA256Writer: sha256.New(), buffer: make([]byte, 64*1024), debug: false, }, ErrNone } // Represents the overall state that is required for decoding a // AWS Signature V4 chunked reader. type s3ChunkedReader struct { reader *bufio.Reader cred auth.Credentials seedSignature string seedDate time.Time
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 18.2K bytes - Viewed (0) -
istioctl/pkg/admin/istiodconfig.go
} } type istiodConfigLog struct { state flagState } func (id *istiodConfigLog) execute(out io.Writer) error { return id.state.run(out) } func chooseClientFlag(ctrzClient *ControlzClient, reset bool, outputLogLevel, stackTraceLevel, outputFormat string) *istiodConfigLog { if reset { return &istiodConfigLog{state: &resetState{ctrzClient}} } else if outputLogLevel != "" {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 13.5K bytes - Viewed (0) -
cmd/metrics.go
[]string{"type"}, nil), prometheus.GaugeValue, float64(v), string(k), ) } for k, v := range bgSeq.getHealFailedItemsMap() { // healFailedItemsMap stores the endpoint and volume state separated by comma, // split the fields and pass to channel at correct index s := strings.Split(k, ",") ch <- prometheus.MustNewConstMetric( prometheus.NewDesc(
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 02 06:48:36 GMT 2024 - 16.9K bytes - Viewed (0) -
cmd/storage-rest-client.go
return client.endpoint.String() } // IsOnline - returns whether RPC client failed to connect or not. func (client *storageRESTClient) IsOnline() bool { return client.gridConn.State() == grid.StateConnected } // LastConn - returns when the disk is seen to be connected the last time func (client *storageRESTClient) LastConn() time.Time { return client.restClient.LastConn() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
cmd/bucket-replication.go
var replicationStatus replication.StatusType defer func() { if replicationStatus.Empty() { // replication status is empty means // replication was not attempted for some // reason, notify the state of the object // on disk. replicationStatus = ri.ReplicationStatus } auditLogInternal(ctx, AuditLogOptions{ Event: ri.EventType, APIName: ReplicateObjectAPI, Bucket: ri.Bucket,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
istioctl/pkg/writer/ztunnel/configdump/connections.go
return r } return cmp.Compare(a.Info.Namespace, b.Info.Namespace) }) workloads = slices.FilterInPlace(workloads, func(state WorkloadState) bool { if filter.Namespace != "" && filter.Namespace != state.Info.Namespace { return false } return true }) out, err := json.MarshalIndent(workloads, "", " ") if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 22 15:39:28 GMT 2024 - 3.3K bytes - Viewed (0) -
cmd/admin-handlers-site-replication.go
// SRStateEdit - PUT /minio/admin/v3/site-replication/state/edit // // used internally to tell current cluster to update site replication state func (a adminAPIHandlers) SRStateEdit(w http.ResponseWriter, r *http.Request) { ctx := r.Context() objectAPI, _ := validateAdminReq(ctx, w, r, policy.SiteReplicationOperationAction) if objectAPI == nil { return } var state madmin.SRStateEditReq
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 09:40:39 GMT 2024 - 19.4K bytes - Viewed (0)