madmin

package module

Go to main page

Versions in this module

v3

v3.0.103

Apr 1, 2025

Changes in this version

type AdminClient

+ func (adm *AdminClient) ObjectSummary(ctx context.Context, objOpts ObjectSummaryOptions) (objectSummary *ObjectSummary, err error)

+ type BucketEncInfo struct

+ Algorithm string

+ EncKey string

type HealthDataType

+ const HealthDataTypeReplication

type HealthInfo

+ Replication ReplDiagInfo

+ type ObjectMetaSummary struct

+ Drive string

+ Errors []string

+ Filename string

+ Host string

+ IsDeleteMarker bool

+ ModTime int64

+ Signature [4]byte

+ Size int64

+ func (z *ObjectMetaSummary) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *ObjectMetaSummary) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *ObjectMetaSummary) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *ObjectMetaSummary) Msgsize() (s int)

+ func (z *ObjectMetaSummary) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type ObjectPartSummary struct

+ Drive string

+ Filename string

+ Host string

+ Part int

+ Pool int

+ Set int

+ Size int64

+ func (z *ObjectPartSummary) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *ObjectPartSummary) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *ObjectPartSummary) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *ObjectPartSummary) Msgsize() (s int)

+ func (z *ObjectPartSummary) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type ObjectSummary struct

+ DataDir string

+ ErasureDist []uint8

+ Errors []string

+ IsInline bool

+ Metas []*ObjectMetaSummary

+ Name string

+ PartNumbers []int

+ Parts []*ObjectPartSummary

+ func (z *ObjectSummary) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *ObjectSummary) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *ObjectSummary) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *ObjectSummary) Msgsize() (s int)

+ func (z *ObjectSummary) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type ObjectSummaryOptions struct

+ Bucket string

+ Object string

+ func (z *ObjectSummaryOptions) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *ObjectSummaryOptions) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z ObjectSummaryOptions) EncodeMsg(en *msgp.Writer) (err error)

+ func (z ObjectSummaryOptions) MarshalMsg(b []byte) (o []byte, err error)

+ func (z ObjectSummaryOptions) Msgsize() (s int)

+ type ReplDiagBucketReplInfo struct

+ Config replication.Config

+ Encryption ReplDiagEncInfo

+ ExcludedPrefixes []string

+ ILM ReplDiagILMInfo

+ ObjectLocking bool

+ Resync ReplDiagBucketResyncInfo

+ VersionEnabled bool

+ type ReplDiagBucketReplTarget struct

+ Addr string

+ AdminPermissions bool

+ BandwidthLimit uint64

+ CurrentDowntime time.Duration

+ DeleteMarkerReplication bool

+ DeleteReplication bool

+ DisableProxying bool

+ Edge bool

+ ExistingObjectReplication bool

+ HealthCheckDuration time.Duration

+ HeartbeatErrCount int64

+ Latency LatencyStat

+ MetadataSync bool

+ Online bool

+ ReplicationPriority int

+ SourceBucket string

+ SyncReplication bool

+ TargetBucket string

+ TotalDowntime time.Duration

+ type ReplDiagBucketResyncInfo struct

+ FailedCount int64

+ FailedSize int64

+ InProgress bool

+ ReplicatedCount int64

+ ReplicatedSize int64

+ StartTime time.Time

+ type ReplDiagEncInfo struct

+ Enabled bool

+ EncRules []BucketEncInfo

+ type ReplDiagILMInfo struct

+ Enabled bool

+ Rules []ReplDiagILMRule

+ type ReplDiagILMRule struct

+ Expiration bool

+ ID string

+ Transition bool

+ type ReplDiagInfo struct

+ ActiveWorkers WorkerStat

+ Error string

+ Proxied ReplProxyMetric

+ Proxying bool

+ Queued InQueueMetric

+ RDReplicatedBuckets []ReplDiagReplBucket

+ ReplicaCount int64

+ ReplicaSize int64

+ SREnabled bool

+ Sites []ReplDiagSite

+ type ReplDiagNode struct

+ Addr string

+ ILMExpiryInProgress bool

+ IsLeader bool

+ MinIOVersion string

+ PoolID int

+ Uptime int64

+ type ReplDiagReplBucket struct

+ Name string

+ ReplicationInfo ReplDiagBucketReplInfo

+ ReplicationTargets []ReplDiagBucketReplTarget

+ type ReplDiagSite struct

+ Addr string

+ DeploymentID string

+ Info ReplDiagSiteInfo

+ type ReplDiagSiteInfo struct

+ BucketsCount int

+ Edge bool

+ EncryptionEnabled bool

+ ILMEnabled bool

+ ILMExpiryReplication bool

+ LDAPEnabled bool

+ Nodes []ReplDiagNode

+ ObjectLockingEnabled bool

+ OpenIDEnabled bool

+ ReplicatedCount int64

+ ReplicatedSize int64

+ ResyncStatus string

+ Throttle ReplDiagThrottle

+ type ReplDiagThrottle struct

+ IsSet bool

+ Limit uint64

type ServerProperties

+ ILMExpiryInProgress bool

+ IsLeader bool

v3.0.102

Mar 29, 2025

v3.0.101

Mar 29, 2025

Changes in this version

type HealingDisk

+ Reason HealingDriveReason

+ type HealingDriveReason int8

+ const HealingReasonFreshDisk

+ const HealingReasonOfflineDisk

+ func (z *HealingDriveReason) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *HealingDriveReason) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z HealingDriveReason) EncodeMsg(en *msgp.Writer) (err error)

+ func (z HealingDriveReason) MarshalMsg(b []byte) (o []byte, err error)

+ func (z HealingDriveReason) Msgsize() (s int)

v3.0.100

Mar 21, 2025

Changes in this version

+ const BuiltinProvider

+ const CertificateProvider

+ const CustomTokenProvider

+ const K8SProvider

+ const LDAPProvider

+ const OpenIDProvider

type AdminClient

+ func (adm *AdminClient) RevokeTokens(ctx context.Context, opts RevokeTokensReq) error

+ func (adm *AdminClient) RevokeTokensLDAP(ctx context.Context, opts RevokeTokensReq) error

+ func (adm AdminClient) ServiceTelemetry(ctx context.Context, opts ServiceTelemetryOpts, dst chan<- ServiceTelemetry, ...)

+ func (adm AdminClient) ServiceTelemetryStream(ctx context.Context, opts ServiceTelemetryOpts) (io.ReadCloser, error)

+ type RevokeTokensReq struct

+ FullRevoke bool

+ TokenRevokeType string

+ User string

+ func (r *RevokeTokensReq) Validate() error

+ type ServiceTelemetry struct

+ Err error

+ SpanMZ []byte

+ type ServiceTelemetryOpts struct

+ HTTPFilter struct{ ... }

+ ParentOnly bool

+ PubCert []byte

+ SampleRate float64

+ TagKV map[string]string

+ Types TraceType

+ func (z *ServiceTelemetryOpts) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *ServiceTelemetryOpts) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *ServiceTelemetryOpts) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *ServiceTelemetryOpts) Msgsize() (s int)

+ func (z *ServiceTelemetryOpts) UnmarshalMsg(bts []byte) (o []byte, err error)

type TraceType

+ const TraceAdmin

+ const TraceObject

v3.0.99

Mar 13, 2025

Changes in this version

type BatchJobType

+ const BatchJobCatalog

+ type CatalogDataFile struct

+ Key string

+ MD5Checksum string

+ Size uint64

+ type CatalogInfo struct

+ ErrorMsg string

+ LastBucketMatched string

+ LastBucketScanned string

+ LastObjectMatched string

+ LastObjectScanned string

+ ManifestPathBucket string

+ ManifestPathObject string

+ ObjectsMatchedCount uint64

+ ObjectsScannedCount uint64

+ OutputObjectsCount uint64

+ RecordsWrittenCount uint64

+ func (z *CatalogInfo) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *CatalogInfo) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *CatalogInfo) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *CatalogInfo) Msgsize() (s int)

+ func (z *CatalogInfo) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type CatalogManifest struct

+ Files []CatalogDataFile

+ JobID string

+ StartTimestamp string

+ Version CatalogManifestVersion

+ type CatalogManifestVersion string

+ const CatalogManifestVersionV1

type JobMetric

+ Catalog *CatalogInfo

v3.0.98

Mar 13, 2025

Changes in this version

type LicenseInfo

+ func (z *LicenseInfo) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *LicenseInfo) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *LicenseInfo) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *LicenseInfo) Msgsize() (s int)

+ func (z *LicenseInfo) UnmarshalMsg(bts []byte) (o []byte, err error)

type ServerInfo

+ License *LicenseInfo

type ServerProperties

+ License *LicenseInfo

v3.0.97

Mar 12, 2025

Changes in this version

type AdminClient

+ func (adm *AdminClient) GenerateBatchJobV2(ctx context.Context, opts GenerateBatchJobOpts) (template string, apiUnavailable bool, err error)

+ func (adm *AdminClient) GetSupportedBatchJobTypes(ctx context.Context) (supportedTypes []BatchJobType, apiUnavailable bool, err error)

v3.0.96

Mar 6, 2025

v3.0.95

Feb 28, 2025

Changes in this version

type BucketTarget

+ OfflineCount int64

+ func (z *BucketTarget) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *BucketTarget) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *BucketTarget) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *BucketTarget) Msgsize() (s int)

+ func (z *BucketTarget) UnmarshalMsg(bts []byte) (o []byte, err error)

type BucketTargets

+ func (z *BucketTargets) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *BucketTargets) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *BucketTargets) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *BucketTargets) Msgsize() (s int)

+ func (z *BucketTargets) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type Counter struct

+ Last1hr uint64

+ Last1m uint64

+ Total uint64

type Credentials

+ func (z *Credentials) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Credentials) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *Credentials) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *Credentials) Msgsize() (s int)

+ func (z *Credentials) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type DowntimeInfo struct

+ Count StatRecorder

+ Duration StatRecorder

+ func (d *DowntimeInfo) RecordCount(value int64)

+ func (d *DowntimeInfo) RecordDuration(value int64)

+ func (z *DowntimeInfo) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *DowntimeInfo) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *DowntimeInfo) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *DowntimeInfo) Msgsize() (s int)

+ func (z *DowntimeInfo) UnmarshalMsg(bts []byte) (o []byte, err error)

type SRMetric

+ DowntimeInfo DowntimeInfo

type SRMetricsSummary

+ Errors Counter

+ Retries Counter

type ServiceType

+ func (z *ServiceType) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *ServiceType) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z ServiceType) EncodeMsg(en *msgp.Writer) (err error)

+ func (z ServiceType) MarshalMsg(b []byte) (o []byte, err error)

+ func (z ServiceType) Msgsize() (s int)

+ type StatRecorder struct

+ Avg int64

+ Max int64

+ Total int64

+ func (s *StatRecorder) Record(value int64)

+ func (z *StatRecorder) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *StatRecorder) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z StatRecorder) EncodeMsg(en *msgp.Writer) (err error)

+ func (z StatRecorder) MarshalMsg(b []byte) (o []byte, err error)

+ func (z StatRecorder) Msgsize() (s int)

v3.0.94

Feb 21, 2025

Changes in this version

+ type SRSessionPolicy json.RawMessage

+ func (s *SRSessionPolicy) UnmarshalJSON(data []byte) error

+ func (s SRSessionPolicy) MarshalJSON() ([]byte, error)

v3.0.93

Feb 20, 2025

Changes in this version

type MinioInfo

+ TierConfigs []TierConfig

type Partition

+ Major uint32

+ Minor uint32

v3.0.92

Feb 14, 2025

Changes in this version

type NetInfo

+ Settings *NetSettings

+ type NetSettings struct

+ CombinedCount uint32

+ MaxCombined uint32

+ RxMaxPending uint32

+ RxPending uint32

+ TxMaxPending uint32

+ TxPending uint32

v3.0.91

Feb 7, 2025

Changes in this version

type SRAddOptions

+ Force bool

v3.0.90

Jan 25, 2025

Changes in this version

type ServiceTraceOpts

+ Formatting bool

type TraceType

+ const TraceFormatting

v3.0.89

Jan 21, 2025

v3.0.88

Jan 17, 2025

Changes in this version

+ const BucketEventQueueSubSys

v3.0.87

Jan 16, 2025

v3.0.86

Jan 6, 2025

Changes in this version

type ClusterInfo

+ Edition string

type ServerInfo

+ Edition string

type ServerProperties

+ Edition string

v3.0.85

Dec 30, 2024

v3.0.84

Dec 29, 2024

v3.0.83

Dec 29, 2024

Changes in this version

type AdminClient

+ func (adm AdminClient) CredContext() *credentials.CredContext

type MetricsClient

+ func (client *MetricsClient) CredContext() *credentials.CredContext

v3.0.82

Dec 19, 2024

Changes in this version

type ServiceTraceOpts

+ KMS bool

v3.0.81

Dec 18, 2024

Changes in this version

type MetricType

+ const MetricsRuntime

type Metrics

+ Go *RuntimeMetrics

type ProfilerType

+ const ProfilerRuntime

+ type RuntimeMetrics struct

+ FloatMetrics map[string]float64

+ HistMetrics map[string]metrics.Float64Histogram

+ N int

+ UintMetrics map[string]uint64

+ func (m *RuntimeMetrics) Merge(other *RuntimeMetrics)

+ func (z *RuntimeMetrics) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *RuntimeMetrics) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *RuntimeMetrics) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *RuntimeMetrics) Msgsize() (s int)

+ func (z *RuntimeMetrics) UnmarshalMsg(bts []byte) (o []byte, err error)

v3.0.80

Dec 18, 2024

v3.0.79

Dec 13, 2024

Changes in this version

+ const SRIAMItemExternalUser

+ type OpenIDUser struct

+ AccessInfo OpenIDUserAccessInfo

+ type OpenIDUserAccessInfo struct

+ AccessToken string

+ RefreshToken string

+ type SRExternalUser struct

+ APIVersion string

+ IsDeleteReq bool

+ Name string

+ OpenIDUser *OpenIDUser

type SRIAMItem

+ ExternalUser *SRExternalUser

type TimedAction

+ MaxTime uint64

+ MinTime uint64

type TraceType

+ const TraceKMS

+ func FindTraceType(s string) TraceType

v3.0.78

Nov 21, 2024

Changes in this version

type Audit

+ func (z *Audit) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Audit) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z Audit) EncodeMsg(en *msgp.Writer) (err error)

+ func (z Audit) MarshalMsg(b []byte) (o []byte, err error)

+ func (z Audit) Msgsize() (s int)

type BackendDisks

+ func (z *BackendDisks) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *BackendDisks) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z BackendDisks) EncodeMsg(en *msgp.Writer) (err error)

+ func (z BackendDisks) MarshalMsg(b []byte) (o []byte, err error)

+ func (z BackendDisks) Msgsize() (s int)

type BackendInfo

+ func (z *BackendInfo) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *BackendInfo) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *BackendInfo) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *BackendInfo) Msgsize() (s int)

+ func (z *BackendInfo) UnmarshalMsg(bts []byte) (o []byte, err error)

type BackendType

+ func (z *BackendType) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *BackendType) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z BackendType) EncodeMsg(en *msgp.Writer) (err error)

+ func (z BackendType) MarshalMsg(b []byte) (o []byte, err error)

+ func (z BackendType) Msgsize() (s int)

type BatchJobMetrics

+ func (z *BatchJobMetrics) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *BatchJobMetrics) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *BatchJobMetrics) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *BatchJobMetrics) Msgsize() (s int)

+ func (z *BatchJobMetrics) UnmarshalMsg(bts []byte) (o []byte, err error)

type BgHealState

+ func (z *BgHealState) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *BgHealState) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *BgHealState) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *BgHealState) Msgsize() (s int)

+ func (z *BgHealState) UnmarshalMsg(bts []byte) (o []byte, err error)

type BucketScanInfo

+ func (z *BucketScanInfo) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *BucketScanInfo) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *BucketScanInfo) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *BucketScanInfo) Msgsize() (s int)

+ func (z *BucketScanInfo) UnmarshalMsg(bts []byte) (o []byte, err error)

type BucketUsageInfo

+ func (z *BucketUsageInfo) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *BucketUsageInfo) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *BucketUsageInfo) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *BucketUsageInfo) Msgsize() (s int)

+ func (z *BucketUsageInfo) UnmarshalMsg(bts []byte) (o []byte, err error)

type Buckets

+ func (z *Buckets) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Buckets) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z Buckets) EncodeMsg(en *msgp.Writer) (err error)

+ func (z Buckets) MarshalMsg(b []byte) (o []byte, err error)

+ func (z Buckets) Msgsize() (s int)

type CPUMetrics

+ func (z *CPUMetrics) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *CPUMetrics) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *CPUMetrics) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *CPUMetrics) Msgsize() (s int)

+ func (z *CPUMetrics) UnmarshalMsg(bts []byte) (o []byte, err error)

type CacheStats

+ func (z *CacheStats) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *CacheStats) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *CacheStats) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *CacheStats) Msgsize() (s int)

+ func (z *CacheStats) UnmarshalMsg(bts []byte) (o []byte, err error)

type DataUsageInfo

+ func (z *DataUsageInfo) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *DataUsageInfo) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *DataUsageInfo) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *DataUsageInfo) Msgsize() (s int)

+ func (z *DataUsageInfo) UnmarshalMsg(bts []byte) (o []byte, err error)

type DeleteMarkers

+ func (z *DeleteMarkers) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *DeleteMarkers) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z DeleteMarkers) EncodeMsg(en *msgp.Writer) (err error)

+ func (z DeleteMarkers) MarshalMsg(b []byte) (o []byte, err error)

+ func (z DeleteMarkers) Msgsize() (s int)

type Disk

+ func (z *Disk) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Disk) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *Disk) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *Disk) Msgsize() (s int)

+ func (z *Disk) UnmarshalMsg(bts []byte) (o []byte, err error)

type DiskIOStats

+ func (z *DiskIOStats) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *DiskIOStats) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *DiskIOStats) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *DiskIOStats) Msgsize() (s int)

+ func (z *DiskIOStats) UnmarshalMsg(bts []byte) (o []byte, err error)

type DiskMetric

+ func (z *DiskMetric) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *DiskMetric) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *DiskMetric) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *DiskMetric) Msgsize() (s int)

+ func (z *DiskMetric) UnmarshalMsg(bts []byte) (o []byte, err error)

type DiskMetrics

+ func (z *DiskMetrics) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *DiskMetrics) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *DiskMetrics) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *DiskMetrics) Msgsize() (s int)

+ func (z *DiskMetrics) UnmarshalMsg(bts []byte) (o []byte, err error)

type ErasureBackend

+ func (z *ErasureBackend) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *ErasureBackend) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *ErasureBackend) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *ErasureBackend) Msgsize() (s int)

+ func (z *ErasureBackend) UnmarshalMsg(bts []byte) (o []byte, err error)

type ErasureSetInfo

+ func (z *ErasureSetInfo) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *ErasureSetInfo) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *ErasureSetInfo) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *ErasureSetInfo) Msgsize() (s int)

+ func (z *ErasureSetInfo) UnmarshalMsg(bts []byte) (o []byte, err error)

type ExpirationInfo

+ func (z *ExpirationInfo) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *ExpirationInfo) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *ExpirationInfo) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *ExpirationInfo) Msgsize() (s int)

+ func (z *ExpirationInfo) UnmarshalMsg(bts []byte) (o []byte, err error)

type FSBackend

+ func (z *FSBackend) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *FSBackend) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z FSBackend) EncodeMsg(en *msgp.Writer) (err error)

+ func (z FSBackend) MarshalMsg(b []byte) (o []byte, err error)

+ func (z FSBackend) Msgsize() (s int)

type GCStats

+ func (z *GCStats) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *GCStats) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *GCStats) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *GCStats) Msgsize() (s int)

+ func (z *GCStats) UnmarshalMsg(bts []byte) (o []byte, err error)

type HealDriveInfo

+ func (z *HealDriveInfo) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *HealDriveInfo) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z HealDriveInfo) EncodeMsg(en *msgp.Writer) (err error)

+ func (z HealDriveInfo) MarshalMsg(b []byte) (o []byte, err error)

+ func (z HealDriveInfo) Msgsize() (s int)

type HealItemType

+ func (z *HealItemType) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *HealItemType) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z HealItemType) EncodeMsg(en *msgp.Writer) (err error)

+ func (z HealItemType) MarshalMsg(b []byte) (o []byte, err error)

+ func (z HealItemType) Msgsize() (s int)

type HealOpts

+ func (z *HealOpts) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *HealOpts) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *HealOpts) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *HealOpts) Msgsize() (s int)

+ func (z *HealOpts) UnmarshalMsg(bts []byte) (o []byte, err error)

type HealResultItem

+ func (z *HealResultItem) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *HealResultItem) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *HealResultItem) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *HealResultItem) Msgsize() (s int)

+ func (z *HealResultItem) UnmarshalMsg(bts []byte) (o []byte, err error)

type HealScanMode

+ func (z *HealScanMode) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *HealScanMode) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z HealScanMode) EncodeMsg(en *msgp.Writer) (err error)

+ func (z HealScanMode) MarshalMsg(b []byte) (o []byte, err error)

+ func (z HealScanMode) Msgsize() (s int)

type HealStartSuccess

+ func (z *HealStartSuccess) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *HealStartSuccess) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z HealStartSuccess) EncodeMsg(en *msgp.Writer) (err error)

+ func (z HealStartSuccess) MarshalMsg(b []byte) (o []byte, err error)

+ func (z HealStartSuccess) Msgsize() (s int)

type HealStopSuccess

+ func (z *HealStopSuccess) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *HealStopSuccess) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z HealStopSuccess) EncodeMsg(en *msgp.Writer) (err error)

+ func (z HealStopSuccess) MarshalMsg(b []byte) (o []byte, err error)

+ func (z HealStopSuccess) Msgsize() (s int)

type HealTaskStatus

+ func (z *HealTaskStatus) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *HealTaskStatus) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *HealTaskStatus) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *HealTaskStatus) Msgsize() (s int)

+ func (z *HealTaskStatus) UnmarshalMsg(bts []byte) (o []byte, err error)

type HealingDisk

+ func (z *HealingDisk) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *HealingDisk) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *HealingDisk) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *HealingDisk) Msgsize() (s int)

+ func (z *HealingDisk) UnmarshalMsg(bts []byte) (o []byte, err error)

type InfoMessage

+ func (z *InfoMessage) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *InfoMessage) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *InfoMessage) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *InfoMessage) Msgsize() (s int)

+ func (z *InfoMessage) UnmarshalMsg(bts []byte) (o []byte, err error)

type ItemState

+ func (z *ItemState) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *ItemState) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z ItemState) EncodeMsg(en *msgp.Writer) (err error)

+ func (z ItemState) MarshalMsg(b []byte) (o []byte, err error)

+ func (z ItemState) Msgsize() (s int)

type JobMetric

+ func (z *JobMetric) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *JobMetric) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *JobMetric) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *JobMetric) Msgsize() (s int)

+ func (z *JobMetric) UnmarshalMsg(bts []byte) (o []byte, err error)

type KMS

+ func (z *KMS) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *KMS) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *KMS) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *KMS) Msgsize() (s int)

+ func (z *KMS) UnmarshalMsg(bts []byte) (o []byte, err error)

type KeyRotationInfo

+ func (z *KeyRotationInfo) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *KeyRotationInfo) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *KeyRotationInfo) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *KeyRotationInfo) Msgsize() (s int)

+ func (z *KeyRotationInfo) UnmarshalMsg(bts []byte) (o []byte, err error)

type LDAP

+ func (z *LDAP) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *LDAP) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z LDAP) EncodeMsg(en *msgp.Writer) (err error)

+ func (z LDAP) MarshalMsg(b []byte) (o []byte, err error)

+ func (z LDAP) Msgsize() (s int)

type Logger

+ func (z *Logger) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Logger) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z Logger) EncodeMsg(en *msgp.Writer) (err error)

+ func (z Logger) MarshalMsg(b []byte) (o []byte, err error)

+ func (z Logger) Msgsize() (s int)

type MRFStatus

+ func (z *MRFStatus) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *MRFStatus) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z MRFStatus) EncodeMsg(en *msgp.Writer) (err error)

+ func (z MRFStatus) MarshalMsg(b []byte) (o []byte, err error)

+ func (z MRFStatus) Msgsize() (s int)

type MemInfo

+ func (z *MemInfo) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *MemInfo) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *MemInfo) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *MemInfo) Msgsize() (s int)

+ func (z *MemInfo) UnmarshalMsg(bts []byte) (o []byte, err error)

type MemMetrics

+ func (z *MemMetrics) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *MemMetrics) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *MemMetrics) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *MemMetrics) Msgsize() (s int)

+ func (z *MemMetrics) UnmarshalMsg(bts []byte) (o []byte, err error)

type MemStats

+ func (z *MemStats) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *MemStats) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *MemStats) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *MemStats) Msgsize() (s int)

+ func (z *MemStats) UnmarshalMsg(bts []byte) (o []byte, err error)

type MetricType

+ func (z *MetricType) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *MetricType) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z MetricType) EncodeMsg(en *msgp.Writer) (err error)

+ func (z MetricType) MarshalMsg(b []byte) (o []byte, err error)

+ func (z MetricType) Msgsize() (s int)

type Metrics

+ func (z *Metrics) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Metrics) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *Metrics) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *Metrics) Msgsize() (s int)

+ func (z *Metrics) UnmarshalMsg(bts []byte) (o []byte, err error)

type MetricsOptions

+ func (z *MetricsOptions) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *MetricsOptions) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *MetricsOptions) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *MetricsOptions) Msgsize() (s int)

+ func (z *MetricsOptions) UnmarshalMsg(bts []byte) (o []byte, err error)

type NetMetrics

+ func (z *NetMetrics) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *NetMetrics) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *NetMetrics) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *NetMetrics) Msgsize() (s int)

+ func (z *NetMetrics) UnmarshalMsg(bts []byte) (o []byte, err error)

type NodeCommon

+ func (z *NodeCommon) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *NodeCommon) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z NodeCommon) EncodeMsg(en *msgp.Writer) (err error)

+ func (z NodeCommon) MarshalMsg(b []byte) (o []byte, err error)

+ func (z NodeCommon) Msgsize() (s int)

type OSMetrics

+ func (z *OSMetrics) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *OSMetrics) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *OSMetrics) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *OSMetrics) Msgsize() (s int)

+ func (z *OSMetrics) UnmarshalMsg(bts []byte) (o []byte, err error)

type Objects

+ func (z *Objects) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Objects) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z Objects) EncodeMsg(en *msgp.Writer) (err error)

+ func (z Objects) MarshalMsg(b []byte) (o []byte, err error)

+ func (z Objects) Msgsize() (s int)

type RPCMetrics

+ func (z *RPCMetrics) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *RPCMetrics) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *RPCMetrics) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *RPCMetrics) Msgsize() (s int)

+ func (z *RPCMetrics) UnmarshalMsg(bts []byte) (o []byte, err error)

type RealtimeMetrics

+ func (z *RealtimeMetrics) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *RealtimeMetrics) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *RealtimeMetrics) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *RealtimeMetrics) Msgsize() (s int)

+ func (z *RealtimeMetrics) UnmarshalMsg(bts []byte) (o []byte, err error)

type ReplicateInfo

+ func (z *ReplicateInfo) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *ReplicateInfo) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *ReplicateInfo) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *ReplicateInfo) Msgsize() (s int)

+ func (z *ReplicateInfo) UnmarshalMsg(bts []byte) (o []byte, err error)

type ScannerMetrics

+ func (z *ScannerMetrics) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *ScannerMetrics) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *ScannerMetrics) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *ScannerMetrics) Msgsize() (s int)

+ func (z *ScannerMetrics) UnmarshalMsg(bts []byte) (o []byte, err error)

type ServerInfoOpts

+ func (z *ServerInfoOpts) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *ServerInfoOpts) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z ServerInfoOpts) EncodeMsg(en *msgp.Writer) (err error)

+ func (z ServerInfoOpts) MarshalMsg(b []byte) (o []byte, err error)

+ func (z ServerInfoOpts) Msgsize() (s int)

type ServerProperties

+ func (z *ServerProperties) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *ServerProperties) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *ServerProperties) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *ServerProperties) Msgsize() (s int)

+ func (z *ServerProperties) UnmarshalMsg(bts []byte) (o []byte, err error)

type Services

+ func (z *Services) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Services) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *Services) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *Services) Msgsize() (s int)

+ func (z *Services) UnmarshalMsg(bts []byte) (o []byte, err error)

type SetStatus

+ func (z *SetStatus) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *SetStatus) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *SetStatus) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *SetStatus) Msgsize() (s int)

+ func (z *SetStatus) UnmarshalMsg(bts []byte) (o []byte, err error)

type SiteResyncMetrics

+ func (z *SiteResyncMetrics) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *SiteResyncMetrics) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *SiteResyncMetrics) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *SiteResyncMetrics) Msgsize() (s int)

+ func (z *SiteResyncMetrics) UnmarshalMsg(bts []byte) (o []byte, err error)

type Status

+ func (z *Status) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Status) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z Status) EncodeMsg(en *msgp.Writer) (err error)

+ func (z Status) MarshalMsg(b []byte) (o []byte, err error)

+ func (z Status) Msgsize() (s int)

type StorageInfo

+ func (z *StorageInfo) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *StorageInfo) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *StorageInfo) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *StorageInfo) Msgsize() (s int)

+ func (z *StorageInfo) UnmarshalMsg(bts []byte) (o []byte, err error)

type TargetIDStatus

+ func (z *TargetIDStatus) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *TargetIDStatus) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z TargetIDStatus) EncodeMsg(en *msgp.Writer) (err error)

+ func (z TargetIDStatus) MarshalMsg(b []byte) (o []byte, err error)

+ func (z TargetIDStatus) Msgsize() (s int)

type TierStats

+ func (z *TierStats) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *TierStats) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z TierStats) EncodeMsg(en *msgp.Writer) (err error)

+ func (z TierStats) MarshalMsg(b []byte) (o []byte, err error)

+ func (z TierStats) Msgsize() (s int)

type TimedAction

+ func (z *TimedAction) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *TimedAction) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z TimedAction) EncodeMsg(en *msgp.Writer) (err error)

+ func (z TimedAction) MarshalMsg(b []byte) (o []byte, err error)

+ func (z TimedAction) Msgsize() (s int)

type Usage

+ func (z *Usage) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Usage) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z Usage) EncodeMsg(en *msgp.Writer) (err error)

+ func (z Usage) MarshalMsg(b []byte) (o []byte, err error)

+ func (z Usage) Msgsize() (s int)

type Versions

+ func (z *Versions) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *Versions) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z Versions) EncodeMsg(en *msgp.Writer) (err error)

+ func (z Versions) MarshalMsg(b []byte) (o []byte, err error)

+ func (z Versions) Msgsize() (s int)

v3.0.77

Nov 13, 2024

Changes in this version

type AdminClient

+ func (adm *AdminClient) GetLicenseInfo(ctx context.Context) (*LicenseInfo, error)

+ type LicenseInfo struct

+ APIKey string

+ ExpiresAt time.Time

+ ID string

+ IssuedAt time.Time

+ Organization string

+ Plan string

+ Trial bool

v3.0.76

Nov 3, 2024

Changes in this version

type CacheStats

+ Capacity int64

+ Used int64

v3.0.75

Oct 19, 2024

Changes in this version

+ const ErasureSubSys

v3.0.74

Oct 19, 2024

Changes in this version

+ type CacheStats struct

+ Collisions int64

+ DelHits int64

+ DelMisses int64

+ Hits int64

+ Misses int64

type Disk

+ Cache *CacheStats

v3.0.73

Oct 16, 2024

v3.0.72

Oct 14, 2024

Changes in this version

type ILMExpiryRule

+ APIVersion string

type PeerInfo

+ APIVersion string

type ReplicateRemoveStatus

+ APIVersion string

type SRBucketInfo

+ APIVersion string

type SRBucketMeta

+ APIVersion string

type SRBucketStatsSummary

+ APIVersion string

type SRCredInfo

+ APIVersion string

type SRGroupInfo

+ APIVersion string

type SRGroupStatsSummary

+ APIVersion string

type SRIAMItem

+ APIVersion string

type SRIAMPolicy

+ APIVersion string

type SRIAMUser

+ APIVersion string

type SRILMExpiryStatsSummary

+ APIVersion string

type SRInfo

+ APIVersion string

type SRPolicyMapping

+ APIVersion string

type SRPolicyStatsSummary

+ APIVersion string

type SRSTSCredential

+ APIVersion string

type SRSiteSummary

+ APIVersion string

type SRStateInfo

+ APIVersion string

type SRStatusInfo

+ APIVersion string

type SRStatusOptions

+ APIVersion string

type SRSvcAccChange

+ APIVersion string

type SRSvcAccCreate

+ APIVersion string

type SRSvcAccDelete

+ APIVersion string

type SRSvcAccUpdate

+ APIVersion string

type SRUserStatsSummary

+ APIVersion string

type SiteReplicationInfo

+ APIVersion string

v3.0.71

Oct 8, 2024

Changes in this version

type BucketScanInfo

+ Ongoing bool

type ScannerMetrics

+ PerBucketStats map[string][]BucketScanInfo

v3.0.70

Oct 1, 2024

v3.0.69

Sep 28, 2024

Changes in this version

+ const AuditEventQueueSubSys

+ var EOSSubSystems = set.CreateStringSet(CredentialsSubSys, PolicyOPASubSys, PolicyPluginSubSys, IdentityOpenIDSubSys, ...)

type BucketTarget

+ EdgeSyncBeforeExpiry bool

type TargetUpdateType

+ const EdgeExpiryUpdateType

v3.0.68

Sep 14, 2024

Changes in this version

type AdminClient

+ func (adm *AdminClient) ListAccessKeysLDAPBulkWithOpts(ctx context.Context, users []string, opts ListAccessKeysOpts) (map[string]ListAccessKeysLDAPResp, error)

v3.0.67

Sep 14, 2024

Changes in this version

type AdminClient

+ func (adm *AdminClient) ListAccessKeysBulk(ctx context.Context, users []string, opts ListAccessKeysOpts) (map[string]ListAccessKeysResp, error)

type BucketTarget

+ Edge bool

+ type ListAccessKeysOpts struct

+ All bool

+ ListType string

+ type ListAccessKeysResp struct

+ STSKeys []ServiceAccountInfo

+ ServiceAccounts []ServiceAccountInfo

type TargetUpdateType

+ const EdgeUpdateType

v3.0.66

Sep 5, 2024

Changes in this version

type AdminClient

+ func (adm *AdminClient) ImportIAMV2(ctx context.Context, contentReader io.ReadCloser) (iamr ImportIAMResult, err error)

+ type IAMEntities struct

+ GroupPolicies []map[string][]string

+ Groups []string

+ Policies []string

+ STSPolicies []map[string][]string

+ ServiceAccounts []string

+ UserPolicies []map[string][]string

+ Users []string

+ type IAMErrEntities struct

+ GroupPolicies []IAMErrPolicyEntity

+ Groups []IAMErrEntity

+ Policies []IAMErrEntity

+ STSPolicies []IAMErrPolicyEntity

+ ServiceAccounts []IAMErrEntity

+ UserPolicies []IAMErrPolicyEntity

+ Users []IAMErrEntity

+ type IAMErrEntity struct

+ Error error

+ Name string

+ type IAMErrPolicyEntity struct

+ Error error

+ Name string

+ Policies []string

+ type ImportIAMResult struct

+ Added IAMEntities

+ Failed IAMErrEntities

+ Removed IAMEntities

+ Skipped IAMEntities

v3.0.65

Sep 4, 2024

Changes in this version

type AdminClient

+ func (adm *AdminClient) RemoveTierV2(ctx context.Context, tierName string, opts RemoveTierOpts) error

+ type RemoveTierOpts struct

+ Force bool

v3.0.64

Aug 22, 2024

Changes in this version

type HealingDisk

+ RetryAttempts uint64

v3.0.63

Aug 16, 2024

Changes in this version

type HealingDisk

+ Finished bool

v3.0.62

Aug 13, 2024

v3.0.61

Aug 13, 2024

v3.0.60

Jul 31, 2024

Changes in this version

+ const SRBucketMetaTypeCorsConfig

type BucketStatus

+ Cors MetaStatus

type SRBucketInfo

+ CorsConfig *string

+ CorsConfigUpdatedAt time.Time

type SRBucketMeta

+ Cors *string

type SRBucketStatsSummary

+ CorsCfgMismatch bool

+ HasCorsCfgSet bool

type SRSiteSummary

+ ReplicatedCorsConfig int

+ TotalCorsConfigCount int

v3.0.59

Jul 25, 2024

Changes in this version

type AdminClient

+ func (adm *AdminClient) BucketScanInfo(ctx context.Context, bucket string) ([]BucketScanInfo, error)

+ type BucketScanInfo struct

+ Completed []time.Time

+ Cycle uint64

+ LastStarted time.Time

+ LastUpdate time.Time

+ Pool int

+ Set int

type RPCMetrics

+ ByCaller map[string]RPCMetrics

+ LastConnectTime time.Time

+ LastPingMS float64

+ MaxPingDurMS float64

+ ReconnectCount int

type ScannerMetrics

+ OngoingBuckets int

v3.0.58

Jul 1, 2024

Changes in this version

+ const DriveStateRootMount

type HealOpts

+ Pool *int

+ Set *int

v3.0.57

Jun 21, 2024

Changes in this version

+ const AccessKeyListAll

+ const AccessKeyListSTSOnly

+ const AccessKeyListSvcaccOnly

+ const AccessKeyListUsersOnly

type AdminClient

+ func (adm *AdminClient) ListAccessKeysLDAPBulk(ctx context.Context, users []string, listType string, all bool) (map[string]ListAccessKeysLDAPResp, error)

type UserPolicyEntities

+ MemberOfMappings []GroupPolicyEntities

v3.0.56

Jun 17, 2024

Changes in this version

+ type ProductInfo struct

+ Family string

+ Name string

+ SKU string

+ SerialNumber string

+ UUID string

+ Vendor string

+ Version string

+ func GetProductInfo(addr string) ProductInfo

type SysInfo

+ ProductInfo []ProductInfo

v3.0.55

Jun 3, 2024

v3.0.54

May 31, 2024

Changes in this version

type MetricType

+ const MetricsRPC

type Metrics

+ RPC *RPCMetrics

+ type RPCMetrics struct

+ ByDestination map[string]RPCMetrics

+ CollectedAt time.Time

+ Connected int

+ Disconnected int

+ IncomingBytes int64

+ IncomingMessages int64

+ IncomingStreams int

+ LastPongTime time.Time

+ OutQueue int

+ OutgoingBytes int64

+ OutgoingMessages int64

+ OutgoingStreams int

+ func (m *RPCMetrics) Merge(other *RPCMetrics)

type TraceInfo

+ Bytes int64

v3.0.53

May 29, 2024

Changes in this version

type AdminClient

+ func (adm *AdminClient) BatchJobStatus(ctx context.Context, jobID string) (BatchJobStatus, error)

+ type BatchJobStatus struct

+ LastMetric JobMetric

v3.0.52

May 23, 2024

v3.0.51

May 1, 2024

Changes in this version

+ var MetricsRespBodyLimit = int64(humanize.GiByte)

type MetricsClient

+ func (client *MetricsClient) GetMetrics(ctx context.Context, subSystem string) ([]*prom2json.Family, error)

type ServiceAccountInfo

+ AccountStatus string

+ Description string

+ ImpliedPolicy bool

+ Name string

+ ParentUser string

v3.0.50

Mar 7, 2024

Changes in this version

type ServerInfo

+ PoolNumbers []int

type ServerProperties

+ PoolNumbers []int

v3.0.49

Feb 29, 2024

Changes in this version

type Disk

+ Local bool

type HealingDisk

+ BytesSkipped uint64

+ ItemsSkipped uint64

v3.0.48

Feb 20, 2024

Changes in this version

+ const ILMSubsys

v3.0.47

Feb 17, 2024

Changes in this version

type MetricsClient

+ func NewMetricsClientWithOptions(endpoint string, opts *Options) (*MetricsClient, error)

type Options

+ Transport http.RoundTripper

v3.0.46

Feb 11, 2024

Changes in this version

+ func WithDriveMetrics(metrics bool) func(*ServerInfoOpts)

+ type ServerInfoOpts struct

+ Metrics bool

v3.0.45

Feb 6, 2024

Changes in this version

+ type ReplProxyMetric struct

+ GetFailedTotal uint64

+ GetTagFailedTotal uint64

+ GetTagTotal uint64

+ GetTotal uint64

+ HeadFailedTotal uint64

+ HeadTotal uint64

+ PutTagFailedTotal uint64

+ PutTagTotal uint64

+ RmvTagFailedTotal uint64

+ RmvTagTotal uint64

+ func (p *ReplProxyMetric) Add(p2 ReplProxyMetric)

type SRMetricsSummary

+ Proxied ReplProxyMetric

v3.0.44

Feb 5, 2024

Changes in this version

type DataUsageInfo

+ TotalCapacity uint64

+ TotalFreeCapacity uint64

+ TotalUsedCapacity uint64

v3.0.43

Jan 30, 2024

Changes in this version

type LogKind

+ const LogKindError

+ const LogKindEvent

+ const LogKindFatal

+ const LogKindInfo

+ const LogKindWarning

type LogMask

+ const LogMaskError

+ const LogMaskEvent

+ const LogMaskFatal

+ const LogMaskInfo

+ const LogMaskWarning

v3.0.42

Jan 29, 2024

v3.0.41

Jan 26, 2024

Changes in this version

type AdminClient

+ func (adm *AdminClient) ServiceFreezeV2(ctx context.Context) error

+ func (adm *AdminClient) ServiceRestartV2(ctx context.Context) error

+ func (adm *AdminClient) ServiceStopV2(ctx context.Context) error

+ func (adm *AdminClient) ServiceUnfreezeV2(ctx context.Context) error

v3.0.40

Jan 24, 2024

Changes in this version

+ func ParsePrometheusResults(reader io.Reader) (results []*prom2json.Family, err error)

type AdminClient

+ func (adm *AdminClient) ServerUpdateV2(ctx context.Context, opts ServerUpdateOpts) (us ServerUpdateStatusV2, err error)

+ func (adm *AdminClient) ServiceAction(ctx context.Context, opts ServiceActionOpts) (ServiceActionResult, error)

type DiskMetrics

+ TotalDeletes uint64

+ TotalTokens uint32

+ TotalWaiting uint32

+ TotalWrites uint64

+ type ServerPeerUpdateStatus struct

+ CurrentVersion string

+ Err string

+ Host string

+ UpdatedVersion string

+ WaitingDrives map[string]DiskMetrics

+ type ServerUpdateOpts struct

+ DryRun bool

+ UpdateURL string

+ type ServerUpdateStatusV2 struct

+ DryRun bool

+ Results []ServerPeerUpdateStatus

+ type ServiceActionOpts struct

+ Action ServiceAction

+ DryRun bool

+ type ServiceActionPeerResult struct

+ Err string

+ Host string

+ WaitingDrives map[string]DiskMetrics

+ type ServiceActionResult struct

+ Action ServiceAction

+ DryRun bool

+ Results []ServiceActionPeerResult

v3.0.39

Jan 15, 2024

Changes in this version

type SpeedtestOpts

+ EnableSha256 bool

v3.0.38

Dec 21, 2023

Changes in this version

type TierCreds

+ AWSRoleARN string

+ AWSRoleWebIdentityTokenFile string

+ AzSP ServicePrincipalAuth

v3.0.37

Dec 18, 2023

Changes in this version

+ const BrowserSubSys

+ func AzureServicePrincipal(tenantID, clientID, clientSecret string) func(az *TierAzure) error

+ type ServicePrincipalAuth struct

+ ClientID string

+ ClientSecret string

+ TenantID string

+ func (z *ServicePrincipalAuth) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *ServicePrincipalAuth) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z ServicePrincipalAuth) EncodeMsg(en *msgp.Writer) (err error)

+ func (z ServicePrincipalAuth) MarshalMsg(b []byte) (o []byte, err error)

+ func (z ServicePrincipalAuth) Msgsize() (s int)

type TierAzure

+ SPAuth ServicePrincipalAuth

+ func (ti TierAzure) IsSPEnabled() bool

v3.0.36

Dec 5, 2023

Changes in this version

type CPUMetrics

+ CPUCount int

v3.0.35

Nov 30, 2023

Changes in this version

type TLSCert

+ Checksum string

v3.0.34

Nov 26, 2023

Changes in this version

+ func S3AWSRoleARN(roleARN string) func(s3 *TierS3) error

+ func S3AWSRoleDurationSeconds(dsecs int) func(s3 *TierS3) error

+ func S3AWSRoleSessionName(roleSessionName string) func(s3 *TierS3) error

+ func S3AWSRoleWebIdentityTokenFile(tokenFile string) func(s3 *TierS3) error

type TierS3

+ AWSRoleARN string

+ AWSRoleDurationSeconds int

+ AWSRoleSessionName string

+ AWSRoleWebIdentityTokenFile string

v3.0.33

Nov 23, 2023

Changes in this version

+ const DriveSubSys

v3.0.32

Nov 21, 2023

Changes in this version

type AdminClient

+ func (adm *AdminClient) SRStateEdit(ctx context.Context, state SRStateEditReq) error

type SRInfo

+ State SRStateInfo

type SRPeerJoinReq

+ UpdatedAt time.Time

+ type SRStateEditReq struct

+ Peers map[string]PeerInfo

+ UpdatedAt time.Time

+ type SRStateInfo struct

+ Name string

+ Peers map[string]PeerInfo

+ UpdatedAt time.Time

type SRStatusOptions

+ PeerState bool

v3.0.31

Nov 20, 2023

v3.0.30

Nov 6, 2023

Changes in this version

type AdminClient

+ func (adm *AdminClient) AddServiceAccountLDAP(ctx context.Context, opts AddServiceAccountReq) (Credentials, error)

+ func (adm *AdminClient) ListAccessKeysLDAP(ctx context.Context, userDN string, listType string) (ListAccessKeysLDAPResp, error)

+ type ListAccessKeysLDAPResp struct

+ STSKeys []ServiceAccountInfo

+ ServiceAccounts []ServiceAccountInfo

v3.0.29

Oct 30, 2023

v3.0.28

Oct 26, 2023

Changes in this version

+ type ILMExpiryRule struct

+ Bucket string

+ ILMRule string

+ UpdatedAt time.Time

type MetricsClient

+ func (client *MetricsClient) SetCustomTransport(customHTTPTransport http.RoundTripper)

type PeerInfo

+ ReplicateILMExpiry bool

type SREditOptions

+ EnableILMExpiryReplication bool

type SREntityType

+ const SRILMExpiryRuleEntity

+ type SRILMExpiryStatsSummary struct

+ DeploymentID string

+ HasILMExpiryRules bool

+ ILMExpiryRuleMismatch bool

type SRInfo

+ ILMExpiryRules map[string]ILMExpiryRule

type SRPeerJoinReq

+ ReplicateILMExpiry bool

type SRSiteSummary

+ ReplicatedILMExpiryRules int

+ TotalILMExpiryRulesCount int

type SRStatusInfo

+ ILMExpiryStats map[string]map[string]SRILMExpiryStatsSummary

+ MaxILMExpiryRules int

type SRStatusOptions

+ ILMExpiryRules bool

v3.0.27

Oct 13, 2023

v3.0.26

Oct 13, 2023

Changes in this version

+ const SRBucketMetaLCConfig

+ type SRAddOptions struct

+ ReplicateILMExpiry bool

type SRBucketInfo

+ ExpiryLCConfig *string

+ ExpiryLCConfigUpdatedAt time.Time

type SRBucketMeta

+ ExpiryLCConfig *string

+ ExpiryUpdatedAt time.Time

+ type SREditOptions struct

+ DisableILMExpiryReplication bool

type SiteReplicationInfo

+ ReplicateILMExpiry bool

v3.0.25

Oct 13, 2023

v3.0.24

Oct 12, 2023

Changes in this version

type HealthInfoV3

+ func (info HealthInfoV3) GetError() string

+ func (info HealthInfoV3) GetStatus() string

+ func (info HealthInfoV3) GetTimestamp() time.Time

+ func (info HealthInfoV3) JSON() string

+ func (info HealthInfoV3) String() string

v3.0.23

Oct 10, 2023

Changes in this version

+ const HealthInfoVersion4

+ type HealthInfoV3 struct

+ Error string

+ Minio MinioHealthInfo

+ Sys SysInfoV1

+ TimeStamp time.Time

+ Version string

+ type NetInfo struct

+ Driver string

+ FirmwareVersion string

+ Interface string

+ func GetNetInfo(addr string, iface string) (ni NetInfo)

+ func GetNetInfo(addr string, iface string) NetInfo

type Partition

+ Revision string

type SysInfo

+ NetInfo []NetInfo

+ type SysInfoV1 struct

+ CPUInfo []CPUs

+ KubernetesInfo KubernetesInfo

+ MemInfo []MemInfo

+ OSInfo []OSInfo

+ Partitions []Partitions

+ ProcInfo []ProcInfo

+ SysConfig []SysConfig

+ SysErrs []SysErrors

+ SysServices []SysServices

v3.0.22

Oct 4, 2023

Changes in this version

type MetricsClient

+ func (client *MetricsClient) ResourceMetrics(ctx context.Context) ([]*prom2json.Family, error)

v3.0.21

Sep 29, 2023

Changes in this version

type Partition

+ Model string

v3.0.20

Sep 25, 2023

Changes in this version

+ type BucketBandwidth struct

+ IsSet bool

+ Limit uint64

+ UpdatedAt time.Time

type PeerInfo

+ DefaultBandwidth BucketBandwidth

v3.0.19

Sep 15, 2023

Changes in this version

+ type CPUMetrics struct

+ CollectedAt time.Time

+ LoadStat *load.AvgStat

+ TimesStat *cpu.TimesStat

+ func (m *CPUMetrics) Merge(other *CPUMetrics)

type MemInfo

+ Buffers uint64

+ Cache uint64

+ Free uint64

+ Shared uint64

+ Used uint64

+ type MemMetrics struct

+ CollectedAt time.Time

+ Info MemInfo

+ func (m *MemMetrics) Merge(other *MemMetrics)

type MetricType

+ const MetricsCPU

+ const MetricsMem

type Metrics

+ CPU *CPUMetrics

+ Mem *MemMetrics

v3.0.18

Aug 31, 2023

Changes in this version

type MetricsClient

+ func (client *MetricsClient) BucketMetrics(ctx context.Context) ([]*prom2json.Family, error)

v3.0.17

Aug 29, 2023

v3.0.16

Aug 29, 2023

Changes in this version

type TimedErrStats

+ ErrCounts map[string]int

v3.0.15

Aug 25, 2023

Changes in this version

type MetricsClient

+ func (client *MetricsClient) ClusterMetrics(ctx context.Context) ([]*prom2json.Family, error)

v3.0.14

Aug 22, 2023

Changes in this version

type SRMetric

+ MRFStats replication.ReplMRFStats

v3.0.13

Aug 22, 2023

Changes in this version

type BucketQuota

+ Rate uint64

+ Requests uint64

+ Size uint64

+ type MetricsClient struct

+ func NewMetricsClient(endpoint string, accessKeyID, secretAccessKey string, secure bool) (*MetricsClient, error)

+ func (client *MetricsClient) NodeMetrics(ctx context.Context) ([]*prom2json.Family, error)

v3.0.12

Aug 16, 2023

Changes in this version

+ const BatchSubSys

type BucketTarget

+ DeploymentID string

+ Latency LatencyStat

+ type InQueueMetric struct

+ Avg QStat

+ Curr QStat

+ Max QStat

+ type LatencyStat struct

+ Avg time.Duration

+ Curr time.Duration

+ Max time.Duration

+ func (z *LatencyStat) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *LatencyStat) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z LatencyStat) EncodeMsg(en *msgp.Writer) (err error)

+ func (z LatencyStat) MarshalMsg(b []byte) (o []byte, err error)

+ func (z LatencyStat) Msgsize() (s int)

+ type QStat struct

+ Bytes float64

+ Count float64

+ func (q *QStat) Add(o QStat) QStat

+ type RStat struct

+ Bytes int64

+ Count float64

+ func (r RStat) Add(r1 RStat) RStat

+ func (z *RStat) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *RStat) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z RStat) EncodeMsg(en *msgp.Writer) (err error)

+ func (z RStat) MarshalMsg(b []byte) (o []byte, err error)

+ func (z RStat) Msgsize() (s int)

+ type SRMetric struct

+ DeploymentID string

+ Endpoint string

+ Failed TimedErrStats

+ LastOnline time.Time

+ Latency LatencyStat

+ Online bool

+ ReplicatedCount int64

+ ReplicatedSize int64

+ TotalDowntime time.Duration

+ XferStats map[replication.MetricName]replication.XferStats

+ type SRMetricsSummary struct

+ ActiveWorkers WorkerStat

+ Metrics map[string]SRMetric

+ Queued InQueueMetric

+ ReplicaCount int64

+ ReplicaSize int64

+ Uptime int64

type SRStatusInfo

+ Metrics SRMetricsSummary

type SRStatusOptions

+ Metrics bool

+ type TimedErrStats struct

+ LastHour RStat

+ LastMinute RStat

+ Totals RStat

+ func (te TimedErrStats) Add(o TimedErrStats) TimedErrStats

+ func (z *TimedErrStats) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *TimedErrStats) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *TimedErrStats) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *TimedErrStats) Msgsize() (s int)

+ func (z *TimedErrStats) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type WorkerStat struct

+ Avg float32

+ Curr int

+ Max int

v3.0.11

Aug 9, 2023

Changes in this version

+ const MaxClientPerfTimeout

+ const MinClientPerfTimeout

type AdminClient

+ func (adm *AdminClient) ClientPerf(ctx context.Context, dur time.Duration) (result ClientPerfResult, err error)

+ type ClientPerfExtraTime struct

+ TimeSpent int64

+ type ClientPerfResult struct

+ BytesSend uint64

+ Endpoint string

+ Error string

+ TimeSpent int64

+ type ExpirationInfo struct

+ Bucket string

+ Object string

+ Objects int64

+ ObjectsFailed int64

type JobMetric

+ Expired *ExpirationInfo

v3.0.10

Aug 5, 2023

Changes in this version

+ const BatchJobExpireTemplate

+ const TraceBatch

type BackendInfo

+ RRSCParities []int

+ StandardSCParities []int

type BatchJobType

+ const BatchJobExpire

type ServiceTraceOpts

+ BatchAll bool

+ BatchExpire bool

type TraceType

+ const TraceBatchExpire

v3.0.9

Aug 1, 2023

Changes in this version

type DiskMetrics

+ TotalErrorsAvailability uint64

+ TotalErrorsTimeout uint64

v3.0.8

Jul 19, 2023

Changes in this version

type BucketUsageInfo

+ DeleteMarkersCount uint64

+ type DeleteMarkers struct

+ Count uint64

+ Error string

type ErasureSetInfo

+ DeleteMarkersCount uint64

type InfoMessage

+ DeleteMarkers DeleteMarkers

v3.0.7

Jul 11, 2023

Changes in this version

type MetricType

+ const MetricNet

type Metrics

+ Net *NetMetrics

+ type NetMetrics struct

+ CollectedAt time.Time

+ InterfaceName string

+ NetStats procfs.NetDevLine

+ func (n *NetMetrics) Merge(other *NetMetrics)

v3.0.6

Jul 7, 2023

Changes in this version

+ const SRIAMItemCredential

type KMS

+ Endpoint string

+ Version string

type PoolDecommissionInfo

+ BytesDone int64

+ BytesFailed int64

+ ObjectsDecommissionFailed int64

+ ObjectsDecommissioned int64

+ type SRCredInfo struct

+ AccessKey string

+ IAMUserType int

+ IsDeleteReq bool

+ UserIdentityJSON json.RawMessage

type SRIAMItem

+ CredentialInfo *SRCredInfo

type Services

+ KMSStatus []KMS

v3.0.5

Jun 26, 2023

Changes in this version

type AdminClient

+ func (adm *AdminClient) SiteReplicationPerf(ctx context.Context, duration time.Duration) (result SiteNetPerfResult, err error)

+ type SiteNetPerfNodeResult struct

+ Endpoint string

+ Error string

+ RX uint64

+ RXTotalDuration time.Duration

+ TX uint64

+ TXTotalDuration time.Duration

+ TotalConn uint64

+ type SiteNetPerfResult struct

+ NodeResults []SiteNetPerfNodeResult

v3.0.4

Jun 23, 2023

Changes in this version

type MinioInfo

+ Metrics *RealtimeMetrics

v3.0.3

Jun 21, 2023

Changes in this version

+ type UserAuthInfo struct

+ AuthServer string

+ AuthServerUserID string

+ Type UserAuthType

+ type UserAuthType string

+ const BuiltinUserAuthType

+ const LDAPUserAuthType

type UserInfo

+ AuthInfo *UserAuthInfo

v3.0.2

Jun 20, 2023

Changes in this version

type AdminClient

+ func (adm *AdminClient) BucketReplicationMRF(ctx context.Context, bucketName string, node string) <-chan ReplicationMRF

+ type ReplicationMRF struct

+ Bucket string

+ Err string

+ NodeName string

+ Object string

+ RetryCount int

+ VersionID string

+ func (z *ReplicationMRF) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *ReplicationMRF) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *ReplicationMRF) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *ReplicationMRF) Msgsize() (s int)

+ func (z *ReplicationMRF) UnmarshalMsg(bts []byte) (o []byte, err error)

v3.0.1

Jun 19, 2023

v3.0.0

Jun 14, 2023

Changes in this version

+ const APISubSys

+ const AdminAPIVersion

+ const AdminAPIVersionV2

+ const AuditKafkaSubSys

+ const AuditWebhookSubSys

+ const BatchJobKeyRotateTemplate

+ const BatchJobReplicateTemplate

+ const CacheSubSys

+ const CallhomeSubSys

+ const CommentKey

+ const CompressionSubSys

+ const ConfigAppliedHeader

+ const ConfigAppliedTrue

+ const CrawlerSubSys

+ const CredentialsSubSys

+ const Default

+ const DefaultRetryCap

+ const DefaultRetryUnit

+ const DriveStateCorrupt

+ const DriveStateFaulty

+ const DriveStateMissing

+ const DriveStateOffline

+ const DriveStateOk

+ const DriveStatePermission

+ const DriveStateUnformatted

+ const DriveStateUnknown

+ const EnableKey

+ const EnableOff

+ const EnableOn

+ const EnvLinePrefix

+ const EnvPrefix

+ const EnvWordDelimiter

+ const ErasureType

+ const EtcdSubSys

+ const FsType

+ const HealItemBucket

+ const HealItemBucketMetadata

+ const HealItemMetadata

+ const HealItemObject

+ const HealSubSys

+ const HealthInfoVersion

+ const HealthInfoVersion0

+ const HealthInfoVersion1

+ const HealthInfoVersion2

+ const HealthInfoVersion3

+ const IdentityLDAPSubSys

+ const IdentityOpenIDSubSys

+ const IdentityPluginSubSys

+ const IdentityTLSSubSys

+ const ItemInitializing

+ const ItemOffline

+ const ItemOnline

+ const KvComment

+ const KvDoubleQuote

+ const KvNewline

+ const KvSeparator

+ const KvSingleQuote

+ const KvSpaceSeparator

+ const LDAPIDPCfg

+ const LambdaWebhookSubSys

+ const LoggerWebhookSubSys

+ const MaxJitter

+ const NoJitter

+ const NotifyAMQPSubSys

+ const NotifyESSubSys

+ const NotifyKafkaSubSys

+ const NotifyMQTTSubSys

+ const NotifyMySQLSubSys

+ const NotifyNATSSubSys

+ const NotifyNSQSubSys

+ const NotifyPostgresSubSys

+ const NotifyRedisSubSys

+ const NotifyWebhookSubSys

+ const OpenidIDPCfg

+ const PolicyOPASubSys

+ const PolicyPluginSubSys

+ const RegionSubSys

+ const ReplicateAddStatusPartial

+ const ReplicateAddStatusSuccess

+ const ReplicateRemoveStatusPartial

+ const ReplicateRemoveStatusSuccess

+ const SRBucketMetaTypeObjectLockConfig

+ const SRBucketMetaTypePolicy

+ const SRBucketMetaTypeQuotaConfig

+ const SRBucketMetaTypeSSEConfig

+ const SRBucketMetaTypeTags

+ const SRBucketMetaTypeVersionConfig

+ const SRIAMItemGroupInfo

+ const SRIAMItemIAMUser

+ const SRIAMItemPolicy

+ const SRIAMItemPolicyMapping

+ const SRIAMItemSTSAcc

+ const SRIAMItemSvcAcc

+ const ScannerSubSys

+ const ServiceActionFreeze

+ const ServiceActionRestart

+ const ServiceActionStop

+ const ServiceActionUnfreeze

+ const SiteReplAPIVersion

+ const SiteSubSys

+ const SrvNotInstalled

+ const SrvSELinux

+ const StorageClassSubSys

+ const SubSystemSeparator

+ const SubnetSubSys

+ const SysErrAuditEnabled

+ const SysErrUpdatedbInstalled

+ const TierConfigVer

+ var DefaultTransport = func(secure bool) http.RoundTripper

+ var ErrInvalidConfigKV = errors.New("expected config value in the format `key=value`")

+ var ErrInvalidEnvVarLine = errors.New("expected env var line of the form `# MINIO_...=...`")

+ var ErrMaliciousData = sio.NotAuthentic

+ var ErrTierInvalidConfig = errors.New("invalid tier config")

+ var ErrTierInvalidConfigVersion = errors.New("invalid tier config version")

+ var ErrTierNameEmpty = errors.New("remote tier name empty")

+ var ErrTierTypeUnsupported = errors.New("unsupported tier type")

+ var ErrUnexpectedHeader = errors.New("unexpected header")

+ var HealthDataTypesList = []HealthDataType

+ var HealthDataTypesMap = map[string]HealthDataType

+ var MaxRetry = 10

+ var SubSystems = set.CreateStringSet(CredentialsSubSys, PolicyOPASubSys, PolicyPluginSubSys, IdentityOpenIDSubSys, ...)

+ var SupportedJobTypes = []BatchJobType

+ var ValidIDPConfigTypes = set.CreateStringSet(OpenidIDPCfg, LDAPIDPCfg)

+ func AzureEndpoint(endpoint string) func(az *TierAzure) error

+ func AzurePrefix(prefix string) func(az *TierAzure) error

+ func AzureRegion(region string) func(az *TierAzure) error

+ func AzureStorageClass(sc string) func(az *TierAzure) error

+ func DecryptData(password string, data io.Reader) ([]byte, error)

+ func EncryptData(password string, data []byte) ([]byte, error)

+ func ErrInvalidArgument(message string) error

+ func FIPSEnabled() bool

+ func GCSPrefix(prefix string) func(*TierGCS) error

+ func GCSRegion(region string) func(*TierGCS) error

+ func GCSStorageClass(sc string) func(*TierGCS) error

+ func HasSpace(s string) bool

+ func IsEncrypted(data []byte) bool

+ func MinIOPrefix(prefix string) func(m *TierMinIO) error

+ func MinIORegion(region string) func(m *TierMinIO) error

+ func S3AWSRole() func(s3 *TierS3) error

+ func S3Endpoint(endpoint string) func(s3 *TierS3) error

+ func S3Prefix(prefix string) func(s3 *TierS3) error

+ func S3Region(region string) func(s3 *TierS3) error

+ func S3StorageClass(storageClass string) func(s3 *TierS3) error

+ func SanitizeValue(v string) string

+ type ARN struct

+ Bucket string

+ ID string

+ Region string

+ Type ServiceType

+ func ParseARN(s string) (*ARN, error)

+ func (a ARN) Empty() bool

+ func (a ARN) String() string

+ type AccountAccess struct

+ Read bool

+ Write bool

+ type AccountInfo struct

+ AccountName string

+ Buckets []BucketAccessInfo

+ Policy json.RawMessage

+ Server BackendInfo

+ type AccountOpts struct

+ PrefixUsage bool

+ type AccountStatus string

+ const AccountDisabled

+ const AccountEnabled

+ type AddOrUpdateUserReq struct

+ Policy string

+ SecretKey string

+ Status AccountStatus

+ type AddServiceAccountReq struct

+ AccessKey string

+ Comment string

+ Description string

+ Expiration *time.Time

+ Name string

+ Policy json.RawMessage

+ SecretKey string

+ TargetUser string

+ func (r *AddServiceAccountReq) Validate() error

+ type AddServiceAccountResp struct

+ Credentials Credentials

+ type AdminClient struct

+ func New(endpoint string, accessKeyID, secretAccessKey string, secure bool) (*AdminClient, error)

+ func NewWithOptions(endpoint string, opts *Options) (*AdminClient, error)

+ func (adm *AdminClient) AccountInfo(ctx context.Context, opts AccountOpts) (AccountInfo, error)

+ func (adm *AdminClient) AddCannedPolicy(ctx context.Context, policyName string, policy []byte) error

+ func (adm *AdminClient) AddOrUpdateIDPConfig(ctx context.Context, cfgType, cfgName, cfgData string, update bool) (restart bool, err error)

+ func (adm *AdminClient) AddServiceAccount(ctx context.Context, opts AddServiceAccountReq) (Credentials, error)

+ func (adm *AdminClient) AddTier(ctx context.Context, cfg *TierConfig) error

+ func (adm *AdminClient) AddTierIgnoreInUse(ctx context.Context, cfg *TierConfig) error

+ func (adm *AdminClient) AddUser(ctx context.Context, accessKey, secretKey string) error

+ func (adm *AdminClient) AssignPolicy(ctx context.Context, policy string, content []byte) error

+ func (adm *AdminClient) AttachPolicy(ctx context.Context, r PolicyAssociationReq) (PolicyAssociationResp, error)

+ func (adm *AdminClient) AttachPolicyLDAP(ctx context.Context, par PolicyAssociationReq) (PolicyAssociationResp, error)

+ func (adm *AdminClient) BackgroundHealStatus(ctx context.Context) (BgHealState, error)

+ func (adm *AdminClient) BucketReplicationDiff(ctx context.Context, bucketName string, opts ReplDiffOpts) <-chan DiffInfo

+ func (adm *AdminClient) CancelBatchJob(ctx context.Context, jobID string) error

+ func (adm *AdminClient) CancelDecommissionPool(ctx context.Context, pool string) error

+ func (adm *AdminClient) ClearConfigHistoryKV(ctx context.Context, restoreID string) (err error)

+ func (adm *AdminClient) CreateKey(ctx context.Context, keyID string) error

+ func (adm *AdminClient) DataUsageInfo(ctx context.Context) (DataUsageInfo, error)

+ func (adm *AdminClient) DecommissionPool(ctx context.Context, pool string) error

+ func (adm *AdminClient) DelConfigKV(ctx context.Context, k string) (restart bool, err error)

+ func (adm *AdminClient) DeleteIDPConfig(ctx context.Context, cfgType, cfgName string) (restart bool, err error)

+ func (adm *AdminClient) DeleteIdentity(ctx context.Context, identity string) error

+ func (adm *AdminClient) DeleteKey(ctx context.Context, keyID string) error

+ func (adm *AdminClient) DeletePolicy(ctx context.Context, policy string) error

+ func (adm *AdminClient) DeleteServiceAccount(ctx context.Context, serviceAccount string) error

+ func (adm *AdminClient) DescribeBatchJob(ctx context.Context, jobID string) (string, error)

+ func (adm *AdminClient) DescribeIdentity(ctx context.Context, identity string) (*KMSDescribeIdentity, error)

+ func (adm *AdminClient) DescribePolicy(ctx context.Context, policy string) (*KMSDescribePolicy, error)

+ func (adm *AdminClient) DescribeSelfIdentity(ctx context.Context) (*KMSDescribeSelfIdentity, error)

+ func (adm *AdminClient) DetachPolicy(ctx context.Context, r PolicyAssociationReq) (PolicyAssociationResp, error)

+ func (adm *AdminClient) DetachPolicyLDAP(ctx context.Context, par PolicyAssociationReq) (PolicyAssociationResp, error)

+ func (adm *AdminClient) DownloadProfilingData(ctx context.Context) (io.ReadCloser, error)

+ func (adm *AdminClient) DriveSpeedtest(ctx context.Context, opts DriveSpeedTestOpts) (chan DriveSpeedTestResult, error)

+ func (adm *AdminClient) EditTier(ctx context.Context, tierName string, creds TierCreds) error

+ func (adm *AdminClient) ExportBucketMetadata(ctx context.Context, bucket string) (io.ReadCloser, error)

+ func (adm *AdminClient) ExportIAM(ctx context.Context) (io.ReadCloser, error)

+ func (adm *AdminClient) ForceUnlock(ctx context.Context, paths ...string) error

+ func (adm *AdminClient) GenerateBatchJob(_ context.Context, opts GenerateBatchJobOpts) (string, error)

+ func (adm *AdminClient) GetBucketBandwidth(ctx context.Context, buckets ...string) <-chan Report

+ func (adm *AdminClient) GetBucketQuota(ctx context.Context, bucket string) (q BucketQuota, err error)

+ func (adm *AdminClient) GetConfig(ctx context.Context) ([]byte, error)

+ func (adm *AdminClient) GetConfigKV(ctx context.Context, key string) ([]byte, error)

+ func (adm *AdminClient) GetConfigKVWithOptions(ctx context.Context, key string, opts KVOptions) ([]byte, error)

+ func (adm *AdminClient) GetGroupDescription(ctx context.Context, group string) (*GroupDesc, error)

+ func (adm *AdminClient) GetIDPConfig(ctx context.Context, cfgType, cfgName string) (c IDPConfig, err error)

+ func (adm *AdminClient) GetKeyStatus(ctx context.Context, keyID string) (*KMSKeyStatus, error)

+ func (adm *AdminClient) GetLDAPPolicyEntities(ctx context.Context, q PolicyEntitiesQuery) (r PolicyEntitiesResult, err error)

+ func (adm *AdminClient) GetPolicy(ctx context.Context, policy string) (*KMSPolicy, error)

+ func (adm *AdminClient) GetPolicyEntities(ctx context.Context, q PolicyEntitiesQuery) (r PolicyEntitiesResult, err error)

+ func (adm *AdminClient) GetUserInfo(ctx context.Context, name string) (u UserInfo, err error)

+ func (adm *AdminClient) Heal(ctx context.Context, bucket, prefix string, healOpts HealOpts, ...) (healStart HealStartSuccess, healTaskStatus HealTaskStatus, err error)

+ func (adm *AdminClient) HelpConfigKV(ctx context.Context, subSys, key string, envOnly bool) (Help, error)

+ func (adm *AdminClient) ImportBucketMetadata(ctx context.Context, bucket string, contentReader io.ReadCloser) (r BucketMetaImportErrs, err error)

+ func (adm *AdminClient) ImportIAM(ctx context.Context, contentReader io.ReadCloser) error

+ func (adm *AdminClient) ImportKey(ctx context.Context, keyID string, content []byte) error

+ func (adm *AdminClient) InfoCannedPolicy(ctx context.Context, policyName string) ([]byte, error)

+ func (adm *AdminClient) InfoCannedPolicyV2(ctx context.Context, policyName string) (*PolicyInfo, error)

+ func (adm *AdminClient) InfoServiceAccount(ctx context.Context, accessKey string) (InfoServiceAccountResp, error)

+ func (adm *AdminClient) Inspect(ctx context.Context, d InspectOptions) (key []byte, c io.ReadCloser, err error)

+ func (adm *AdminClient) KMSAPIs(ctx context.Context) ([]KMSAPI, error)

+ func (adm *AdminClient) KMSMetrics(ctx context.Context) (*KMSMetrics, error)

+ func (adm *AdminClient) KMSStatus(ctx context.Context) (KMSStatus, error)

+ func (adm *AdminClient) KMSVersion(ctx context.Context) (*KMSVersion, error)

+ func (adm *AdminClient) ListBatchJobs(ctx context.Context, fl *ListBatchJobsFilter) (ListBatchJobsResult, error)

+ func (adm *AdminClient) ListCannedPolicies(ctx context.Context) (map[string]json.RawMessage, error)

+ func (adm *AdminClient) ListConfigHistoryKV(ctx context.Context, count int) ([]ConfigHistoryEntry, error)

+ func (adm *AdminClient) ListGroups(ctx context.Context) ([]string, error)

+ func (adm *AdminClient) ListIDPConfig(ctx context.Context, cfgType string) ([]IDPListItem, error)

+ func (adm *AdminClient) ListIdentities(ctx context.Context, pattern string) ([]KMSIdentityInfo, error)

+ func (adm *AdminClient) ListKeys(ctx context.Context, pattern string) ([]KMSKeyInfo, error)

+ func (adm *AdminClient) ListPolicies(ctx context.Context, pattern string) ([]KMSPolicyInfo, error)

+ func (adm *AdminClient) ListPoolsStatus(ctx context.Context) ([]PoolStatus, error)

+ func (adm *AdminClient) ListRemoteTargets(ctx context.Context, bucket, arnType string) (targets []BucketTarget, err error)

+ func (adm *AdminClient) ListServiceAccounts(ctx context.Context, user string) (ListServiceAccountsResp, error)

+ func (adm *AdminClient) ListTiers(ctx context.Context) ([]*TierConfig, error)

+ func (adm *AdminClient) ListUsers(ctx context.Context) (map[string]UserInfo, error)

+ func (adm *AdminClient) Metrics(ctx context.Context, o MetricsOptions, out func(RealtimeMetrics)) (err error)

+ func (adm *AdminClient) Netperf(ctx context.Context, duration time.Duration) (result NetperfResult, err error)

+ func (adm *AdminClient) Profile(ctx context.Context, profiler ProfilerType, duration time.Duration) (io.ReadCloser, error)

+ func (adm *AdminClient) RebalanceStart(ctx context.Context) (id string, err error)

+ func (adm *AdminClient) RebalanceStatus(ctx context.Context) (r RebalanceStatus, err error)

+ func (adm *AdminClient) RebalanceStop(ctx context.Context) error

+ func (adm *AdminClient) RemoveCannedPolicy(ctx context.Context, policyName string) error

+ func (adm *AdminClient) RemoveRemoteTarget(ctx context.Context, bucket, arn string) error

+ func (adm *AdminClient) RemoveTier(ctx context.Context, tierName string) error

+ func (adm *AdminClient) RemoveUser(ctx context.Context, accessKey string) error

+ func (adm *AdminClient) RestoreConfigHistoryKV(ctx context.Context, restoreID string) (err error)

+ func (adm *AdminClient) SRMetaInfo(ctx context.Context, opts SRStatusOptions) (info SRInfo, err error)

+ func (adm *AdminClient) SRPeerBucketOps(ctx context.Context, bucket string, op BktOp, opts map[string]string) error

+ func (adm *AdminClient) SRPeerEdit(ctx context.Context, pi PeerInfo) error

+ func (adm *AdminClient) SRPeerGetIDPSettings(ctx context.Context) (info IDPSettings, err error)

+ func (adm *AdminClient) SRPeerJoin(ctx context.Context, r SRPeerJoinReq) error

+ func (adm *AdminClient) SRPeerRemove(ctx context.Context, removeReq SRRemoveReq) (st ReplicateRemoveStatus, err error)

+ func (adm *AdminClient) SRPeerReplicateBucketMeta(ctx context.Context, item SRBucketMeta) error

+ func (adm *AdminClient) SRPeerReplicateIAMItem(ctx context.Context, item SRIAMItem) error

+ func (adm *AdminClient) SRStatusInfo(ctx context.Context, opts SRStatusOptions) (info SRStatusInfo, err error)

+ func (adm *AdminClient) ServerHealthInfo(ctx context.Context, types []HealthDataType, deadline time.Duration) (*http.Response, string, error)

+ func (adm *AdminClient) ServerInfo(ctx context.Context) (InfoMessage, error)

+ func (adm *AdminClient) ServerUpdate(ctx context.Context, updateURL string) (us ServerUpdateStatus, err error)

+ func (adm *AdminClient) ServiceFreeze(ctx context.Context) error

+ func (adm *AdminClient) ServiceRestart(ctx context.Context) error

+ func (adm *AdminClient) ServiceStop(ctx context.Context) error

+ func (adm *AdminClient) ServiceUnfreeze(ctx context.Context) error

+ func (adm *AdminClient) SetAppInfo(appName string, appVersion string)

+ func (adm *AdminClient) SetBucketQuota(ctx context.Context, bucket string, quota *BucketQuota) error

+ func (adm *AdminClient) SetConfig(ctx context.Context, config io.Reader) (err error)

+ func (adm *AdminClient) SetConfigKV(ctx context.Context, kv string) (restart bool, err error)

+ func (adm *AdminClient) SetCustomTransport(customHTTPTransport http.RoundTripper)

+ func (adm *AdminClient) SetGroupStatus(ctx context.Context, group string, status GroupStatus) error

+ func (adm *AdminClient) SetKMSPolicy(ctx context.Context, policy string, content []byte) error

+ func (adm *AdminClient) SetPolicy(ctx context.Context, policyName, entityName string, isGroup bool) error

+ func (adm *AdminClient) SetRemoteTarget(ctx context.Context, bucket string, target *BucketTarget) (string, error)

+ func (adm *AdminClient) SetUser(ctx context.Context, accessKey, secretKey string, status AccountStatus) error

+ func (adm *AdminClient) SetUserReq(ctx context.Context, accessKey string, req AddOrUpdateUserReq) error

+ func (adm *AdminClient) SetUserStatus(ctx context.Context, accessKey string, status AccountStatus) error

+ func (adm *AdminClient) SiteReplicationAdd(ctx context.Context, sites []PeerSite) (ReplicateAddStatus, error)

+ func (adm *AdminClient) SiteReplicationEdit(ctx context.Context, site PeerInfo) (ReplicateEditStatus, error)

+ func (adm *AdminClient) SiteReplicationInfo(ctx context.Context) (info SiteReplicationInfo, err error)

+ func (adm *AdminClient) SiteReplicationRemove(ctx context.Context, removeReq SRRemoveReq) (st ReplicateRemoveStatus, err error)

+ func (adm *AdminClient) SiteReplicationResyncOp(ctx context.Context, site PeerInfo, op SiteResyncOp) (SRResyncOpStatus, error)

+ func (adm *AdminClient) Speedtest(ctx context.Context, opts SpeedtestOpts) (chan SpeedTestResult, error)

+ func (adm *AdminClient) StartBatchJob(ctx context.Context, job string) (BatchJobResult, error)

+ func (adm *AdminClient) StartProfiling(ctx context.Context, profiler ProfilerType) ([]StartProfilingResult, error)

+ func (adm *AdminClient) StatusPool(ctx context.Context, pool string) (PoolStatus, error)

+ func (adm *AdminClient) StorageInfo(ctx context.Context) (StorageInfo, error)

+ func (adm *AdminClient) TemporaryAccountInfo(ctx context.Context, accessKey string) (TemporaryAccountInfoResp, error)

+ func (adm *AdminClient) TierStats(ctx context.Context) ([]TierInfo, error)

+ func (adm *AdminClient) TopLocks(ctx context.Context) (LockEntries, error)

+ func (adm *AdminClient) TopLocksWithOpts(ctx context.Context, opts TopLockOpts) (LockEntries, error)

+ func (adm *AdminClient) TraceOff()

+ func (adm *AdminClient) TraceOn(outputStream io.Writer)

+ func (adm *AdminClient) UpdateGroupMembers(ctx context.Context, g GroupAddRemove) error

+ func (adm *AdminClient) UpdateRemoteTarget(ctx context.Context, target *BucketTarget, ops ...TargetUpdateType) (string, error)

+ func (adm *AdminClient) UpdateServiceAccount(ctx context.Context, accessKey string, opts UpdateServiceAccountReq) error

+ func (adm *AdminClient) VerifyTier(ctx context.Context, tierName string) error

+ func (adm AdminClient) ExecuteMethod(ctx context.Context, method string, reqData RequestData) (res *http.Response, err error)

+ func (adm AdminClient) GetAccessAndSecretKey() (string, string)

+ func (adm AdminClient) GetEndpointURL() *url.URL

+ func (adm AdminClient) GetLogs(ctx context.Context, node string, lineCnt int, logKind string) <-chan LogInfo

+ func (adm AdminClient) ServiceTrace(ctx context.Context, opts ServiceTraceOpts) <-chan ServiceTraceInfo

+ type AliveOpts struct

+ Readiness bool

+ type AliveResult struct

+ DNSResolveTime time.Duration

+ Endpoint *url.URL

+ Error error

+ Online bool

+ ResponseTime time.Duration

+ type AnonymousClient struct

+ func NewAnonymousClient(endpoint string, secure bool) (*AnonymousClient, error)

+ func NewAnonymousClientNoEndpoint() (*AnonymousClient, error)

+ func (an *AnonymousClient) Alive(ctx context.Context, opts AliveOpts, servers ...ServerProperties) (resultsCh chan AliveResult)

+ func (an *AnonymousClient) Healthy(ctx context.Context, opts HealthOpts) (result HealthResult, err error)

+ func (an *AnonymousClient) SetCustomTransport(customHTTPTransport http.RoundTripper)

+ func (an *AnonymousClient) TraceOn(outputStream io.Writer)

+ type Audit map[string]Status

+ type AzureOptions func(*TierAzure) error

+ type BackendDisks map[string]int

+ func (d1 BackendDisks) Merge(d2 BackendDisks) BackendDisks

+ func (d1 BackendDisks) Sum() (sum int)

+ type BackendInfo struct

+ DrivesPerSet []int

+ GatewayOnline bool

+ OfflineDisks BackendDisks

+ OnlineDisks BackendDisks

+ RRSCData []int

+ RRSCParity int

+ StandardSCData []int

+ StandardSCParity int

+ TotalSets []int

+ Type BackendType

+ type BackendType int

+ const Erasure

+ const FS

+ const Gateway

+ const Unknown

+ type BandwidthDetails struct

+ CurrentBandwidthInBytesPerSecond float64

+ LimitInBytesPerSecond int64

+ type BatchJobMetrics struct

+ CollectedAt time.Time

+ Jobs map[string]JobMetric

+ func (o *BatchJobMetrics) Merge(other *BatchJobMetrics)

+ type BatchJobResult struct

+ Elapsed time.Duration

+ ID string

+ Started time.Time

+ Type BatchJobType

+ User string

+ type BatchJobType string

+ const BatchJobKeyRotate

+ const BatchJobReplicate

+ type BgHealState struct

+ HealDisks []string

+ MRF map[string]MRFStatus

+ OfflineEndpoints []string

+ SCParity map[string]int

+ ScannedItemsCount int64

+ Sets []SetStatus

+ func (b *BgHealState) Merge(others ...BgHealState)

+ type BktOp string

+ const ConfigureReplBktOp

+ const DeleteBucketBktOp

+ const ForceDeleteBucketBktOp

+ const MakeWithVersioningBktOp

+ const PurgeDeletedBucketOp

+ type BucketAccessInfo struct

+ Access AccountAccess

+ Created time.Time

+ Details *BucketDetails

+ Name string

+ ObjectSizesHistogram map[string]uint64

+ ObjectVersionsHistogram map[string]uint64

+ Objects uint64

+ PrefixUsage map[string]uint64

+ Size uint64

+ type BucketBandwidthReport struct

+ BucketStats map[string]BandwidthDetails

+ type BucketDetails struct

+ Locking bool

+ Quota *BucketQuota

+ Replication bool

+ Tagging *tags.Tags

+ Versioning bool

+ VersioningSuspended bool

+ type BucketMetaImportErrs struct

+ Buckets map[string]BucketStatus

+ type BucketQuota struct

+ Quota uint64

+ Type QuotaType

+ func (q BucketQuota) IsValid() bool

+ type BucketStatus struct

+ Err string

+ Lifecycle MetaStatus

+ Notification MetaStatus

+ ObjectLock MetaStatus

+ Policy MetaStatus

+ Quota MetaStatus

+ SSEConfig MetaStatus

+ Tagging MetaStatus

+ Versioning MetaStatus

+ type BucketTarget struct

+ API string

+ Arn string

+ BandwidthLimit int64

+ Credentials *Credentials

+ DisableProxy bool

+ Endpoint string

+ HealthCheckDuration time.Duration

+ LastOnline time.Time

+ Online bool

+ Path string

+ Region string

+ ReplicationSync bool

+ ResetBeforeDate time.Time

+ ResetID string

+ Secure bool

+ SourceBucket string

+ StorageClass string

+ TargetBucket string

+ TotalDowntime time.Duration

+ Type ServiceType

+ func (t *BucketTarget) Clone() BucketTarget

+ func (t *BucketTarget) String() string

+ func (t BucketTarget) Empty() bool

+ func (t BucketTarget) URL() *url.URL

+ type BucketTargets struct

+ Targets []BucketTarget

+ func (t BucketTargets) Empty() bool

+ type BucketUsageInfo struct

+ ObjectSizesHistogram map[string]uint64

+ ObjectVersionsHistogram map[string]uint64

+ ObjectsCount uint64

+ ReplicaSize uint64

+ ReplicatedSize uint64

+ ReplicationFailedCount uint64

+ ReplicationFailedSize uint64

+ ReplicationPendingCount uint64

+ ReplicationPendingSize uint64

+ Size uint64

+ VersionsCount uint64

+ type Buckets struct

+ Count uint64

+ Error string

+ type CPU struct

+ CacheSize int32

+ Cores int

+ Family string

+ Flags []string

+ Mhz float64

+ Microcode string

+ Model string

+ ModelName string

+ PhysicalID string

+ Stepping int32

+ VendorID string

+ type CPUFreqStats struct

+ AvailableGovernors string

+ CpuinfoCurrentFrequency *uint64

+ CpuinfoMaximumFrequency *uint64

+ CpuinfoMinimumFrequency *uint64

+ CpuinfoTransitionLatency *uint64

+ Driver string

+ Governor string

+ Name string

+ RelatedCpus string

+ ScalingCurrentFrequency *uint64

+ ScalingMaximumFrequency *uint64

+ ScalingMinimumFrequency *uint64

+ SetSpeed string

+ type CPUs struct

+ CPUFreqStats []CPUFreqStats

+ CPUs []CPU

+ func GetCPUs(ctx context.Context, addr string) CPUs

+ type ClusterInfo struct

+ MinioVersion string

+ NoOfBuckets uint64

+ NoOfDrives int

+ NoOfObjects uint64

+ NoOfServerPools int

+ NoOfServers int

+ TotalDriveSpace uint64

+ UsedDriveSpace uint64

+ type ClusterRegistrationInfo struct

+ ClusterName string

+ DeploymentID string

+ Info ClusterInfo

+ UsedCapacity uint64

+ type ClusterRegistrationReq struct

+ Token string

+ type ConfigHistoryEntry struct

+ CreateTime time.Time

+ Data string

+ RestoreID string

+ func (ch ConfigHistoryEntry) CreateTimeFormatted() string

+ type ConfigKV struct

+ EnvOverride *EnvOverride

+ Key string

+ Value string

+ type Credentials struct

+ AccessKey string

+ Expiration time.Time

+ SecretKey string

+ SessionToken string

+ type DailyTierStats struct

+ Bins [24]TierStats

+ UpdatedAt time.Time

+ type DataUsageInfo struct

+ BucketSizes map[string]uint64

+ BucketsCount uint64

+ BucketsUsage map[string]BucketUsageInfo

+ LastUpdate time.Time

+ ObjectsTotalCount uint64

+ ObjectsTotalSize uint64

+ ReplicaSize uint64

+ ReplicatedSize uint64

+ ReplicationFailedCount uint64

+ ReplicationFailedSize uint64

+ ReplicationPendingCount uint64

+ ReplicationPendingSize uint64

+ TierStats map[string]TierStats

+ type DiffInfo struct

+ DeleteReplicationStatus string

+ Err error

+ IsDeleteMarker bool

+ LastModified time.Time

+ Object string

+ ReplicationStatus string

+ ReplicationTimestamp time.Time

+ Targets map[string]TgtDiffInfo

+ VersionID string

+ type Disk struct

+ AvailableSpace uint64

+ DiskIndex int

+ DrivePath string

+ Endpoint string

+ FreeInodes uint64

+ HealInfo *HealingDisk

+ Healing bool

+ Major uint32

+ Metrics *DiskMetrics

+ Minor uint32

+ Model string

+ PoolIndex int

+ ReadLatency float64

+ ReadThroughput float64

+ RootDisk bool

+ Scanning bool

+ SetIndex int

+ State string

+ TotalSpace uint64

+ UUID string

+ UsedInodes uint64

+ UsedSpace uint64

+ Utilization float64

+ WriteLatency float64

+ WriteThroughPut float64

+ type DiskIOStats struct

+ CurrentIOs uint64

+ DiscardIOs uint64

+ DiscardMerges uint64

+ DiscardSectors uint64

+ DiscardTicks uint64

+ FlushIOs uint64

+ FlushTicks uint64

+ ReadIOs uint64

+ ReadMerges uint64

+ ReadSectors uint64

+ ReadTicks uint64

+ ReqTicks uint64

+ TotalTicks uint64

+ WriteIOs uint64

+ WriteMerges uint64

+ WriteSectors uint64

+ WriteTicks uint64

+ type DiskLatency struct

+ Avg float64

+ Max float64

+ Min float64

+ Percentile50 float64

+ Percentile90 float64

+ Percentile99 float64

+ type DiskMetric struct

+ CollectedAt time.Time

+ Healing int

+ IOStats DiskIOStats

+ LastMinute struct{ ... }

+ LifeTimeOps map[string]uint64

+ NDisks int

+ Offline int

+ func (d *DiskMetric) Merge(other *DiskMetric)

+ type DiskMetrics struct

+ APICalls map[string]uint64

+ APILatencies map[string]interface{}

+ LastMinute map[string]TimedAction

+ type DiskThroughput struct

+ Avg float64

+ Max float64

+ Min float64

+ Percentile50 float64

+ Percentile90 float64

+ Percentile99 float64

+ type DrivePerf struct

+ Error string

+ Path string

+ ReadThroughput uint64

+ WriteThroughput uint64

+ type DrivePerfInfo struct

+ Error string

+ Latency Latency

+ Path string

+ Throughput Throughput

+ type DrivePerfInfoV0 struct

+ Error string

+ Latency DiskLatency

+ Path string

+ Throughput DiskThroughput

+ type DrivePerfInfos struct

+ ParallelPerf []DrivePerfInfo

+ SerialPerf []DrivePerfInfo

+ type DriveSpeedTestOpts struct

+ BlockSize uint64

+ FileSize uint64

+ Serial bool

+ type DriveSpeedTestResult struct

+ DrivePerf []DrivePerf

+ Endpoint string

+ Error string

+ Version string

+ type EnvOverride struct

+ Name string

+ Value string

+ type ErasureBackend struct

+ DrivesPerSet []int

+ OfflineDisks int

+ OnlineDisks int

+ RRSCParity int

+ StandardSCParity int

+ TotalSets []int

+ Type backendType

+ type ErasureSetInfo struct

+ HealDisks int

+ ID int

+ ObjectsCount uint64

+ RawCapacity uint64

+ RawUsage uint64

+ Usage uint64

+ VersionsCount uint64

+ type ErrorResponse struct

+ BucketName string

+ Code string

+ HostID string

+ Key string

+ Message string

+ Region string

+ RequestID string

+ XMLName xml.Name

+ func ToErrorResponse(err error) ErrorResponse

+ func (e ErrorResponse) Error() string

+ type FSBackend struct

+ Type backendType

+ type GCSOptions func(*TierGCS) error

+ type GCStats struct

+ LastGC time.Time

+ NumGC int64

+ Pause []time.Duration

+ PauseEnd []time.Time

+ PauseTotal time.Duration

+ type GenerateBatchJobOpts struct

+ Type BatchJobType

+ type GroupAddRemove struct

+ Group string

+ IsRemove bool

+ Members []string

+ Status GroupStatus

+ type GroupDesc struct

+ Members []string

+ Name string

+ Policy string

+ Status string

+ UpdatedAt time.Time

+ type GroupPolicyEntities struct

+ Group string

+ Policies []string

+ type GroupStatus string

+ const GroupDisabled

+ const GroupEnabled

+ type HealDriveInfo struct

+ Endpoint string

+ State string

+ UUID string

+ type HealItemType string

+ type HealOpts struct

+ DryRun bool

+ NoLock bool

+ Recreate bool

+ Recursive bool

+ Remove bool

+ ScanMode HealScanMode

+ UpdateParity bool

+ func (o HealOpts) Equal(no HealOpts) bool

+ type HealResultItem struct

+ After struct{ ... }

+ Before struct{ ... }

+ Bucket string

+ DataBlocks int

+ Detail string

+ DiskCount int

+ Object string

+ ObjectSize int64

+ ParityBlocks int

+ ResultIndex int64

+ SetCount int

+ Type HealItemType

+ VersionID string

+ func (hri *HealResultItem) GetCorruptedCounts() (b, a int)

+ func (hri *HealResultItem) GetMissingCounts() (b, a int)

+ func (hri *HealResultItem) GetOfflineCounts() (b, a int)

+ func (hri *HealResultItem) GetOnlineCounts() (b, a int)

+ type HealScanMode int

+ const HealDeepScan

+ const HealNormalScan

+ const HealUnknownScan

+ type HealStartSuccess struct

+ ClientAddress string

+ ClientToken string

+ StartTime time.Time

+ type HealStopSuccess HealStartSuccess

+ type HealTaskStatus struct

+ FailureDetail string

+ HealSettings HealOpts

+ Items []HealResultItem

+ StartTime time.Time

+ Summary string

+ type HealingDisk struct

+ Bucket string

+ BytesDone uint64

+ BytesFailed uint64

+ DiskIndex int

+ Endpoint string

+ HealID string

+ HealedBuckets []string

+ ID string

+ ItemsFailed uint64

+ ItemsHealed uint64

+ LastUpdate time.Time

+ Object string

+ ObjectsFailed uint64

+ ObjectsHealed uint64

+ ObjectsTotalCount uint64

+ ObjectsTotalSize uint64

+ Path string

+ PoolIndex int

+ QueuedBuckets []string

+ SetIndex int

+ Started time.Time

+ type HealthDataType string

+ const HealthDataTypeMinioConfig

+ const HealthDataTypeMinioInfo

+ const HealthDataTypeSysCPU

+ const HealthDataTypeSysConfig

+ const HealthDataTypeSysDocker

+ const HealthDataTypeSysDriveHw

+ const HealthDataTypeSysErrors

+ const HealthDataTypeSysLoad

+ const HealthDataTypeSysMem

+ const HealthDataTypeSysNet

+ const HealthDataTypeSysOsInfo

+ const HealthDataTypeSysProcess

+ const HealthDataTypeSysServices

+ type HealthInfo struct

+ Error string

+ Minio MinioHealthInfo

+ Sys SysInfo

+ TimeStamp time.Time

+ Version string

+ func (info HealthInfo) GetError() string

+ func (info HealthInfo) GetStatus() string

+ func (info HealthInfo) GetTimestamp() time.Time

+ func (info HealthInfo) JSON() string

+ func (info HealthInfo) String() string

+ type HealthInfoV0 struct

+ Error string

+ Minio MinioHealthInfoV0

+ Perf PerfInfoV0

+ Sys SysHealthInfo

+ TimeStamp time.Time

+ func (info HealthInfoV0) JSON() string

+ func (info HealthInfoV0) String() string

+ type HealthInfoV2 struct

+ Error string

+ Minio MinioHealthInfo

+ Perf PerfInfo

+ Sys SysInfo

+ TimeStamp time.Time

+ Version string

+ func (info HealthInfoV2) GetError() string

+ func (info HealthInfoV2) GetStatus() string

+ func (info HealthInfoV2) GetTimestamp() time.Time

+ func (info HealthInfoV2) JSON() string

+ func (info HealthInfoV2) String() string

+ type HealthInfoVersionStruct struct

+ Error string

+ Version string

+ type HealthOpts struct

+ ClusterRead bool

+ Maintenance bool

+ type HealthResult struct

+ HealingDrives int

+ Healthy bool

+ MaintenanceMode bool

+ WriteQuorum int

+ type Help struct

+ Description string

+ KeysHelp HelpKVS

+ MultipleTargets bool

+ SubSys string

+ func (h Help) Keys() []string

+ type HelpKV struct

+ Description string

+ Key string

+ MultipleTargets bool

+ Optional bool

+ Type string

+ type HelpKVS []HelpKV

+ type IDPCfgInfo struct

+ IsCfg bool

+ IsEnv bool

+ Key string

+ Value string

+ type IDPConfig struct

+ Info []IDPCfgInfo

+ Name string

+ Type string

+ type IDPListItem struct

+ Enabled bool

+ Name string

+ RoleARN string

+ Type string

+ type IDPSettings struct

+ LDAP LDAPSettings

+ OpenID OpenIDSettings

+ type InfoMessage struct

+ Backend ErasureBackend

+ Buckets Buckets

+ DeploymentID string

+ Domain []string

+ Mode string

+ Objects Objects

+ Pools map[int]map[int]ErasureSetInfo

+ Region string

+ SQSARN []string

+ Servers []ServerProperties

+ Services Services

+ Usage Usage

+ Versions Versions

+ func (info InfoMessage) BackendType() BackendType

+ func (info InfoMessage) StandardParity() int

+ type InfoServiceAccountResp struct

+ AccountStatus string

+ Description string

+ Expiration *time.Time

+ ImpliedPolicy bool

+ Name string

+ ParentUser string

+ Policy string

+ type InspectOptions struct

+ File string

+ PublicKey []byte

+ Volume string

+ type ItemState string

+ type JobMetric struct

+ Complete bool

+ Failed bool

+ JobID string

+ JobType string

+ KeyRotate *KeyRotationInfo

+ LastUpdate time.Time

+ Replicate *ReplicateInfo

+ RetryAttempts int

+ StartTime time.Time

+ type KMS struct

+ Decrypt string

+ Encrypt string

+ Status string

+ type KMSAPI struct

+ MaxBody int64

+ Method string

+ Path string

+ Timeout int64

+ type KMSDescribeIdentity struct

+ CreatedAt string

+ CreatedBy string

+ Identity string

+ IsAdmin bool

+ Policy string

+ type KMSDescribePolicy struct

+ CreatedAt string

+ CreatedBy string

+ Name string

+ type KMSDescribeSelfIdentity struct

+ CreatedAt string

+ CreatedBy string

+ Identity string

+ IsAdmin bool

+ Policy *KMSPolicy

+ PolicyName string

+ type KMSIdentityInfo struct

+ CreatedAt string

+ CreatedBy string

+ Error string

+ Identity string

+ Policy string

+ type KMSKeyInfo struct

+ CreatedAt string

+ CreatedBy string

+ Name string

+ type KMSKeyStatus struct

+ DecryptionErr string

+ EncryptionErr string

+ KeyID string

+ type KMSMetrics struct

+ AuditEvents int64

+ CPUs int64

+ ErrorEvents int64

+ HeapAlloc int64

+ HeapObjects int64

+ LatencyHistogram map[int64]int64

+ RequestActive int64

+ RequestErr int64

+ RequestFail int64

+ RequestOK int64

+ StackAlloc int64

+ Threads int64

+ UpTime int64

+ UsableCPUs int64

+ type KMSPolicy struct

+ Allow []string

+ Deny []string

+ type KMSPolicyInfo struct

+ CreatedAt string

+ CreatedBy string

+ Name string

+ type KMSState struct

+ Arch string

+ CPUs int

+ HeapAlloc uint64

+ KeyStoreLatency time.Duration

+ KeyStoreReachable bool

+ KeystoreAvailable bool

+ OS string

+ StackAlloc uint64

+ UpTime time.Duration

+ UsableCPUs int

+ Version string

+ type KMSStatus struct

+ DefaultKeyID string

+ Endpoints map[string]ItemState

+ Name string

+ State KMSState

+ type KMSVersion struct

+ Version string

+ type KVOptions struct

+ Env bool

+ type KeyRotationInfo struct

+ Bucket string

+ Object string

+ Objects int64

+ ObjectsFailed int64

+ type KubernetesInfo struct

+ BuildDate time.Time

+ Error string

+ GitCommit string

+ GitVersion string

+ Major string

+ Minor string

+ Platform string

+ type LDAP struct

+ Status string

+ type LDAPSettings struct

+ IsLDAPEnabled bool

+ LDAPGroupSearchBase string

+ LDAPGroupSearchFilter string

+ LDAPUserDNSearchBase string

+ LDAPUserDNSearchFilter string

+ type Latency struct

+ Avg float64

+ Max float64

+ Min float64

+ Percentile50 float64

+ Percentile90 float64

+ Percentile99 float64

+ type ListBatchJobsFilter struct

+ ByJobType string

+ type ListBatchJobsResult struct

+ Jobs []BatchJobResult

+ type ListServiceAccountsResp struct

+ Accounts []ServiceAccountInfo

+ type LockEntries []LockEntry

+ func (l LockEntries) Len() int

+ func (l LockEntries) Less(i, j int) bool

+ func (l LockEntries) Swap(i, j int)

+ type LockEntry struct

+ Elapsed time.Duration

+ ID string

+ Owner string

+ Quorum int

+ Resource string

+ ServerList []string

+ Source string

+ Timestamp time.Time

+ Type string

+ type LogInfo struct

+ ConsoleMsg string

+ Err error

+ NodeName string

+ func (l LogInfo) Mask() uint64

+ type LogKind string

+ const LogKindAll

+ const LogKindApplication

+ const LogKindMinio

+ func (l LogKind) LogMask() LogMask

+ func (l LogKind) String() string

+ type LogMask uint64

+ const LogMaskAll

+ const LogMaskApplication

+ const LogMaskMinIO

+ func (m LogMask) Contains(other LogMask) bool

+ func (m LogMask) Mask() uint64

+ type Logger map[string]Status

+ type MRFStatus struct

+ BytesHealed uint64

+ ItemsHealed uint64

+ type MemInfo struct

+ Available uint64

+ Limit uint64

+ SwapSpaceFree uint64

+ SwapSpaceTotal uint64

+ Total uint64

+ func GetMemInfo(ctx context.Context, addr string) MemInfo

+ type MemStats struct

+ Alloc uint64

+ Frees uint64

+ HeapAlloc uint64

+ Mallocs uint64

+ TotalAlloc uint64

+ type MetaStatus struct

+ Err string

+ IsSet bool

+ type MetricType uint32

+ const MetricsAll

+ const MetricsBatchJobs

+ const MetricsDisk

+ const MetricsNone

+ const MetricsOS

+ const MetricsScanner

+ const MetricsSiteResync

+ func (m MetricType) Contains(x MetricType) bool

+ type Metrics struct

+ BatchJobs *BatchJobMetrics

+ Disk *DiskMetric

+ OS *OSMetrics

+ Scanner *ScannerMetrics

+ SiteResync *SiteResyncMetrics

+ func (r *Metrics) Merge(other *Metrics)

+ type MetricsOptions struct

+ ByDepID string

+ ByDisk bool

+ ByHost bool

+ ByJobID string

+ Disks []string

+ Hosts []string

+ Interval time.Duration

+ N int

+ Type MetricType

+ type MinIOOptions func(*TierMinIO) error

+ type MinioConfig struct

+ Config interface{}

+ Error string

+ type MinioHealthInfo struct

+ Config MinioConfig

+ Error string

+ Info MinioInfo

+ type MinioHealthInfoV0 struct

+ Config interface{}

+ Error string

+ Info InfoMessage

+ type MinioInfo struct

+ Backend interface{}

+ Buckets Buckets

+ DeploymentID string

+ Domain []string

+ IsDocker *bool

+ IsKubernetes *bool

+ Mode string

+ Objects Objects

+ Region string

+ SQSARN []string

+ Servers []ServerInfo

+ Services Services

+ TLS *TLSInfo

+ Usage Usage

+ type NetLatency struct

+ Avg float64

+ Max float64

+ Min float64

+ Percentile50 float64

+ Percentile90 float64

+ Percentile99 float64

+ type NetPerfInfo struct

+ RemotePeers []PeerNetPerfInfo

+ type NetPerfInfoV0 struct

+ Addr string

+ Error string

+ Latency NetLatency

+ Throughput NetThroughput

+ type NetThroughput struct

+ Avg float64

+ Max float64

+ Min float64

+ Percentile50 float64

+ Percentile90 float64

+ Percentile99 float64

+ type NetperfNodeResult struct

+ Endpoint string

+ Error string

+ RX uint64

+ TX uint64

+ type NetperfResult struct

+ NodeResults []NetperfNodeResult

+ type NodeCommon struct

+ Addr string

+ Error string

+ func (n *NodeCommon) GetAddr() string

+ func (n *NodeCommon) SetAddr(addr string)

+ func (n *NodeCommon) SetError(err string)

+ type NodeInfo interface

+ GetAddr func() string

+ SetAddr func(addr string)

+ SetError func(err string)

+ type OSInfo struct

+ Info host.InfoStat

+ Sensors []host.TemperatureStat

+ func GetOSInfo(ctx context.Context, addr string) OSInfo

+ type OSMetrics struct

+ CollectedAt time.Time

+ LastMinute struct{ ... }

+ LifeTimeOps map[string]uint64

+ func (o *OSMetrics) Merge(other *OSMetrics)

+ type Objects struct

+ Count uint64

+ Error string

+ type OpenIDProviderSettings struct

+ ClaimName string

+ ClaimUserinfoEnabled bool

+ ClientID string

+ HashedClientSecret string

+ RolePolicy string

+ type OpenIDSettings struct

+ ClaimProvider OpenIDProviderSettings

+ Enabled bool

+ Region string

+ Roles map[string]OpenIDProviderSettings

+ type Options struct

+ Creds *credentials.Credentials

+ Secure bool

+ type Partition struct

+ Device string

+ Error string

+ FSType string

+ InodeFree uint64

+ InodeTotal uint64

+ MountFSType string

+ MountOptions string

+ Mountpoint string

+ SpaceFree uint64

+ SpaceTotal uint64

+ type PartitionStat struct

+ Device string

+ Fstype string

+ Mountpoint string

+ Opts string

+ SmartInfo SmartInfo

+ type Partitions struct

+ Partitions []Partition

+ func GetPartitions(ctx context.Context, addr string) Partitions

+ type PeerInfo struct

+ DeploymentID string

+ Endpoint string

+ Name string

+ SyncState SyncStatus

+ type PeerNetPerfInfo struct

+ Latency Latency

+ Throughput Throughput

+ type PeerSite struct

+ AccessKey string

+ Endpoint string

+ Name string

+ SecretKey string

+ type PerfInfo struct

+ Drives []DrivePerfInfos

+ Net []NetPerfInfo

+ NetParallel NetPerfInfo

+ type PerfInfoV0 struct

+ DriveInfo []ServerDrivesInfo

+ Error string

+ Net []ServerNetHealthInfo

+ NetParallel ServerNetHealthInfo

+ type PolicyAssociationReq struct

+ Group string

+ Policies []string

+ User string

+ func (p PolicyAssociationReq) IsValid() error

+ type PolicyAssociationResp struct

+ PoliciesAttached []string

+ PoliciesDetached []string

+ UpdatedAt time.Time

+ type PolicyEntities struct

+ Groups []string

+ Policy string

+ Users []string

+ type PolicyEntitiesQuery struct

+ Groups []string

+ Policy []string

+ Users []string

+ type PolicyEntitiesResult struct

+ GroupMappings []GroupPolicyEntities

+ PolicyMappings []PolicyEntities

+ Timestamp time.Time

+ UserMappings []UserPolicyEntities

+ type PolicyInfo struct

+ CreateDate time.Time

+ Policy json.RawMessage

+ PolicyName string

+ UpdateDate time.Time

+ func (pi PolicyInfo) MarshalJSON() ([]byte, error)

+ type PoolDecommissionInfo struct

+ Canceled bool

+ Complete bool

+ CurrentSize int64

+ Failed bool

+ StartSize int64

+ StartTime time.Time

+ TotalSize int64

+ type PoolStatus struct

+ CmdLine string

+ Decommission *PoolDecommissionInfo

+ ID int

+ LastUpdate time.Time

+ type ProcInfo struct

+ CPUPercent float64

+ CWD string

+ ChildrenPIDs []int32

+ CmdLine string

+ CreateTime int64

+ ExecPath string

+ GIDs []int32

+ IOCounters process.IOCountersStat

+ IsBackground bool

+ IsRunning bool

+ MemInfo process.MemoryInfoStat

+ MemMaps []process.MemoryMapsStat

+ MemPercent float32

+ Name string

+ Nice int32

+ NumConnections int

+ NumCtxSwitches process.NumCtxSwitchesStat

+ NumFDs int32

+ NumThreads int32

+ PID int32

+ PPID int32

+ PageFaults process.PageFaultsStat

+ Status string

+ TGID int32

+ Times cpu.TimesStat

+ UIDs []int32

+ Username string

+ func GetProcInfo(ctx context.Context, addr string) ProcInfo

+ type ProfilerType string

+ const ProfilerBlock

+ const ProfilerCPU

+ const ProfilerCPUIO

+ const ProfilerGoroutines

+ const ProfilerMEM

+ const ProfilerMutex

+ const ProfilerThreads

+ const ProfilerTrace

+ type QuotaType string

+ const HardQuota

+ func (t QuotaType) IsValid() bool

+ type RealtimeMetrics struct

+ Aggregated Metrics

+ ByDisk map[string]DiskMetric

+ ByHost map[string]Metrics

+ Errors []string

+ Final bool

+ Hosts []string

+ func (r *RealtimeMetrics) Merge(other *RealtimeMetrics)

+ type RebalPoolProgress struct

+ Bucket string

+ Bytes uint64

+ ETA time.Duration

+ Elapsed time.Duration

+ NumObjects uint64

+ NumVersions uint64

+ Object string

+ type RebalancePoolStatus struct

+ ID int

+ Progress RebalPoolProgress

+ Status string

+ Used float64

+ type RebalanceStatus struct

+ ID string

+ Pools []RebalancePoolStatus

+ StoppedAt time.Time

+ type ReplDiffOpts struct

+ ARN string

+ Prefix string

+ Verbose bool

+ type ReplicateAddStatus struct

+ ErrDetail string

+ InitialSyncErrorMessage string

+ Status string

+ Success bool

+ type ReplicateEditStatus struct

+ ErrDetail string

+ Status string

+ Success bool

+ type ReplicateInfo struct

+ Bucket string

+ BytesFailed int64

+ BytesTransferred int64

+ Object string

+ Objects int64

+ ObjectsFailed int64

+ type ReplicateRemoveStatus struct

+ ErrDetail string

+ Status string

+ type Report struct

+ Err error

+ Report BucketBandwidthReport

+ type RequestData struct

+ Content []byte

+ CustomHeaders http.Header

+ QueryValues url.Values

+ RelPath string

+ type ResyncBucketStatus struct

+ Bucket string

+ ErrDetail string

+ Status string

+ type S3Options func(*TierS3) error

+ type SRBucketInfo struct

+ Bucket string

+ CreatedAt time.Time

+ DeletedAt time.Time

+ Location string

+ ObjectLockConfig *string

+ ObjectLockConfigUpdatedAt time.Time

+ Policy json.RawMessage

+ PolicyUpdatedAt time.Time

+ QuotaConfig *string

+ QuotaConfigUpdatedAt time.Time

+ ReplicationConfig *string

+ ReplicationConfigUpdatedAt time.Time

+ SSEConfig *string

+ SSEConfigUpdatedAt time.Time

+ TagConfigUpdatedAt time.Time

+ Tags *string

+ Versioning *string

+ VersioningConfigUpdatedAt time.Time

+ type SRBucketMeta struct

+ Bucket string

+ ObjectLockConfig *string

+ Policy json.RawMessage

+ Quota json.RawMessage

+ SSEConfig *string

+ Tags *string

+ Type string

+ UpdatedAt time.Time

+ Versioning *string

+ type SRBucketStatsSummary struct

+ BucketMarkedDeleted bool

+ DeploymentID string

+ HasBucket bool

+ HasOLockConfigSet bool

+ HasPolicySet bool

+ HasQuotaCfgSet bool

+ HasReplicationCfg bool

+ HasSSECfgSet bool

+ HasTagsSet bool

+ OLockConfigMismatch bool

+ PolicyMismatch bool

+ QuotaCfgMismatch bool

+ ReplicationCfgMismatch bool

+ SSEConfigMismatch bool

+ TagMismatch bool

+ VersioningConfigMismatch bool

+ type SREntityType int

+ const SRBucketEntity

+ const SRGroupEntity

+ const SRPolicyEntity

+ const SRUserEntity

+ const Unspecified

+ func GetSREntityType(name string) SREntityType

+ type SRGroupInfo struct

+ UpdateReq GroupAddRemove

+ type SRGroupStatsSummary struct

+ DeploymentID string

+ GroupDescMismatch bool

+ HasGroup bool

+ HasPolicyMapping bool

+ PolicyMismatch bool

+ type SRIAMItem struct

+ GroupInfo *SRGroupInfo

+ IAMUser *SRIAMUser

+ Name string

+ Policy json.RawMessage

+ PolicyMapping *SRPolicyMapping

+ STSCredential *SRSTSCredential

+ SvcAccChange *SRSvcAccChange

+ Type string

+ UpdatedAt time.Time

+ type SRIAMPolicy struct

+ Policy json.RawMessage

+ UpdatedAt time.Time

+ type SRIAMUser struct

+ AccessKey string

+ IsDeleteReq bool

+ UserReq *AddOrUpdateUserReq

+ type SRInfo struct

+ Buckets map[string]SRBucketInfo

+ DeploymentID string

+ Enabled bool

+ GroupDescMap map[string]GroupDesc

+ GroupPolicies map[string]SRPolicyMapping

+ Name string

+ Policies map[string]SRIAMPolicy

+ ReplicationCfg map[string]replication.Config

+ UserInfoMap map[string]UserInfo

+ UserPolicies map[string]SRPolicyMapping

+ type SRPeerJoinReq struct

+ Peers map[string]PeerInfo

+ SvcAcctAccessKey string

+ SvcAcctParent string

+ SvcAcctSecretKey string

+ type SRPolicyMapping struct

+ CreatedAt time.Time

+ IsGroup bool

+ Policy string

+ UpdatedAt time.Time

+ UserOrGroup string

+ UserType int

+ type SRPolicyStatsSummary struct

+ DeploymentID string

+ HasPolicy bool

+ PolicyMismatch bool

+ type SRRemoveReq struct

+ RemoveAll bool

+ RequestingDepID string

+ SiteNames []string

+ type SRResyncOpStatus struct

+ Buckets []ResyncBucketStatus

+ ErrDetail string

+ OpType string

+ ResyncID string

+ Status string

+ type SRSTSCredential struct

+ AccessKey string

+ ParentPolicyMapping string

+ ParentUser string

+ SecretKey string

+ SessionToken string

+ type SRSiteSummary struct

+ ReplicatedBucketPolicies int

+ ReplicatedBuckets int

+ ReplicatedGroupPolicyMappings int

+ ReplicatedGroups int

+ ReplicatedIAMPolicies int

+ ReplicatedLockConfig int

+ ReplicatedQuotaConfig int

+ ReplicatedSSEConfig int

+ ReplicatedTags int

+ ReplicatedUserPolicyMappings int

+ ReplicatedUsers int

+ ReplicatedVersioningConfig int

+ TotalBucketPoliciesCount int

+ TotalBucketsCount int

+ TotalGroupPolicyMappingCount int

+ TotalGroupsCount int

+ TotalIAMPoliciesCount int

+ TotalLockConfigCount int

+ TotalQuotaConfigCount int

+ TotalSSEConfigCount int

+ TotalTagsCount int

+ TotalUserPolicyMappingCount int

+ TotalUsersCount int

+ TotalVersioningConfigCount int

+ type SRStatusInfo struct

+ BucketStats map[string]map[string]SRBucketStatsSummary

+ Enabled bool

+ GroupStats map[string]map[string]SRGroupStatsSummary

+ MaxBuckets int

+ MaxGroups int

+ MaxPolicies int

+ MaxUsers int

+ PolicyStats map[string]map[string]SRPolicyStatsSummary

+ Sites map[string]PeerInfo

+ StatsSummary map[string]SRSiteSummary

+ UserStats map[string]map[string]SRUserStatsSummary

+ type SRStatusOptions struct

+ Buckets bool

+ Entity SREntityType

+ EntityValue string

+ Groups bool

+ Policies bool

+ ShowDeleted bool

+ Users bool

+ func (o *SRStatusOptions) IsEntitySet() bool

+ type SRSvcAccChange struct

+ Create *SRSvcAccCreate

+ Delete *SRSvcAccDelete

+ Update *SRSvcAccUpdate

+ type SRSvcAccCreate struct

+ AccessKey string

+ Claims map[string]interface{}

+ Description string

+ Expiration *time.Time

+ Groups []string

+ Name string

+ Parent string

+ SecretKey string

+ SessionPolicy json.RawMessage

+ Status string

+ type SRSvcAccDelete struct

+ AccessKey string

+ type SRSvcAccUpdate struct

+ AccessKey string

+ Description string

+ Expiration *time.Time

+ Name string

+ SecretKey string

+ SessionPolicy json.RawMessage

+ Status string

+ type SRUserStatsSummary struct

+ DeploymentID string

+ HasPolicyMapping bool

+ HasUser bool

+ PolicyMismatch bool

+ UserInfoMismatch bool

+ type ScannerMetrics struct

+ ActivePaths []string

+ CollectedAt time.Time

+ CurrentCycle uint64

+ CurrentStarted time.Time

+ CyclesCompletedAt []time.Time

+ LastMinute struct{ ... }

+ LifeTimeILM map[string]uint64

+ LifeTimeOps map[string]uint64

+ func (s *ScannerMetrics) Merge(other *ScannerMetrics)

+ type ServerCPUInfo struct

+ Addr string

+ CPUStat []cpu.InfoStat

+ Error string

+ TimeStat []cpu.TimesStat

+ type ServerDiskHwInfo struct

+ Addr string

+ Counters map[string]diskhw.IOCountersStat

+ Error string

+ Partitions []PartitionStat

+ Usage []*diskhw.UsageStat

+ func (s *ServerDiskHwInfo) GetTotalCapacity() (capacity uint64)

+ func (s *ServerDiskHwInfo) GetTotalFreeCapacity() (capacity uint64)

+ func (s *ServerDiskHwInfo) GetTotalUsedCapacity() (capacity uint64)

+ type ServerDrivesInfo struct

+ Addr string

+ Error string

+ Parallel []DrivePerfInfoV0

+ Serial []DrivePerfInfoV0

+ type ServerInfo struct

+ CommitID string

+ Drives []Disk

+ Endpoint string

+ GCStats *GCStats

+ GoMaxProcs int

+ MemStats MemStats

+ MinioEnvVars map[string]string

+ Network map[string]string

+ NumCPU int

+ PoolNumber int

+ RuntimeVersion string

+ State string

+ Uptime int64

+ Version string

+ type ServerMemInfo struct

+ Addr string

+ Error string

+ SwapMem *mem.SwapMemoryStat

+ VirtualMem *mem.VirtualMemoryStat

+ type ServerNetHealthInfo struct

+ Addr string

+ Error string

+ Net []NetPerfInfoV0

+ type ServerOsInfo struct

+ Addr string

+ Error string

+ Info *host.InfoStat

+ Sensors []host.TemperatureStat

+ Users []host.UserStat

+ type ServerProcInfo struct

+ Addr string

+ Error string

+ Processes []SysProcess

+ type ServerProperties struct

+ CommitID string

+ Disks []Disk

+ Endpoint string

+ GCStats *GCStats

+ GoMaxProcs int

+ MemStats MemStats

+ MinioEnvVars map[string]string

+ Network map[string]string

+ NumCPU int

+ PoolNumber int

+ RuntimeVersion string

+ Scheme string

+ State string

+ Uptime int64

+ Version string

+ type ServerUpdateStatus struct

+ CurrentVersion string

+ UpdatedVersion string

+ type ServiceAccountInfo struct

+ AccessKey string

+ Expiration *time.Time

+ type ServiceAction string

+ type ServiceTraceInfo struct

+ Err error

+ Trace TraceInfo

+ type ServiceTraceOpts struct

+ BatchKeyRotation bool

+ BatchReplication bool

+ Bootstrap bool

+ Decommission bool

+ FTP bool

+ Healing bool

+ ILM bool

+ Internal bool

+ OS bool

+ OnlyErrors bool

+ Rebalance bool

+ ReplicationResync bool

+ S3 bool

+ Scanner bool

+ Storage bool

+ Threshold time.Duration

+ func (t *ServiceTraceOpts) ParseParams(r *http.Request) (err error)

+ func (t ServiceTraceOpts) AddParams(u url.Values)

+ func (t ServiceTraceOpts) TraceTypes() TraceType

+ type ServiceType string

+ const ReplicationService

+ func (t ServiceType) IsValid() bool

+ type Services struct

+ Audit []Audit

+ KMS KMS

+ LDAP LDAP

+ Logger []Logger

+ Notifications []map[string][]TargetIDStatus

+ type SetStatus struct

+ Disks []Disk

+ HealPriority string

+ HealStatus string

+ ID string

+ PoolIndex int

+ SetIndex int

+ TotalObjects int

+ type SiteReplicationInfo struct

+ Enabled bool

+ Name string

+ ServiceAccountAccessKey string

+ Sites []PeerInfo

+ type SiteResyncMetrics struct

+ Bucket string

+ CollectedAt time.Time

+ DeplID string

+ FailedBuckets []string

+ FailedCount int64

+ FailedSize int64

+ LastUpdate time.Time

+ NumBuckets int64

+ Object string

+ ReplicatedCount int64

+ ReplicatedSize int64

+ ResyncID string

+ ResyncStatus string

+ StartTime time.Time

+ func (o *SiteResyncMetrics) Merge(other *SiteResyncMetrics)

+ func (o SiteResyncMetrics) Complete() bool

+ type SiteResyncOp string

+ const SiteResyncCancel

+ const SiteResyncStart

+ type SmartAtaInfo struct

+ ATAMajorVersion string

+ ATAMinorVersion string

+ ErrorLog string

+ FirmwareRevision string

+ LUWWNDeviceID string

+ ModelNum string

+ RotationRate string

+ SerialNum string

+ SmartSupportAvailable bool

+ SmartSupportEnabled bool

+ Transport string

+ type SmartInfo struct

+ Ata *SmartAtaInfo

+ Device string

+ Nvme *SmartNvmeInfo

+ Scsi *SmartScsiInfo

+ type SmartNvmeInfo struct

+ ControllerBusyTime *big.Int

+ CriticalWarning string

+ DataUnitsReadBytes *big.Int

+ DataUnitsWrittenBytes *big.Int

+ FirmwareVersion string

+ HostReadCommands *big.Int

+ HostWriteCommands *big.Int

+ MaxDataTransferPages int

+ MediaAndDataIntegrityErrors *big.Int

+ ModelNum string

+ PowerCycles *big.Int

+ PowerOnHours *big.Int

+ SerialNum string

+ SpareAvailable string

+ SpareThreshold string

+ Temperature string

+ UnsafeShutdowns *big.Int

+ VendorID string

+ type SmartScsiInfo struct

+ BdLen int64

+ CapacityBytes int64

+ ModeSenseBuf string

+ Offset int64

+ RPM int64

+ RespLen int64

+ type SpeedTestResult struct

+ Concurrent int

+ Disks int

+ GETStats SpeedTestStats

+ PUTStats SpeedTestStats

+ Servers int

+ Size int

+ Version string

+ type SpeedTestResults struct

+ DrivePerf []DriveSpeedTestResult

+ Error string

+ NetPerf []NetperfNodeResult

+ ObjPerf []SpeedTestResult

+ type SpeedTestStatServer struct

+ Endpoint string

+ Err string

+ ObjectsPerSec uint64

+ ThroughputPerSec uint64

+ type SpeedTestStats struct

+ ObjectsPerSec uint64

+ Response Timings

+ Servers []SpeedTestStatServer

+ TTFB Timings

+ ThroughputPerSec uint64

+ type SpeedtestOpts struct

+ Autotune bool

+ Bucket string

+ Concurrency int

+ Duration time.Duration

+ NoClear bool

+ Size int

+ StorageClass string

+ type StartProfilingResult struct

+ Error string

+ NodeName string

+ Success bool

+ type Status struct

+ Status string

+ type StorageInfo struct

+ Backend BackendInfo

+ Disks []Disk

+ type SubnetLoginReq struct

+ Password string

+ Username string

+ type SubnetMFAReq struct

+ OTP string

+ Token string

+ Username string

+ type SubsysConfig struct

+ KV []ConfigKV

+ SubSystem string

+ Target string

+ func ParseServerConfigOutput(serverConfigOutput string) ([]SubsysConfig, error)

+ func (c *SubsysConfig) AddConfigKV(ckv ConfigKV)

+ func (c *SubsysConfig) Lookup(key string) (val string, present bool)

+ type SyncStatus string

+ const SyncDisabled

+ const SyncEnabled

+ func (s SyncStatus) Empty() bool

+ type SysConfig struct

+ Config map[string]interface{}

+ func GetSysConfig(_ context.Context, addr string) SysConfig

+ type SysErrors struct

+ Errors []string

+ func GetSysErrors(_ context.Context, addr string) SysErrors

+ type SysHealthInfo struct

+ CPUInfo []ServerCPUInfo

+ DiskHwInfo []ServerDiskHwInfo

+ Error string

+ MemInfo []ServerMemInfo

+ OsInfo []ServerOsInfo

+ ProcInfo []ServerProcInfo

+ type SysInfo struct

+ CPUInfo []CPUs

+ KubernetesInfo KubernetesInfo

+ MemInfo []MemInfo

+ OSInfo []OSInfo

+ Partitions []Partitions

+ ProcInfo []ProcInfo

+ SysConfig []SysConfig

+ SysErrs []SysErrors

+ SysServices []SysServices

+ type SysProcess struct

+ Background bool

+ CPUPercent float64

+ Children []int32

+ CmdLine string

+ ConnectionCount int

+ CreateTime int64

+ Cwd string

+ Exe string

+ Gids []int32

+ IOCounters *process.IOCountersStat

+ IsRunning bool

+ MemInfo *process.MemoryInfoStat

+ MemMaps *[]process.MemoryMapsStat

+ MemPercent float32

+ Name string

+ Nice int32

+ NumCtxSwitches *process.NumCtxSwitchesStat

+ NumFds int32

+ NumThreads int32

+ PageFaults *process.PageFaultsStat

+ Parent int32

+ Pid int32

+ Ppid int32

+ Status string

+ Tgid int32

+ Times *cpu.TimesStat

+ Uids []int32

+ Username string

+ func (sp SysProcess) GetOwner() string

+ type SysService struct

+ Name string

+ Status string

+ type SysServices struct

+ Services []SysService

+ func GetSysServices(_ context.Context, addr string) SysServices

+ type TLSCert struct

+ NotAfter time.Time

+ NotBefore time.Time

+ PubKeyAlgo string

+ SignatureAlgo string

+ type TLSInfo struct

+ Certs []TLSCert

+ TLSEnabled bool

+ type TargetIDStatus map[string]Status

+ type TargetUpdateType int

+ const BandwidthLimitUpdateType

+ const CredentialsUpdateType

+ const HealthCheckDurationUpdateType

+ const PathUpdateType

+ const ProxyUpdateType

+ const ResetUpdateType

+ const SyncUpdateType

+ func GetTargetUpdateOps(values url.Values) []TargetUpdateType

+ type TemporaryAccountInfoResp InfoServiceAccountResp

+ type TgtDiffInfo struct

+ DeleteReplicationStatus string

+ ReplicationStatus string

+ type Throughput struct

+ Avg uint64

+ Max uint64

+ Min uint64

+ Percentile50 uint64

+ Percentile90 uint64

+ Percentile99 uint64

+ type TierAzure struct

+ AccountKey string

+ AccountName string

+ Bucket string

+ Endpoint string

+ Prefix string

+ Region string

+ StorageClass string

+ func (z *TierAzure) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *TierAzure) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *TierAzure) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *TierAzure) Msgsize() (s int)

+ func (z *TierAzure) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type TierConfig struct

+ Azure *TierAzure

+ GCS *TierGCS

+ MinIO *TierMinIO

+ Name string

+ S3 *TierS3

+ Type TierType

+ Version string

+ func NewTierAzure(name, accountName, accountKey, bucket string, options ...AzureOptions) (*TierConfig, error)

+ func NewTierGCS(name string, credsJSON []byte, bucket string, options ...GCSOptions) (*TierConfig, error)

+ func NewTierMinIO(name, endpoint, accessKey, secretKey, bucket string, options ...MinIOOptions) (*TierConfig, error)

+ func NewTierS3(name, accessKey, secretKey, bucket string, options ...S3Options) (*TierConfig, error)

+ func (cfg *TierConfig) Bucket() string

+ func (cfg *TierConfig) Clone() TierConfig

+ func (cfg *TierConfig) Endpoint() string

+ func (cfg *TierConfig) Prefix() string

+ func (cfg *TierConfig) Region() string

+ func (cfg *TierConfig) UnmarshalJSON(b []byte) error

+ func (z *TierConfig) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *TierConfig) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *TierConfig) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *TierConfig) Msgsize() (s int)

+ func (z *TierConfig) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type TierCreds struct

+ AWSRole bool

+ AccessKey string

+ CredsJSON []byte

+ SecretKey string

+ type TierGCS struct

+ Bucket string

+ Creds string

+ Endpoint string

+ Prefix string

+ Region string

+ StorageClass string

+ func (gcs *TierGCS) GetCredentialJSON() ([]byte, error)

+ func (z *TierGCS) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *TierGCS) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *TierGCS) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *TierGCS) Msgsize() (s int)

+ func (z *TierGCS) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type TierInfo struct

+ DailyStats DailyTierStats

+ Name string

+ Stats TierStats

+ Type string

+ type TierMinIO struct

+ AccessKey string

+ Bucket string

+ Endpoint string

+ Prefix string

+ Region string

+ SecretKey string

+ func (z *TierMinIO) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *TierMinIO) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *TierMinIO) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *TierMinIO) Msgsize() (s int)

+ func (z *TierMinIO) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type TierS3 struct

+ AWSRole bool

+ AccessKey string

+ Bucket string

+ Endpoint string

+ Prefix string

+ Region string

+ SecretKey string

+ StorageClass string

+ func (z *TierS3) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *TierS3) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *TierS3) MarshalMsg(b []byte) (o []byte, err error)

+ func (z *TierS3) Msgsize() (s int)

+ func (z *TierS3) UnmarshalMsg(bts []byte) (o []byte, err error)

+ type TierStats struct

+ NumObjects int

+ NumVersions int

+ TotalSize uint64

+ type TierType int

+ const Azure

+ const GCS

+ const MinIO

+ const S3

+ const Unsupported

+ func NewTierType(scType string) (TierType, error)

+ func (tt *TierType) UnmarshalJSON(data []byte) error

+ func (tt TierType) MarshalJSON() ([]byte, error)

+ func (tt TierType) String() string

+ func (z *TierType) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *TierType) UnmarshalMsg(bts []byte) (o []byte, err error)

+ func (z TierType) EncodeMsg(en *msgp.Writer) (err error)

+ func (z TierType) MarshalMsg(b []byte) (o []byte, err error)

+ func (z TierType) Msgsize() (s int)

+ type TimeDurations []time.Duration

+ func (ts TimeDurations) Len() int

+ func (ts TimeDurations) Measure() Timings

+ type TimeInfo struct

+ CurrentTime time.Time

+ RoundtripDuration int32

+ TimeZone string

+ type TimedAction struct

+ AccTime uint64

+ Bytes uint64

+ Count uint64

+ func (t *TimedAction) Merge(other TimedAction)

+ func (t TimedAction) Avg() time.Duration

+ func (t TimedAction) AvgBytes() uint64

+ type Timings struct

+ Avg time.Duration

+ Long5p time.Duration

+ Max time.Duration

+ Min time.Duration

+ P50 time.Duration

+ P75 time.Duration

+ P95 time.Duration

+ P99 time.Duration

+ P999 time.Duration

+ Range time.Duration

+ Short5p time.Duration

+ StdDev time.Duration

+ type TopLockOpts struct

+ Count int

+ Stale bool

+ type TraceCallStats struct

+ InputBytes int

+ Latency time.Duration

+ OutputBytes int

+ TimeToFirstByte time.Duration

+ type TraceHTTPStats struct

+ CallStats TraceCallStats

+ ReqInfo TraceRequestInfo

+ RespInfo TraceResponseInfo

+ type TraceInfo struct

+ Custom map[string]string

+ Duration time.Duration

+ Error string

+ FuncName string

+ HTTP *TraceHTTPStats

+ HealResult *HealResultItem

+ Message string

+ NodeName string

+ Path string

+ Time time.Time

+ TraceType TraceType

+ func (t TraceInfo) Mask() uint64

+ type TraceRequestInfo struct

+ Body []byte

+ Client string

+ Headers http.Header

+ Method string

+ Path string

+ Proto string

+ RawQuery string

+ Time time.Time

+ type TraceResponseInfo struct

+ Body []byte

+ Headers http.Header

+ StatusCode int

+ Time time.Time

+ type TraceType uint64

+ const TraceAll

+ const TraceBatchKeyRotation

+ const TraceBatchReplication

+ const TraceBootstrap

+ const TraceDecommission

+ const TraceFTP

+ const TraceHealing

+ const TraceILM

+ const TraceInternal

+ const TraceOS

+ const TraceRebalance

+ const TraceReplicationResync

+ const TraceS3

+ const TraceScanner

+ const TraceStorage

+ func (i TraceType) String() string

+ func (t *TraceType) Merge(other TraceType)

+ func (t *TraceType) SetIf(b bool, other TraceType)

+ func (t TraceType) Contains(other TraceType) bool

+ func (t TraceType) Mask() uint64

+ func (t TraceType) Overlaps(other TraceType) bool

+ func (t TraceType) SingleType() bool

+ type UpdateServiceAccountReq struct

+ NewDescription string

+ NewExpiration *time.Time

+ NewName string

+ NewPolicy json.RawMessage

+ NewSecretKey string

+ NewStatus string

+ func (u *UpdateServiceAccountReq) Validate() error

+ type Usage struct

+ Error string

+ Size uint64

+ type UserInfo struct

+ MemberOf []string

+ PolicyName string

+ SecretKey string

+ Status AccountStatus

+ UpdatedAt time.Time

+ type UserPolicyEntities struct

+ Policies []string

+ User string

+ type Versions struct

+ Count uint64

+ Error string

+ type XFSErrorConfig struct

+ ConfigFile string

+ MaxRetries int

+ type XFSErrorConfigs struct

+ Configs []XFSErrorConfig

+ Error string

Other modules containing this package

github.com/minio/madmin-go

github.com/minio/madmin-go/v2

github.com/minio/madmin-go/v4

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL