Versions in this module Expand all Collapse all v1 v1.0.2 Mar 17, 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 + var DefaultTransport = func(secure bool) http.RoundTripper + var ErrMaliciousData = sio.NotAuthentic + var HealthDataTypesList = []HealthDataType + var HealthDataTypesMap = map[string]HealthDataType + var MaxRetry = 10 + func DecryptData(password string, data io.Reader) ([]byte, error) + func EncryptData(password string, data []byte) ([]byte, error) + func ErrInvalidArgument(message string) error + func HasSpace(s string) bool + func KvFields(input string, keys []string) []string + 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 []BucketUsageInfo + Policy iampolicy.Policy + type AccountStatus string + const AccountDisabled + const AccountEnabled + type AddServiceAccountReq struct + Policy *iampolicy.Policy + type AddServiceAccountResp struct + Credentials auth.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 *iampolicy.Policy) error + func (adm *AdminClient) AddServiceAccount(ctx context.Context, policy *iampolicy.Policy) (auth.Credentials, 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) 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) (*iampolicy.Policy, error) + func (adm *AdminClient) ListCannedPolicies(ctx context.Context) (map[string]*iampolicy.Policy, 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) (ListServiceAccountsResp, 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) (string, error) + func (adm AdminClient) GetLogs(ctx context.Context, node string, lineCnt int, logKind string) <-chan LogInfo + func (adm AdminClient) ServiceTrace(ctx context.Context, allTrace, errTrace bool) <-chan ServiceTraceInfo + type Audit map[string]Status + 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 BgHealState struct + HealDisks []string + ScannedItemsCount int64 + Sets []SetStatus + func (b *BgHealState) Merge(others ...BgHealState) + type BucketQuota struct + Quota uint64 + Type QuotaType + func (q BucketQuota) IsValid() bool + type BucketTarget struct + API string + Arn string + BandwidthLimit int64 + Credentials *auth.Credentials + Endpoint string + HealthCheckDuration time.Duration + Label string + Path string + Region string + ReplicationSync bool + Secure bool + SourceBucket 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 + Access AccountAccess + Created time.Time + Name string + 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 DataUsageInfo struct + BucketsCount uint64 + BucketsSizes map[string]uint64 + LastUpdate time.Time + ObjectsCount uint64 + ObjectsSizesHistogram map[string]uint64 + ObjectsTotalSize uint64 + type Disk struct + AvailableSpace uint64 + DiskIndex int + DrivePath string + Endpoint string + HealInfo *HealingDisk + Healing bool + 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 DrivePerfInfo struct + Error string + Latency disk.Latency + Path string + Throughput disk.Throughput + 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 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 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 NetPerfInfo struct + Addr string + Error string + Latency net.Latency + Throughput net.Throughput + 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 smart.Info + 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 bandwidth.Report + 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 + 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 trace.Info + type ServiceType string + const ILMService + 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 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 TopLockOpts struct + Count int + Stale bool + type Usage struct + Error string + Size uint64 + type UserInfo struct + MemberOf []string + PolicyName string + SecretKey string + Status AccountStatus