madmin

Nov 14, 2022

Changes in this version

type LockEntry

+ Elapsed time.Duration

Nov 4, 2022

Changes in this version

type AdminClient

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

+ type GroupPolicyEntities struct

+ Group string

+ Policies []string

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

+ Policies []string

+ User string

Nov 2, 2022

Changes in this version

type AdminClient

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

type TimeInfo

+ TimeZone string

Oct 27, 2022

Changes in this version

+ const SiteReplAPIVersion

Oct 25, 2022

Changes in this version

type InspectOptions

+ PublicKey []byte

Oct 16, 2022

Changes in this version

+ const LDAPIDPCfg

+ const OpenidIDPCfg

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

type AdminClient

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

type MetricType

+ const MetricsSiteResync

type Metrics

+ SiteResync *SiteResyncMetrics

type MetricsOptions

+ ByDepID string

+ type ResyncBucketStatus struct

+ Bucket string

+ ErrDetail string

+ Status string

+ type SRResyncOpStatus struct

+ Buckets []ResyncBucketStatus

+ ErrDetail string

+ OpType string

+ ResyncID string

+ Status string

type ServiceTraceOpts

+ ReplicationResync bool

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

+ const TraceReplicationResync

Oct 12, 2022

Changes in this version

type GenerateBatchJobOpts

+ Type BatchJobType

Oct 11, 2022

Changes in this version

+ var SupportedJobTypes = []BatchJobType

type AdminClient

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

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

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

+ type KMSAPI struct

+ MaxBody int64

+ Method string

+ Path string

+ Timeout int64

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

+ Version string

Oct 10, 2022

Changes in this version

type ServerInfo

+ GoMaxProcs int

type ServerProperties

+ GCStats *GCStats

+ GoMaxProcs int

+ MinioEnvVars map[string]string

+ NumCPU int

+ RuntimeVersion string

Oct 6, 2022

Changes in this version

type AdminClient

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

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

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

+ 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 uuid.UUID

+ Pools []RebalancePoolStatus

+ StoppedAt time.Time

type ServiceTraceOpts

+ Rebalance bool

type TraceType

+ const TraceRebalance

Sep 29, 2022

Changes in this version

type AdminClient

+ func (adm *AdminClient) AssignPolicy(ctx context.Context, policy string, content []byte) 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) 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) GetPolicy(ctx context.Context, policy string) (*KMSPolicy, error)

+ func (adm *AdminClient) ImportKey(ctx context.Context, keyID string, content []byte) 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) SetKMSPolicy(ctx context.Context, policy string, content []byte) error

+ type BatchJobMetrics struct

+ CollectedAt time.Time

+ Jobs map[string]JobMetric

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

+ type JobMetric struct

+ Complete bool

+ Failed bool

+ JobID string

+ JobType string

+ LastUpdate time.Time

+ Replicate *ReplicateInfo

+ RetryAttempts int

+ StartTime time.Time

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

+ Allow []string

+ Deny []string

+ type KMSPolicyInfo struct

+ CreatedAt string

+ CreatedBy string

+ Name string

type MetricType

+ const MetricsBatchJobs

type Metrics

+ BatchJobs *BatchJobMetrics

type MetricsOptions

+ ByJobID string

+ type ReplicateInfo struct

+ Bucket string

+ BytesFailed int64

+ BytesTransferred int64

+ Object string

+ Objects int64

+ ObjectsFailed int64

Sep 28, 2022

Changes in this version

+ const BatchJobReplicateTemplate

type AdminClient

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

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

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

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

+ func (adm *AdminClient) StatusBatchJob(ctx context.Context, jobID string, out func(MetricsBatchJob)) error

+ type BatchJobResult struct

+ Elapsed time.Duration

+ ID string

+ Started time.Time

+ Type BatchJobType

+ User string

+ type BatchJobType string

+ const BatchJobReplicate

+ type GenerateBatchJobOpts struct

+ type ListBatchJobsFilter struct

+ ByJobType string

+ type ListBatchJobsResult struct

+ Jobs []BatchJobResult

+ type MetricsBatchJob struct

+ Final bool

+ Replicate struct{ ... }

+ Type BatchJobType

type ServiceTraceOpts

+ BatchReplication bool

type TraceType

+ const TraceBatchReplication

Sep 15, 2022

Changes in this version

type InfoMessage

+ func (info InfoMessage) BackendType() BackendType

+ func (info InfoMessage) StandardParity() int

Aug 30, 2022

Changes in this version

type ServiceTraceOpts

+ Healing bool

type TraceInfo

+ HealResult *HealResultItem

type TraceType

+ const TraceHealing

Aug 19, 2022

Changes in this version

type SRPolicyMapping

+ UserType int

Aug 17, 2022

Changes in this version

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

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

type AliveResult

+ DNSResolveTime time.Duration

+ type ConfigKV struct

+ EnvOverride *EnvOverride

+ Key string

+ Value string

+ type EnvOverride struct

+ Name string

+ Value string

+ type SubsysConfig struct

+ KV []ConfigKV

+ SubSystem string

+ Target string

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

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

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

Aug 16, 2022

Changes in this version

type ServerProperties

+ Scheme string

Aug 15, 2022

Changes in this version

type AnonymousClient

+ func NewAnonymousClientNoEndpoint() (*AnonymousClient, error)

Aug 13, 2022

Changes in this version

+ const APISubSys

+ const AuditKafkaSubSys

+ const AuditWebhookSubSys

+ const CacheSubSys

+ const CallhomeSubSys

+ const CompressionSubSys

+ const CrawlerSubSys

+ const CredentialsSubSys

+ const EnvLinePrefix

+ const EnvPrefix

+ const EnvWordDelimiter

+ const EtcdSubSys

+ const HealSubSys

+ const IdentityLDAPSubSys

+ const IdentityOpenIDSubSys

+ const IdentityPluginSubSys

+ const IdentityTLSSubSys

+ const LoggerWebhookSubSys

+ const NotifyAMQPSubSys

+ const NotifyESSubSys

+ const NotifyKafkaSubSys

+ const NotifyMQTTSubSys

+ const NotifyMySQLSubSys

+ const NotifyNATSSubSys

+ const NotifyNSQSubSys

+ const NotifyPostgresSubSys

+ const NotifyRedisSubSys

+ const NotifyWebhookSubSys

+ const PolicyOPASubSys

+ const PolicyPluginSubSys

+ const RegionSubSys

+ const ScannerSubSys

+ const SiteSubSys

+ const StorageClassSubSys

+ const SubnetSubSys

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

Aug 10, 2022

Changes in this version

type Disk

+ Major uint32

+ Minor uint32

+ Scanning bool

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

+ IOStats DiskIOStats

type MetricsOptions

+ ByDisk bool

+ Disks []string

type RealtimeMetrics

+ ByDisk map[string]DiskMetric

Aug 9, 2022

Changes in this version

type TraceInfo

+ Error string

Aug 9, 2022

Changes in this version

type ServiceTraceOpts

+ Decommission bool

type TraceType

+ const TraceDecommission

Aug 5, 2022

Changes in this version

type SpeedTestStats

+ Response Timings

+ TTFB Timings

+ type TimeDurations []time.Duration

+ func (ts TimeDurations) Len() int

+ func (ts TimeDurations) Measure() Timings

+ 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

Aug 5, 2022

Changes in this version

+ type BucketMetaImportErrs struct

+ Buckets map[string]BucketStatus

+ type BucketStatus struct

+ Err string

+ Lifecycle MetaStatus

+ Notification MetaStatus

+ ObjectLock MetaStatus

+ Policy MetaStatus

+ Quota MetaStatus

+ SSEConfig MetaStatus

+ Tagging MetaStatus

+ Versioning MetaStatus

+ type MetaStatus struct

+ Err string

+ IsSet bool

Jul 27, 2022

Changes in this version

type MemInfo

+ Limit uint64

Jul 27, 2022

Changes in this version

type BackendInfo

+ DrivesPerSet []int

+ TotalSets []int

Jul 22, 2022

Changes in this version

+ func IsEncrypted(data []byte) bool

Jul 21, 2022

Changes in this version

type BktOp

+ const PurgeDeletedBucketOp

type SRBucketInfo

+ DeletedAt time.Time

type SRBucketStatsSummary

+ BucketMarkedDeleted bool

type SRStatusOptions

+ ShowDeleted bool

Jul 13, 2022

Changes in this version

type SpeedtestOpts

+ Bucket string

Jul 8, 2022

Changes in this version

+ type AliveOpts struct

+ Readiness bool

+ type AliveResult struct

+ Endpoint *url.URL

+ Error error

+ Online bool

+ ResponseTime time.Duration

type AnonymousClient

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

Jun 30, 2022

Changes in this version

type AdminClient

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

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

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

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

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

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

+ ARN string

+ Prefix string

+ Verbose bool

+ type TgtDiffInfo struct

+ DeleteReplicationStatus string

+ ReplicationStatus string

Jun 30, 2022

Changes in this version

type AdminClient

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

+ type DiskMetric struct

+ CollectedAt time.Time

+ Healing int

+ LastMinute struct{ ... }

+ LifeTimeOps map[string]uint64

+ NDisks int

+ Offline int

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

type DiskMetrics

+ LastMinute map[string]TimedAction

type LogInfo

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

+ const MetricsAll

+ const MetricsDisk

+ const MetricsNone

+ const MetricsOS

+ const MetricsScanner

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

+ type Metrics struct

+ Disk *DiskMetric

+ OS *OSMetrics

+ Scanner *ScannerMetrics

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

+ type MetricsOptions struct

+ ByHost bool

+ Hosts []string

+ Interval time.Duration

+ N int

+ Type MetricType

+ type OSMetrics struct

+ CollectedAt time.Time

+ LastMinute struct{ ... }

+ LifeTimeOps map[string]uint64

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

+ type RealtimeMetrics struct

+ Aggregated Metrics

+ ByHost map[string]Metrics

+ Errors []string

+ Final bool

+ Hosts []string

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

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

+ Scanner bool

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

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

+ func (t ServiceTraceOpts) TraceTypes() TraceType

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

+ CallStats TraceCallStats

+ ReqInfo TraceRequestInfo

+ RespInfo TraceResponseInfo

type TraceInfo

+ Duration time.Duration

+ HTTP *TraceHTTPStats

+ Message string

+ Path string

+ func (t TraceInfo) Mask() uint64

type TraceType

+ const TraceAll

+ const TraceInternal

+ const TraceS3

+ const TraceScanner

+ 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

Jun 27, 2022

Changes in this version

+ type AnonymousClient struct

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

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

+ ClusterRead bool

+ Maintenance bool

+ type HealthResult struct

+ HealingDrives int

+ Healthy bool

+ MaintenanceMode bool

+ WriteQuorum int

type SRBucketMeta

+ UpdatedAt time.Time

type SRIAMItem

+ UpdatedAt time.Time

Jun 14, 2022

Changes in this version

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

+ Password string

+ Username string

+ type SubnetMFAReq struct

+ OTP string

+ Token string

+ Username string

Jun 8, 2022

Changes in this version

type BucketUsageInfo

+ VersionsCount uint64

Jun 7, 2022

Changes in this version

type AdminClient

+ 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) ImportBucketMetadata(ctx context.Context, bucket string, contentReader io.ReadCloser) error

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

Jun 1, 2022

Changes in this version

type AdminClient

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

+ type KVOptions struct

+ Env bool

May 7, 2022

Changes in this version

+ const SRBucketMetaTypeVersionConfig

type SRBucketInfo

+ Versioning *string

+ VersioningConfigUpdatedAt time.Time

type SRBucketMeta

+ Versioning *string

type SRBucketStatsSummary

+ VersioningConfigMismatch bool

type SRSiteSummary

+ ReplicatedVersioningConfig int

+ TotalVersioningConfigCount int

May 4, 2022

Changes in this version

+ type KubernetesInfo struct

+ BuildDate time.Time

+ Error string

+ GitCommit string

+ GitVersion string

+ Major string

+ Minor string

+ Platform string

type SysInfo

+ KubernetesInfo KubernetesInfo

Apr 20, 2022

Changes in this version

type AdminClient

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

type GroupDesc

+ UpdatedAt time.Time

type InfoMessage

+ Versions Versions

type SRBucketInfo

+ CreatedAt time.Time

+ Location string

+ ObjectLockConfigUpdatedAt time.Time

+ PolicyUpdatedAt time.Time

+ QuotaConfigUpdatedAt time.Time

+ ReplicationConfigUpdatedAt time.Time

+ SSEConfigUpdatedAt time.Time

+ TagConfigUpdatedAt time.Time

+ type SRIAMPolicy struct

+ Policy json.RawMessage

+ UpdatedAt time.Time

type SRPolicyMapping

+ CreatedAt time.Time

+ UpdatedAt time.Time

type UserInfo

+ UpdatedAt time.Time

+ type Versions struct

+ Count uint64

+ Error string

Apr 8, 2022

Changes in this version

type SpeedTestResults

+ Error string

Mar 31, 2022

Changes in this version

+ const HealthInfoVersion3

type HealthDataType

+ const HealthDataTypePerfObj

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

+ DrivePerf []DriveSpeedTestResult

+ NetPerf []NetperfNodeResult

+ ObjPerf []SpeedTestResult

Mar 22, 2022

Changes in this version

+ type GCStats struct

+ LastGC time.Time

+ NumGC int64

+ Pause []time.Duration

+ PauseEnd []time.Time

+ PauseTotal time.Duration

type ServerInfo

+ GCStats GCStats

+ GOMAXPROCS int

+ MinioEnvVars map[string]string

+ NumCPU int

+ RuntimeVersion string

Mar 11, 2022

Changes in this version

+ const TierConfigVer

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

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

+ type MinIOOptions func(*TierMinIO) error

type TierConfig

+ MinIO *TierMinIO

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

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

+ const MinIO

Feb 24, 2022

Changes in this version

type AdminClient

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

+ type NetperfNodeResult struct

+ Endpoint string

+ Error string

+ RX uint64

+ TX uint64

+ type NetperfResult struct

+ NodeResults []NetperfNodeResult

Feb 23, 2022

Changes in this version

type AdminClient

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

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

Feb 17, 2022

Changes in this version

type ProfilerType

+ const ProfilerCPUIO

Feb 3, 2022

Changes in this version

type CPUs

+ IsFreqGovPerf *bool

Jan 28, 2022

Changes in this version

+ const ReplicateRemoveStatusPartial

+ const ReplicateRemoveStatusSuccess

type AdminClient

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

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

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

+ type DrivePerf struct

+ Error string

+ Path string

+ ReadThroughput uint64

+ WriteThroughput uint64

+ type DriveSpeedTestOpts struct

+ BlockSize uint64

+ FileSize uint64

+ Serial bool

+ type DriveSpeedTestResult struct

+ DrivePerf []DrivePerf

+ Endpoint string

+ Error string

+ Version string

+ type ReplicateRemoveStatus struct

+ ErrDetail string

+ Status string

type SRBucketInfo

+ QuotaConfig *string

type SRBucketStatsSummary

+ HasOLockConfigSet bool

+ HasPolicySet bool

+ HasQuotaCfgSet bool

+ HasSSECfgSet bool

+ HasTagsSet bool

+ QuotaCfgMismatch bool

+ type SREntityType int

+ const SRBucketEntity

+ const SRGroupEntity

+ const SRPolicyEntity

+ const SRUserEntity

+ const Unspecified

+ func GetSREntityType(name string) SREntityType

type SRGroupStatsSummary

+ GroupDescMismatch bool

+ HasGroup bool

+ HasPolicyMapping bool

type SRInfo

+ GroupDescMap map[string]GroupDesc

+ UserInfoMap map[string]UserInfo

type SRPolicyStatsSummary

+ HasPolicy bool

+ type SRRemoveReq struct

+ RemoveAll bool

+ SiteNames []string

type SRSiteSummary

+ ReplicatedGroupPolicyMappings int

+ ReplicatedQuotaConfig int

+ ReplicatedUserPolicyMappings int

+ TotalGroupPolicyMappingCount int

+ TotalQuotaConfigCount int

+ TotalUserPolicyMappingCount int

type SRStatusInfo

+ BucketStats map[string]map[string]SRBucketStatsSummary

+ GroupStats map[string]map[string]SRGroupStatsSummary

+ PolicyStats map[string]map[string]SRPolicyStatsSummary

+ UserStats map[string]map[string]SRUserStatsSummary

+ type SRStatusOptions struct

+ Buckets bool

+ Entity SREntityType

+ EntityValue string

+ Groups bool

+ Policies bool

+ Users bool

+ func (o *SRStatusOptions) IsEntitySet() bool

type SRUserStatsSummary

+ HasPolicyMapping bool

+ HasUser bool

+ UserInfoMismatch bool

Jan 25, 2022

Changes in this version

+ type DailyTierStats struct

+ Bins [24]TierStats

+ UpdatedAt time.Time

type TierInfo

+ DailyStats DailyTierStats

Jan 20, 2022

Changes in this version

type AdminClient

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

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

+ type ReplicateEditStatus struct

+ ErrDetail string

+ Status string

+ Success bool

Jan 19, 2022

Changes in this version

+ const SRBucketMetaTypeQuotaConfig

type SRBucketMeta

+ Quota json.RawMessage

Jan 18, 2022

Changes in this version

type GroupAddRemove

+ Status GroupStatus

Jan 6, 2022

Changes in this version

+ const SRIAMItemGroupInfo

+ const SRIAMItemIAMUser

type IDPSettings

+ LDAP LDAPSettings

+ OpenID OpenIDSettings

+ type LDAPSettings struct

+ IsLDAPEnabled bool

+ LDAPGroupSearchBase string

+ LDAPGroupSearchFilter string

+ LDAPUserDNSearchBase string

+ LDAPUserDNSearchFilter 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 SRGroupInfo struct

+ UpdateReq GroupAddRemove

type SRIAMItem

+ GroupInfo *SRGroupInfo

+ IAMUser *SRIAMUser

+ type SRIAMUser struct

+ AccessKey string

+ IsDeleteReq bool

+ UserReq *AddOrUpdateUserReq

type SRSTSCredential

+ ParentPolicyMapping string

+ ParentUser string

type SpeedtestOpts

+ StorageClass string

Jan 5, 2022

Changes in this version

type TimeInfo

+ RoundtripDuration int32

Dec 30, 2021

Changes in this version

+ type TimeInfo struct

+ CurrentTime time.Time

+ func GetTimeInfo(ctx context.Context, addr string) TimeInfo

Dec 29, 2021

Changes in this version

type PoolDecommissionInfo

+ Canceled bool

Dec 23, 2021

Changes in this version

type AdminClient

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

+ func (adm *AdminClient) SRPeerBucketOps(ctx context.Context, bucket string, op BktOp, opts map[string]string) 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) SRPeerReplicateBucketMeta(ctx context.Context, item SRBucketMeta) error

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

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

+ type SRBucketInfo struct

+ Bucket string

+ ObjectLockConfig *string

+ Policy json.RawMessage

+ ReplicationConfig *string

+ SSEConfig *string

+ Tags *string

+ type SRBucketStatsSummary struct

+ DeploymentID string

+ HasBucket bool

+ HasReplicationCfg bool

+ OLockConfigMismatch bool

+ PolicyMismatch bool

+ ReplicationCfgMismatch bool

+ SSEConfigMismatch bool

+ TagMismatch bool

+ type SRGroupStatsSummary struct

+ DeploymentID string

+ GroupMissing bool

+ PolicyMismatch bool

+ type SRInfo struct

+ Buckets map[string]SRBucketInfo

+ DeploymentID string

+ Enabled bool

+ GroupPolicies map[string]SRPolicyMapping

+ Name string

+ Policies map[string]json.RawMessage

+ ReplicationCfg map[string]replication.Config

+ UserPolicies map[string]SRPolicyMapping

+ type SRPeerJoinReq struct

+ Peers map[string]PeerInfo

+ SvcAcctAccessKey string

+ SvcAcctParent string

+ SvcAcctSecretKey string

+ type SRPolicyStatsSummary struct

+ DeploymentID string

+ PolicyMismatch bool

+ PolicyMissing bool

+ type SRSiteSummary struct

+ ReplicatedBucketPolicies int

+ ReplicatedBuckets int

+ ReplicatedGroups int

+ ReplicatedIAMPolicies int

+ ReplicatedLockConfig int

+ ReplicatedSSEConfig int

+ ReplicatedTags int

+ ReplicatedUsers int

+ TotalBucketPoliciesCount int

+ TotalBucketsCount int

+ TotalGroupsCount int

+ TotalIAMPoliciesCount int

+ TotalLockConfigCount int

+ TotalSSEConfigCount int

+ TotalTagsCount int

+ TotalUsersCount int

+ type SRStatusInfo struct

+ BucketMismatches map[string]map[string]SRBucketStatsSummary

+ Enabled bool

+ GroupMismatches map[string]map[string]SRGroupStatsSummary

+ MaxBuckets int

+ MaxGroups int

+ MaxPolicies int

+ MaxUsers int

+ PolicyMismatches map[string]map[string]SRPolicyStatsSummary

+ Sites map[string]PeerInfo

+ StatsSummary map[string]SRSiteSummary

+ UserMismatches map[string]map[string]SRUserStatsSummary

+ type SRUserStatsSummary struct

+ DeploymentID string

+ PolicyMismatch bool

+ UserMissing bool

Dec 22, 2021

Changes in this version

+ type AddOrUpdateUserReq struct

+ SecretKey string

+ Status AccountStatus

Dec 22, 2021

Changes in this version

type AdminClient

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

+ type RequestData struct

+ Content []byte

+ CustomHeaders http.Header

+ QueryValues url.Values

+ RelPath string

Dec 16, 2021

Changes in this version

type MinioInfo

+ IsDocker *bool

+ IsKubernetes *bool

Dec 2, 2021

Changes in this version

type AdminClient

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

+ type PolicyInfo struct

+ CreateDate time.Time

+ Policy json.RawMessage

+ PolicyName string

+ UpdateDate time.Time

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

Nov 19, 2021

Changes in this version

+ const ServiceActionFreeze

+ const ServiceActionUnfreeze

type AdminClient

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

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

Nov 12, 2021

Changes in this version

type TLSInfo

+ TLSInfoAvailable bool

Nov 9, 2021

Changes in this version

type PoolDecommissionInfo

+ TotalSize int64

Nov 2, 2021

Changes in this version

type SpeedTestResult

+ Concurrent int

+ Size int

Oct 19, 2021

Changes in this version

type MinioInfo

+ TLS TLSInfo

+ type TLSCert struct

+ NotAfter time.Time

+ NotBefore time.Time

+ PubKeyAlgo string

+ SignatureAlgo string

+ type TLSInfo struct

+ Certs []TLSCert

+ TLSEnabled bool

Oct 18, 2021

Changes in this version

type AdminClient

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

+ type TierInfo struct

+ Name string

+ Stats TierStats

+ Type string

type TierStats

+ NumObjects int

Oct 12, 2021

Changes in this version

type DataUsageInfo

+ TierStats map[string]TierStats

type InfoMessage

+ TierStats map[string]TierStats

+ type TierStats struct

+ NumVersions int

+ TotalSize uint64

Oct 6, 2021

Changes in this version

+ const ReplicateAddStatusPartial

+ const ReplicateAddStatusSuccess

+ const SRBucketMetaTypeObjectLockConfig

+ const SRBucketMetaTypePolicy

+ const SRBucketMetaTypeSSEConfig

+ const SRBucketMetaTypeTags

+ const SRIAMItemPolicy

+ const SRIAMItemPolicyMapping

+ const SRIAMItemSTSAcc

+ const SRIAMItemSvcAcc

+ var HealthDataTypesHeavy = []HealthDataType

+ var HealthDataTypesLite = []HealthDataType

type AdminClient

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

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

+ func (adm *AdminClient) SRInternalJoin(ctx context.Context, r SRInternalJoinReq) error

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

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

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

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

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

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

+ type BktOp string

+ const ConfigureReplBktOp

+ const DeleteBucketBktOp

+ const ForceDeleteBucketBktOp

+ const MakeWithVersioningBktOp

+ type IDPSettings struct

+ IsLDAPEnabled bool

+ LDAPGroupSearchBase string

+ LDAPGroupSearchFilter string

+ LDAPUserDNSearchBase string

+ LDAPUserDNSearchFilter string

+ type PeerInfo struct

+ DeploymentID string

+ Endpoint string

+ Name string

+ type PeerSite struct

+ AccessKey string

+ Endpoint string

+ Name string

+ SecretKey string

+ type ReplicateAddStatus struct

+ ErrDetail string

+ InitialSyncErrorMessage string

+ Status string

+ Success bool

+ type SRBucketMeta struct

+ Bucket string

+ ObjectLockConfig *string

+ Policy json.RawMessage

+ SSEConfig *string

+ Tags *string

+ Type string

+ type SRIAMItem struct

+ Name string

+ Policy json.RawMessage

+ PolicyMapping *SRPolicyMapping

+ STSCredential *SRSTSCredential

+ SvcAccChange *SRSvcAccChange

+ Type string

+ type SRInternalJoinReq struct

+ Peers map[string]PeerInfo

+ SvcAcctAccessKey string

+ SvcAcctParent string

+ SvcAcctSecretKey string

+ type SRPolicyMapping struct

+ IsGroup bool

+ Policy string

+ UserOrGroup string

+ type SRSTSCredential struct

+ AccessKey string

+ SecretKey string

+ SessionToken string

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

+ Enabled bool

+ Name string

+ ServiceAccountAccessKey string

+ Sites []PeerInfo

Sep 22, 2021

Changes in this version

+ type AccountOpts struct

+ PrefixUsage bool

type BucketAccessInfo

+ Details *BucketDetails

+ ObjectSizesHistogram map[string]uint64

+ Objects uint64

+ type BucketDetails struct

+ Locking bool

+ Quota *BucketQuota

+ Replication bool

+ Tagging *tags.Tags

+ Versioning bool

+ VersioningSuspended bool

Sep 7, 2021

Changes in this version

type AdminClient

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

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

+ type PoolDecommissionInfo struct

+ Complete bool

+ CurrentSize int64

+ Duration int64

+ Failed bool

+ StartSize int64

+ StartTime time.Time

type PoolStatus

+ Decommission *PoolDecommissionInfo

Aug 31, 2021

Changes in this version

+ type BucketTargetUsageInfo struct

+ ReplicaSize uint64

+ ReplicatedSize uint64

+ ReplicationFailedCount uint64

+ ReplicationFailedSize uint64

+ ReplicationPendingCount uint64

+ ReplicationPendingSize uint64

type BucketUsageInfo

+ ReplicationInfo map[string]BucketTargetUsageInfo

type DataUsageInfo

+ ReplicationInfo map[string]BucketTargetUsageInfo

Aug 27, 2021

Changes in this version

type BgHealState

+ OfflineEndpoints []string

+ type SpeedTestResult struct

+ Disks int

+ GETStats SpeedTestStats

+ PUTStats SpeedTestStats

+ Servers int

+ Version string

+ type SpeedTestStatServer struct

+ Endpoint string

+ Err string

+ ObjectsPerSec uint64

+ ThroughputPerSec uint64

+ type SpeedTestStats struct

+ ObjectsPerSec uint64

+ Servers []SpeedTestStatServer

+ ThroughputPerSec uint64

type SpeedtestOpts

+ Autotune bool

Aug 24, 2021

Changes in this version

+ const SrvNotInstalled

+ const SrvSELinux

type AdminClient

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

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

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

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

type BgHealState

+ SCParity map[string]int

type HealthDataType

+ const HealthDataTypeSysConfig

+ const HealthDataTypeSysServices

type NodeCommon

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

type NodeInfo

+ SetError func(err string)

+ type PoolDecomissionInfo struct

+ Complete bool

+ CurrentSize int64

+ Duration int64

+ Failed bool

+ StartSize int64

+ StartTime time.Time

+ type PoolStatus struct

+ CmdLine string

+ Decomission *PoolDecomissionInfo

+ ID int

+ LastUpdate time.Time

+ type SysConfig struct

+ Config map[string]interface{}

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

type SysInfo

+ SysConfig []SysConfig

+ SysServices []SysServices

+ type SysService struct

+ Name string

+ Status string

+ type SysServices struct

+ Services []SysService

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

Jul 27, 2021

Changes in this version

type AdminClient

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

+ func (adm *AdminClient) Speedtest(ctx context.Context, opts SpeedtestOpts) ([]SpeedtestResult, error)

+ type InspectOptions struct

+ File string

+ Volume string

+ type SpeedtestOpts struct

+ Concurrency int

+ Duration time.Duration

+ Size int

+ type SpeedtestResult struct

+ Downloads uint64

+ Endpoint string

+ Err error

+ Uploads uint64

Jul 21, 2021

Changes in this version

+ const SysErrAuditEnabled

+ const SysErrUpdatedbInstalled

type HealthDataType

+ const HealthDataTypeSysErrors

type Pool

+ CmdLine string

+ DrivesPerSet int

+ Info PoolInfo

+ SetCount int

+ type PoolDrainInfo struct

+ StartTime time.Time

+ TotalObjects int64

+ TotalSize int64

+ type PoolInfo struct

+ Drain *PoolDrainInfo

+ ID int

+ LastUpdate time.Time

+ Suspend bool

+ type SysErrors struct

+ Errors []string

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

type SysInfo

+ SysErrs []SysErrors

Jul 16, 2021

Changes in this version

type AccountInfo

+ Server BackendInfo

Jul 13, 2021

Changes in this version

type BucketAccessInfo

+ PrefixUsage map[string]uint64

Jul 8, 2021

Changes in this version

type BgHealState

+ MRF map[string]MRFStatus

type HealingDisk

+ ItemsFailed uint64

+ ItemsHealed uint64

+ ObjectsTotalCount uint64

+ ObjectsTotalSize uint64

+ type MRFStatus struct

+ BytesHealed uint64

+ ItemsHealed uint64

+ Started time.Time

+ TotalBytes uint64

+ TotalItems uint64

type SetStatus

+ TotalObjects int

Jul 6, 2021

Changes in this version

+ type NodeCommon struct

+ Addr string

+ Error string

+ func (n *NodeCommon) GetAddr() string

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

+ type NodeInfo interface

+ GetAddr func() string

+ SetAddr func(addr string)

Jun 10, 2021

Changes in this version

type AdminClient

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

+ type Pool struct

+ Local string

+ Number int

+ Remote []string

+ type Pools map[string]Pool

Jun 2, 2021

Changes in this version

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

type TierCreds

+ AWSRole bool

type TierS3

+ AWSRole bool

May 27, 2021

Changes in this version

type BucketTarget

+ ResetBeforeDate time.Time

+ ResetID string

type ServerInfo

+ Drives []Disk

type TargetUpdateType

+ const ResetUpdateType

May 21, 2021

Changes in this version

+ type MemStats struct

+ Alloc uint64

+ Frees uint64

+ HeapAlloc uint64

+ Mallocs uint64

+ TotalAlloc uint64

+ type MinioInfo struct

+ Backend interface{}

+ Buckets Buckets

+ DeploymentID string

+ Domain []string

+ Mode string

+ Objects Objects

+ Region string

+ SQSARN []string

+ Servers []ServerInfo

+ Services Services

+ Usage Usage

+ type ServerInfo struct

+ CommitID string

+ Disks []Disk

+ Endpoint string

+ MemStats MemStats

+ Network map[string]string

+ PoolNumber int

+ State string

+ Uptime int64

+ Version string

May 12, 2021

Changes in this version

+ const HealthInfoVersion2

type HealthInfo

+ func (info HealthInfo) GetError() string

+ func (info HealthInfo) GetStatus() string

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

+ type HealthInfoVersionStruct struct

+ Error string

+ Version string

type SysProcess

+ func (sp SysProcess) GetOwner() string

May 10, 2021

Changes in this version

+ const HealthInfoVersion

+ const HealthInfoVersion0

+ const HealthInfoVersion1

type AdminClient

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

+ 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

+ Addr string

+ CPUs []CPU

+ Error string

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

+ type DrivePerfInfoV0 struct

+ Error string

+ Latency disk.Latency

+ Path string

+ Throughput disk.Throughput

+ type DrivePerfInfos struct

+ Addr string

+ Error string

+ ParallelPerf []DrivePerfInfo

+ SerialPerf []DrivePerfInfo

type HealthDataType

+ const HealthDataTypeSysDriveHw

type HealthInfo

+ Version string

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

+ DefaultKeyID string

+ Endpoints map[string]ItemState

+ Name string

+ type Latency struct

+ Avg float64

+ Max float64

+ Min float64

+ Percentile50 float64

+ Percentile90 float64

+ Percentile99 float64

+ type MemInfo struct

+ Addr string

+ Available uint64

+ Error string

+ SwapSpaceFree uint64

+ SwapSpaceTotal uint64

+ Total uint64

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

+ type MinioConfig struct

+ Config interface{}

+ Error string

+ type MinioHealthInfoV0 struct

+ Config interface{}

+ Error string

+ Info InfoMessage

type NetPerfInfo

+ RemotePeers []PeerNetPerfInfo

+ type NetPerfInfoV0 struct

+ Addr string

+ Error string

+ Latency net.Latency

+ Throughput net.Throughput

+ type OSInfo struct

+ Addr string

+ Error string

+ Info host.InfoStat

+ Sensors []host.TemperatureStat

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

+ type Partition struct

+ Device string

+ Error string

+ FSType string

+ InodeFree uint64

+ InodeTotal uint64

+ MountFSType string

+ MountOptions string

+ Mountpoint string

+ SpaceFree uint64

+ SpaceTotal uint64

+ type Partitions struct

+ Addr string

+ Error string

+ Partitions []Partition

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

+ type PeerNetPerfInfo struct

+ Addr string

+ Error string

+ Latency Latency

+ Throughput Throughput

type PerfInfo

+ Drives []DrivePerfInfos

+ type PerfInfoV0 struct

+ DriveInfo []ServerDrivesInfo

+ Error string

+ Net []ServerNetHealthInfo

+ NetParallel ServerNetHealthInfo

+ type ProcInfo struct

+ Addr string

+ CPUPercent float64

+ CWD string

+ ChildrenPIDs []int32

+ CmdLine string

+ CreateTime int64

+ Error string

+ ExecPath string

+ GIDs []int32

+ IOCounters process.IOCountersStat

+ IsBackground bool

+ IsRunning bool

+ MemInfo process.MemoryInfoStat

+ MemMaps []process.MemoryMapsStat

+ MemPercent float32

+ Name string

+ NetIOCounters []net.IOCountersStat

+ Nice int32

+ NumConnections int

+ NumCtxSwitches process.NumCtxSwitchesStat

+ NumFDs int32

+ NumThreads int32

+ PID int32

+ PPID int32

+ PageFaults process.PageFaultsStat

+ Rlimit []process.RlimitStat

+ Status string

+ TGID int32

+ Times cpu.TimesStat

+ UIDs []int32

+ Username string

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

+ type SysInfo struct

+ CPUInfo []CPUs

+ MemInfo []MemInfo

+ OSInfo []OSInfo

+ Partitions []Partitions

+ ProcInfo []ProcInfo

+ type Throughput struct

+ Avg uint64

+ Max uint64

+ Min uint64

+ Percentile50 uint64

+ Percentile90 uint64

+ Percentile99 uint64

May 6, 2021

Changes in this version

type Disk

+ FreeInodes uint64

May 5, 2021

Changes in this version

+ const AdminAPIVersion

+ const AdminAPIVersionV2

+ const CommentKey

+ const ConfigAppliedHeader

+ const ConfigAppliedTrue

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

+ const FsType

+ const HealItemBucket

+ const HealItemBucketMetadata

+ const HealItemMetadata

+ const HealItemObject

+ const ItemInitializing

+ const ItemOffline

+ const ItemOnline

+ const KvComment

+ const KvDoubleQuote

+ const KvNewline

+ const KvSeparator

+ const KvSingleQuote

+ const KvSpaceSeparator

+ const MaxJitter

+ const NoJitter

+ const SubSystemSeparator

+ const TierConfigV1

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

+ 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

+ 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 KvFields(input string, keys []string) []string

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

+ type AccountStatus string

+ const AccountDisabled

+ const AccountEnabled

+ type AddServiceAccountReq struct

+ AccessKey string

+ Policy []byte

+ 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) (AccountInfo, error)

+ func (adm *AdminClient) AddCannedPolicy(ctx context.Context, policyName string, policy []byte) 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) BackgroundHealStatus(ctx context.Context) (BgHealState, 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) DelConfigKV(ctx context.Context, k string) (err error)

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

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

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

+ func (adm *AdminClient) ForceUnlock(ctx context.Context, paths ...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) GetGroupDescription(ctx context.Context, group string) (*GroupDesc, error)

+ func (adm *AdminClient) GetKeyStatus(ctx context.Context, keyID string) (*KMSKeyStatus, 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) InfoCannedPolicy(ctx context.Context, policyName string) ([]byte, error)

+ func (adm *AdminClient) InfoServiceAccount(ctx context.Context, accessKey string) (InfoServiceAccountResp, 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) 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) RemoveCannedPolicy(ctx context.Context, policyName string) error

+ func (adm *AdminClient) RemoveRemoteTarget(ctx context.Context, bucket, arn 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) ServerHealthInfo(ctx context.Context, healthDataTypes []HealthDataType, deadline time.Duration) <-chan HealthInfo

+ 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) ServiceRestart(ctx context.Context) error

+ func (adm *AdminClient) ServiceStop(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) 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) StartProfiling(ctx context.Context, profiler ProfilerType) ([]StartProfilingResult, error)

+ func (adm *AdminClient) StorageInfo(ctx context.Context) (StorageInfo, 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) GetLogs(ctx context.Context, node string, lineCnt int, logKind string) <-chan LogInfo

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

+ 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

+ GatewayOnline bool

+ OfflineDisks BackendDisks

+ OnlineDisks BackendDisks

+ RRSCData []int

+ RRSCParity int

+ StandardSCData []int

+ StandardSCParity int

+ Type BackendType

+ type BackendType int

+ const Erasure

+ const FS

+ const Gateway

+ const Unknown

+ type BandwidthDetails struct

+ CurrentBandwidthInBytesPerSecond float64

+ LimitInBytesPerSecond int64

+ type BgHealState struct

+ HealDisks []string

+ ScannedItemsCount int64

+ Sets []SetStatus

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

+ type BucketAccessInfo struct

+ Access AccountAccess

+ Created time.Time

+ Name string

+ Size uint64

+ type BucketBandwidthReport struct

+ BucketStats map[string]BandwidthDetails

+ type BucketQuota struct

+ Quota uint64

+ Type QuotaType

+ func (q BucketQuota) IsValid() bool

+ type BucketTarget struct

+ API string

+ Arn string

+ BandwidthLimit int64

+ Credentials *Credentials

+ DisableProxy bool

+ Endpoint string

+ HealthCheckDuration time.Duration

+ Path string

+ Region string

+ ReplicationSync bool

+ 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

+ type Buckets struct

+ Count uint64

+ Error string

+ type ConfigHistoryEntry struct

+ CreateTime time.Time

+ Data string

+ RestoreID string

+ func (ch ConfigHistoryEntry) CreateTimeFormatted() string

+ type Credentials struct

+ AccessKey string

+ Expiration time.Time

+ SecretKey string

+ SessionToken string

+ 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

+ type Disk struct

+ AvailableSpace uint64

+ DiskIndex int

+ DrivePath string

+ Endpoint string

+ HealInfo *HealingDisk

+ Healing bool

+ Metrics *DiskMetrics

+ Model string

+ PoolIndex int

+ ReadLatency float64

+ ReadThroughput float64

+ RootDisk bool

+ SetIndex int

+ State string

+ TotalSpace uint64

+ UUID string

+ UsedSpace uint64

+ Utilization float64

+ WriteLatency float64

+ WriteThroughPut float64

+ type DiskLatency struct

+ Avg float64

+ Max float64

+ Min float64

+ Percentile50 float64

+ Percentile90 float64

+ Percentile99 float64

+ type DiskMetrics struct

+ APICalls map[string]uint64

+ APILatencies map[string]string

+ type DiskThroughput struct

+ Avg float64

+ Max float64

+ Min float64

+ Percentile50 float64

+ Percentile90 float64

+ Percentile99 float64

+ type DrivePerfInfo struct

+ Error string

+ Latency DiskLatency

+ Path string

+ Throughput DiskThroughput

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

+ Group string

+ IsRemove bool

+ Members []string

+ type GroupDesc struct

+ Members []string

+ Name string

+ Policy string

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

+ LastUpdate time.Time

+ Object string

+ ObjectsFailed uint64

+ ObjectsHealed uint64

+ Path string

+ PoolIndex int

+ QueuedBuckets []string

+ SetIndex int

+ Started time.Time

+ type HealthDataType string

+ const HealthDataTypeMinioConfig

+ const HealthDataTypeMinioInfo

+ const HealthDataTypePerfDrive

+ const HealthDataTypePerfNet

+ const HealthDataTypeSysCPU

+ const HealthDataTypeSysDiskHw

+ const HealthDataTypeSysDocker

+ const HealthDataTypeSysLoad

+ const HealthDataTypeSysMem

+ const HealthDataTypeSysNet

+ const HealthDataTypeSysOsInfo

+ const HealthDataTypeSysProcess

+ type HealthInfo struct

+ Error string

+ Minio MinioHealthInfo

+ Perf PerfInfo

+ Sys SysHealthInfo

+ TimeStamp time.Time

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

+ Backend interface{}

+ Buckets Buckets

+ DeploymentID string

+ Domain []string

+ Mode string

+ Objects Objects

+ Region string

+ SQSARN []string

+ Servers []ServerProperties

+ Services Services

+ Usage Usage

+ type InfoServiceAccountResp struct

+ AccountStatus string

+ ImpliedPolicy bool

+ ParentUser string

+ Policy string

+ type ItemState string

+ type KMS struct

+ Decrypt string

+ Encrypt string

+ Status string

+ type KMSKeyStatus struct

+ DecryptionErr string

+ EncryptionErr string

+ KeyID string

+ type KV struct

+ Key string

+ Value string

+ type KVS []KV

+ func (kvs *KVS) Set(key, value string)

+ func (kvs KVS) Empty() bool

+ func (kvs KVS) Get(key string) string

+ func (kvs KVS) Lookup(key string) (string, bool)

+ type LDAP struct

+ Status string

+ 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

+ 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

+ type Logger map[string]Status

+ type MinioHealthInfo struct

+ Config interface{}

+ Error string

+ Info InfoMessage

+ type NetLatency struct

+ Avg float64

+ Max float64

+ Min float64

+ Percentile50 float64

+ Percentile90 float64

+ Percentile99 float64

+ type NetPerfInfo 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 Objects struct

+ Count uint64

+ Error string

+ type Options struct

+ Creds *credentials.Credentials

+ Secure bool

+ type PartitionStat struct

+ Device string

+ Fstype string

+ Mountpoint string

+ Opts string

+ SmartInfo SmartInfo

+ type PerfInfo struct

+ DriveInfo []ServerDrivesInfo

+ Error string

+ Net []ServerNetHealthInfo

+ NetParallel ServerNetHealthInfo

+ type ProfilerType string

+ const ProfilerBlock

+ const ProfilerCPU

+ const ProfilerGoroutines

+ const ProfilerMEM

+ const ProfilerMutex

+ const ProfilerThreads

+ const ProfilerTrace

+ type QuotaType string

+ const FIFOQuota

+ const HardQuota

+ func (t QuotaType) IsValid() bool

+ type Report struct

+ Err error

+ Report BucketBandwidthReport

+ type S3Options func(*TierS3) error

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

+ Serial []DrivePerfInfo

+ type ServerMemInfo struct

+ Addr string

+ Error string

+ SwapMem *mem.SwapMemoryStat

+ VirtualMem *mem.VirtualMemoryStat

+ type ServerNetHealthInfo struct

+ Addr string

+ Error string

+ Net []NetPerfInfo

+ 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

+ MemStats runtime.MemStats

+ Network map[string]string

+ PoolNumber int

+ State string

+ Uptime int64

+ Version string

+ type ServerUpdateStatus struct

+ CurrentVersion string

+ UpdatedVersion string

+ type ServiceAction string

+ const ServiceActionRestart

+ const ServiceActionStop

+ type ServiceTraceInfo struct

+ Err error

+ Trace TraceInfo

+ type ServiceTraceOpts struct

+ All bool

+ Internal bool

+ OS bool

+ OnlyErrors bool

+ S3 bool

+ Storage bool

+ Threshold time.Duration

+ 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

+ 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

+ Error 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 StartProfilingResult struct

+ Error string

+ NodeName string

+ Success bool

+ type Status struct

+ Status string

+ type StorageInfo struct

+ Backend BackendInfo

+ Disks []Disk

+ type SysHealthInfo struct

+ CPUInfo []ServerCPUInfo

+ DiskHwInfo []ServerDiskHwInfo

+ Error string

+ MemInfo []ServerMemInfo

+ OsInfo []ServerOsInfo

+ ProcInfo []ServerProcInfo

+ 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

+ type Target struct

+ KVS KVS

+ SubSystem string

+ func ParseSubSysTarget(buf []byte, help Help) (target *Target, err error)

+ func ParseTarget(s string, help Help) (*Target, error)

+ type TargetIDStatus map[string]Status

+ type TargetUpdateType int

+ const BandwidthLimitUpdateType

+ const CredentialsUpdateType

+ const HealthCheckDurationUpdateType

+ const PathUpdateType

+ const ProxyUpdateType

+ const SyncUpdateType

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

+ 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

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

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

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

+ const Azure

+ const GCS

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

+ Count int

+ Stale bool

+ type TraceCallStats struct

+ InputBytes int

+ Latency time.Duration

+ OutputBytes int

+ TimeToFirstByte time.Duration

+ type TraceInfo struct

+ CallStats TraceCallStats

+ FuncName string

+ NodeName string

+ OSStats TraceOSStats

+ ReqInfo TraceRequestInfo

+ RespInfo TraceResponseInfo

+ StorageStats TraceStorageStats

+ Time time.Time

+ TraceType TraceType

+ type TraceOSStats struct

+ Duration time.Duration

+ Path string

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

+ Duration time.Duration

+ Path string

+ type TraceType int

+ const TraceHTTP

+ const TraceOS

+ const TraceStorage

+ type UpdateServiceAccountReq struct

+ NewPolicy []byte

+ NewSecretKey string

+ NewStatus string

+ type Usage struct

+ Error string

+ Size uint64

+ type UserInfo struct

+ MemberOf []string

+ PolicyName string

+ SecretKey string

+ Status AccountStatus