- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 108 for collection (0.45 sec)
-
internal/config/lambda/event/targetlist.go
) // Target - lambda target interface type Target interface { ID() TargetID IsActive() (bool, error) Send(Event) (*http.Response, error) Stat() TargetStat Close() error } // TargetStats is a collection of stats for multiple targets. type TargetStats struct { TargetStats map[string]TargetStat } // TargetStat is the stats of a single target. type TargetStat struct { ID TargetID
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 07 16:12:41 GMT 2023 - 4.3K bytes - Viewed (0) -
cmd/storage-errors.go
// StorageErr represents error generated by xlStorage call. type StorageErr string func (h StorageErr) Error() string { return string(h) } // Collection of basic errors. var baseErrs = []error{ errDiskNotFound, errFaultyDisk, errFaultyRemoteDisk, } var baseIgnoredErrs = baseErrs // Is a one place function which converts all os.PathError
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6.4K bytes - Viewed (0) -
internal/event/targetlist.go
Save(Event) error SendFromStore(store.Key) error Close() error Store() TargetStore } // TargetStore is a shallow version of a target.Store type TargetStore interface { Len() int } // Stats is a collection of stats for multiple targets. type Stats struct { TotalEvents int64 // Deprecated EventsSkipped int64 CurrentQueuedCalls int64 // Deprecated EventsErrorsTotal int64 // Deprecated
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.2K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
// there were no available workers. func (e *expiryStats) MissedTasks() int64 { return e.missedExpiryTasks.Load() } // MissedFreeVersTasks returns the number of free version collection tasks that // were missed since there were no available workers. func (e *expiryStats) MissedFreeVersTasks() int64 { return e.missedFreeVersTasks.Load() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 33.1K bytes - Viewed (0) -
cmd/api-response.go
type DeleteObjectsResponse struct { XMLName xml.Name `xml:"http://s3.amazonaws.com/doc/2006-03-01/ DeleteResult" json:"-"` // Collection of all deleted objects DeletedObjects []DeletedObject `xml:"Deleted,omitempty"` // Collection of errors deleting certain objects. Errors []DeleteError `xml:"Error,omitempty"` }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 33.3K bytes - Viewed (2) -
cmd/tier.go
) // tierConfigPath refers to remote tier config object name var tierConfigPath = path.Join(minioConfigPrefix, tierConfigFile) const tierCfgRefreshAtHdr = "X-MinIO-TierCfg-RefreshedAt" // TierConfigMgr holds the collection of remote tiers configured in this deployment. type TierConfigMgr struct { sync.RWMutex `msg:"-"` drivercache map[string]WarmBackend `msg:"-"` Tiers map[string]madmin.TierConfig `json:"tiers"`
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 17 05:09:58 GMT 2024 - 15.5K bytes - Viewed (0) -
cmd/object-api-multipart_test.go
if err != nil { // Failed to create newbucket, abort. t.Fatalf("%s : %s", instanceType, err.Error()) } obj.DeleteBucket(context.Background(), "abc", DeleteBucketOptions{}) // Collection of non-exhaustive PutObjectPart test cases, valid errors // and success responses. testCases := []struct { bucketName string objName string uploadID string PartID int
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 77.1K bytes - Viewed (0) -
cmd/storage-datatypes.go
TotalErrorsTimeout uint64 `json:"totalErrsTimeout"` TotalWrites uint64 `json:"totalWrites"` TotalDeletes uint64 `json:"totalDeletes"` } // VolsInfo is a collection of volume(bucket) information type VolsInfo []VolInfo // VolInfo - represents volume stat information. // The above means that any added/deleted fields are incompatible. //
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 15.3K bytes - Viewed (0) -
cmd/storage-rest-server.go
if !s.checkID(p.DiskID) { return grid.NewNPErr(errDiskNotFound) } return grid.NewNPErr(s.getStorage().Delete(context.Background(), p.Volume, p.FilePath, p.Opts)) } // DeleteVersionsErrsResp - collection of delete errors // for bulk version deletes type DeleteVersionsErrsResp struct { Errs []error } // DeleteVersionsHandler - delete a set of a versions.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 44.8K bytes - Viewed (0) -
internal/http/server.go
DefaultMaxHeaderBytes = 1 * humanize.MiByte ) // Server - extended http.Server supports multiple addresses to serve and enhanced connection handling. type Server struct { http.Server Addrs []string // addresses on which the server listens for new connection. TCPOptions TCPOptions // all the configurable TCP conn specific configurable options.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Feb 09 21:25:16 GMT 2024 - 7.7K bytes - Viewed (0)