madmin

package module

Go to main page

Versions in this module

v1

v1.16.0

Jun 13, 2025

v1.15.0

Jun 10, 2025

Changes in this version

type AdminClient

+ func (adm *AdminClient) ScannerStatus(ctx context.Context) (interface{}, error)

v1.14.0

Jun 4, 2025

Changes in this version

+ const ScanActionStart

+ const ScanActionStop

type AdminClient

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

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

v1.13.0

Feb 21, 2025

Changes in this version

+ const BandwidthSubSys

type AdminClient

+ func (adm *AdminClient) GetPrometheusLimits(ctx context.Context) (limitNum int, err error)

v1.12.0

Feb 20, 2025

Changes in this version

type AdminClient

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

v1.11.0

Dec 25, 2024

v1.10.0

Dec 25, 2024

Changes in this version

type PeerInfo

+ SyncStateMap map[string]SyncInfo

type PeerSite

+ SyncStateMap map[string]SyncInfo

+ type SyncInfo struct

+ BandwidthLimit int64

+ SyncState SyncStatus

v1.9.0

Dec 19, 2024

Changes in this version

type PeerInfo

+ BandwidthLimit int64

type PeerSite

+ BandwidthLimit int64

v1.8.0

Oct 29, 2024

Changes in this version

type PeerSite

+ SyncState string

v1.7.0

Sep 4, 2024

Changes in this version

type AdminClient

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

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

+ func (adm *AdminClient) StartProfile(ctx context.Context, profiler ProfilerType) (StartProfileResponse, error)

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

+ type ListProfileResponse struct

+ IsStillRunning bool

+ LastTaskError string

+ ProfileFiles []ProfileFile

+ type ProfileFile struct

+ FileName string

+ type StartProfileResponse struct

+ Result string

v1.6.0

Sep 13, 2023

Changes in this version

type BktOp

+ const RecycleBucketBktOp

type MetricsClient

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

v1.5.0

Sep 11, 2023

Changes in this version

type BktOp

+ const RecycleBucketBktop

v1.4.0

Aug 30, 2023

Changes in this version

+ const BatchJobExpireTemplate

+ const BatchSubSys

+ const MaxClientPerfTimeout

+ const MinClientPerfTimeout

+ const SRIAMItemCredential

+ const TraceBatch

type AdminClient

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

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

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

type BackendInfo

+ RRSCParities []int

+ StandardSCParities []int

type BatchJobType

+ const BatchJobExpire

type BucketQuota

+ Rate uint64

+ Requests uint64

+ Size uint64

type BucketTarget

+ DeploymentID string

+ Latency LatencyStat

type BucketUsageInfo

+ DeleteMarkersCount uint64

+ type ClientPerfExtraTime struct

+ TimeSpent int64

+ type ClientPerfResult struct

+ BytesSend uint64

+ Endpoint string

+ Error string

+ TimeSpent int64

+ type DeleteMarkers struct

+ Count uint64

+ Error string

type DiskMetrics

+ TotalErrorsAvailability uint64

+ TotalErrorsTimeout uint64

type ErasureSetInfo

+ DeleteMarkersCount uint64

+ type ExpirationInfo struct

+ Bucket string

+ Object string

+ Objects int64

+ ObjectsFailed int64

+ type InQueueMetric struct

+ Avg QStat

+ Curr QStat

+ Max QStat

type InfoMessage

+ DeleteMarkers DeleteMarkers

type JobMetric

+ Expired *ExpirationInfo

type KMS

+ Endpoint string

+ Version string

+ 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 MetricType

+ const MetricNet

type Metrics

+ Net *NetMetrics

+ type MetricsClient struct

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

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

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

type MinioInfo

+ Metrics *RealtimeMetrics

+ type NetMetrics struct

+ CollectedAt time.Time

+ InterfaceName string

+ NetStats procfs.NetDevLine

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

type PoolDecommissionInfo

+ BytesDone int64

+ BytesFailed int64

+ ObjectsDecommissionFailed int64

+ ObjectsDecommissioned int64

+ 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 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)

+ type SRCredInfo struct

+ AccessKey string

+ IAMUserType int

+ IsDeleteReq bool

+ UserIdentityJSON json.RawMessage

type SRIAMItem

+ CredentialInfo *SRCredInfo

+ type SRMetric struct

+ DeploymentID string

+ Endpoint string

+ Failed TimedErrStats

+ LastOnline time.Time

+ Latency LatencyStat

+ MRFStats replication.ReplMRFStats

+ 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 SRSvcAccCreate

+ Description string

+ Name string

type SRSvcAccUpdate

+ Description string

+ Name string

type ServiceTraceOpts

+ BatchAll bool

+ BatchExpire bool

type Services

+ KMSStatus []KMS

+ type SiteNetPerfNodeResult struct

+ Endpoint string

+ Error string

+ RX uint64

+ RXTotalDuration time.Duration

+ TX uint64

+ TXTotalDuration time.Duration

+ TotalConn uint64

+ type SiteNetPerfResult struct

+ NodeResults []SiteNetPerfNodeResult

+ type TimedErrStats struct

+ ErrCounts map[string]int

+ 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 TraceType

+ const TraceBatchExpire

+ type UserAuthInfo struct

+ AuthServer string

+ AuthServerUserID string

+ Type UserAuthType

+ type UserAuthType string

+ const BuiltinUserAuthType

+ const LDAPUserAuthType

type UserInfo

+ AuthInfo *UserAuthInfo

+ type WorkerStat struct

+ Avg float32

+ Curr int

+ Max int

v1.3.0

Jun 7, 2023

Changes in this version

type AddServiceAccountReq

+ Description string

+ Name string

+ func (r *AddServiceAccountReq) Validate() error

type BucketTarget

+ LastOnline time.Time

+ Online bool

+ TotalDowntime time.Duration

type ErasureBackend

+ DrivesPerSet []int

+ TotalSets []int

+ type ErasurePoolEngine string

type HealOpts

+ UpdateParity bool

type InfoServiceAccountResp

+ Description 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

+ State KMSState

type OSSClusterInfo

+ Config map[string]string

type PoolInfo

+ ErasurePoolEngine ErasurePoolEngine

+ type ServiceAccountInfo struct

+ AccessKey string

+ Expiration *time.Time

type UpdateServiceAccountReq

+ NewDescription string

+ NewName string

+ func (u *UpdateServiceAccountReq) Validate() error

+ type XFSErrorConfig struct

+ ConfigFile string

+ MaxRetries int

+ type XFSErrorConfigs struct

+ Configs []XFSErrorConfig

+ Error string

v1.2.2

Apr 17, 2023

v1.2.1

Apr 13, 2023

v1.2.0

Apr 13, 2023

Changes in this version

+ const BatchJobKeyRotateTemplate

+ const LambdaWebhookSubSys

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

type AddOrUpdateUserReq

+ Policy string

type AddServiceAccountReq

+ Comment string

+ Expiration *time.Time

type AdminClient

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

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

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

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

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

type BatchJobType

+ const BatchJobKeyRotate

type BucketAccessInfo

+ ObjectVersionsHistogram map[string]uint64

type BucketUsageInfo

+ ObjectVersionsHistogram map[string]uint64

+ 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

+ CPUFreqStats []CPUFreqStats

type Disk

+ UsedInodes uint64

+ type ErasureSetInfo struct

+ HealDisks int

+ ID int

+ ObjectsCount uint64

+ RawCapacity uint64

+ RawUsage uint64

+ Usage uint64

+ VersionsCount uint64

type HealingDisk

+ HealID string

type InfoMessage

+ Pools map[int]map[int]ErasureSetInfo

type InfoServiceAccountResp

+ Comment string

+ Expiration *time.Time

type JobMetric

+ KeyRotate *KeyRotationInfo

+ type KeyRotationInfo struct

+ Bucket string

+ Object string

+ Objects int64

+ ObjectsFailed int64

type PeerInfo

+ SyncState SyncStatus

type SRSvcAccCreate

+ Comment string

+ Expiration *time.Time

type SRSvcAccUpdate

+ Comment string

+ Expiration *time.Time

type ServiceTraceOpts

+ BatchKeyRotation bool

+ FTP bool

+ ILM bool

type SpeedtestOpts

+ NoClear bool

+ type SyncStatus string

+ const SyncDisabled

+ const SyncEnabled

+ func (s SyncStatus) Empty() bool

type TraceInfo

+ Custom map[string]string

type TraceType

+ const TraceBatchKeyRotation

+ const TraceFTP

+ const TraceILM

type UpdateServiceAccountReq

+ NewComment string

+ NewExpiration *time.Time

v1.1.1

Apr 10, 2023

v1.1.0

Apr 4, 2023

Changes in this version

type AdminClient

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

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

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

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

+ func (adm *AdminClient) SetVacancy(ctx context.Context, config VacancyInfo) (err error)

+ type BucketInfoForVcs struct

+ Name string

+ ObjectsCount uint64

+ Size uint64

+ type OSSClusterInfo struct

+ Pools map[int]*PoolInfo

+ type PoolInfo struct

+ DrivesPerSet int

+ Index int

+ Parity int

+ Sets map[int]*SetInfo

+ Status string

+ TotalSpace uint64

+ UsedSpace uint64

+ type SetDiskInfo struct

+ AvailableSpace uint64

+ DiskIndex int

+ DrivePath string

+ Endpoint string

+ Healing bool

+ PoolIndex int

+ RootDisk bool

+ SetIndex int

+ State string

+ TotalSpace uint64

+ UUID string

+ UsedSpace uint64

+ type SetInfo struct

+ Index int

+ Member map[int]*SetDiskInfo

+ Status string

+ type VacancyInfo struct

+ CheckInterval int

+ Enabled bool

+ VacancyThreshold int

v1.0.5

Feb 27, 2023

Changes in this version

+ const APISubSys

+ const AdminAPIVersion

+ const AdminAPIVersionV2

+ const AuditKafkaSubSys

+ const AuditWebhookSubSys

+ 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 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 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

+ SecretKey string

+ Status AccountStatus

+ type AddServiceAccountReq struct

+ AccessKey string

+ Policy json.RawMessage

+ SecretKey string

+ TargetUser string

+ 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) AddUser(ctx context.Context, accessKey, secretKey string) error

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

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

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

+ func (adm *AdminClient) AttachPolicyUser(ctx context.Context, user string, policies []string) 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) 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) DetachPolicyGroup(ctx context.Context, user string, policies []string) error

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

+ func (adm *AdminClient) DetachPolicyUser(ctx context.Context, user string, policies []string) 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(ctx 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) 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 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

+ 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

+ Path string

+ Region string

+ ReplicationSync bool

+ ResetBeforeDate time.Time

+ ResetID string

+ Secure bool

+ SourceBucket string

+ StorageClass string

+ TargetBucket string

+ 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

+ 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 CPUs struct

+ CPUs []CPU

+ IsFreqGovPerf *bool

+ 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

+ 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

+ OfflineDisks int

+ OnlineDisks int

+ RRSCParity int

+ StandardSCParity int

+ Type backendType

+ 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

+ 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

+ 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 interface{}

+ Buckets Buckets

+ DeploymentID string

+ Domain []string

+ Mode string

+ Objects Objects

+ 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

+ ImpliedPolicy bool

+ 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

+ 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 KMSStatus struct

+ DefaultKeyID string

+ Endpoints map[string]ItemState

+ Name string

+ type KMSVersion struct

+ Version string

+ type KVOptions struct

+ Env bool

+ 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 []string

+ 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

+ Started time.Time

+ TotalBytes uint64

+ TotalItems 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

+ 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{}

+ Groups []string

+ Parent string

+ SecretKey string

+ SessionPolicy json.RawMessage

+ Status string

+ type SRSvcAccDelete struct

+ AccessKey string

+ type SRSvcAccUpdate struct

+ AccessKey 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 ServiceAction string

+ type ServiceTraceInfo struct

+ Err error

+ Trace TraceInfo

+ type ServiceTraceOpts struct

+ BatchReplication bool

+ Bootstrap bool

+ Decommission bool

+ Healing 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

+ 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 SysConfig struct

+ Config map[string]interface{}

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

+ type SysErrors struct

+ Errors []string

+ func GetSysErrors(ctx 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(ctx 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

+ 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 TraceBatchReplication

+ const TraceBootstrap

+ const TraceDecommission

+ const TraceHealing

+ 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

+ NewPolicy json.RawMessage

+ NewSecretKey string

+ NewStatus string

+ 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

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