Versions in this module Expand all Collapse all v1 v1.1.0 Mar 1, 2020 Changes in this version + const AdminAPIVersion + const CommentKey + const Default + const DefaultDrivePerfSize + const DefaultNetPerfSize + const DefaultRetryCap + const DefaultRetryUnit + const DriveStateCorrupt + const DriveStateMissing + const DriveStateOffline + const DriveStateOk + const EnableKey + const EnableOff + const EnableOn + const ErasureType + const FsType + const HealItemBucket + const HealItemBucketMetadata + const HealItemMetadata + const HealItemObject + const KvComment + const KvDoubleQuote + const KvNewline + const KvSeparator + const KvSingleQuote + const KvSpaceSeparator + const MaxJitter + const NoJitter + const SubSystemSeparator + var ErrMaliciousData = sio.NotAuthentic + var MaxRetry = 10 + var ObjectsHistogramIntervals = []objectHistogramInterval + 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 SanitizeValue(v string) string + type AccountAccess struct + AccountName string + Custom bool + Read bool + Write bool + type AccountStatus string + const AccountDisabled + const AccountEnabled + type AdminClient struct + func New(endpoint string, accessKeyID, secretAccessKey string, secure bool) (*AdminClient, error) + func (adm *AdminClient) AccountingUsageInfo() (map[string]BucketAccountingUsage, error) + func (adm *AdminClient) AddCannedPolicy(policyName, policy string) error + func (adm *AdminClient) AddUser(accessKey, secretKey string) error + func (adm *AdminClient) BackgroundHealStatus() (BgHealState, error) + func (adm *AdminClient) ClearConfigHistoryKV(restoreID string) (err error) + func (adm *AdminClient) DataUsageInfo() (DataUsageInfo, error) + func (adm *AdminClient) DelConfigKV(k string) (err error) + func (adm *AdminClient) DownloadProfilingData() (io.ReadCloser, error) + func (adm *AdminClient) GetConfig() ([]byte, error) + func (adm *AdminClient) GetConfigKV(key string) (Targets, error) + func (adm *AdminClient) GetGroupDescription(group string) (*GroupDesc, error) + func (adm *AdminClient) GetKeyStatus(keyID string) (*KMSKeyStatus, error) + func (adm *AdminClient) GetUserInfo(name string) (u UserInfo, err error) + func (adm *AdminClient) Heal(bucket, prefix string, healOpts HealOpts, clientToken string, ...) (healStart HealStartSuccess, healTaskStatus HealTaskStatus, err error) + func (adm *AdminClient) HelpConfigKV(subSys, key string, envOnly bool) (Help, error) + func (adm *AdminClient) InfoCannedPolicy(policyName string) ([]byte, error) + func (adm *AdminClient) ListCannedPolicies() (map[string][]byte, error) + func (adm *AdminClient) ListConfigHistoryKV(count int) ([]ConfigHistoryEntry, error) + func (adm *AdminClient) ListGroups() ([]string, error) + func (adm *AdminClient) ListUsers() (map[string]UserInfo, error) + func (adm *AdminClient) NetPerfInfo(size int) (map[string][]NetPerfInfo, error) + func (adm *AdminClient) RemoveCannedPolicy(policyName string) error + func (adm *AdminClient) RemoveUser(accessKey string) error + func (adm *AdminClient) RestoreConfigHistoryKV(restoreID string) (err error) + func (adm *AdminClient) ServerCPUHardwareInfo() ([]ServerCPUHardwareInfo, error) + func (adm *AdminClient) ServerCPULoadInfo() ([]ServerCPULoadInfo, error) + func (adm *AdminClient) ServerDrivesPerfInfo(size int64) ([]ServerDrivesPerfInfo, error) + func (adm *AdminClient) ServerInfo() (InfoMessage, error) + func (adm *AdminClient) ServerMemUsageInfo() ([]ServerMemUsageInfo, error) + func (adm *AdminClient) ServerNetworkHardwareInfo() ([]ServerNetworkHardwareInfo, error) + func (adm *AdminClient) ServerUpdate(updateURL string) (us ServerUpdateStatus, err error) + func (adm *AdminClient) ServiceRestart() error + func (adm *AdminClient) ServiceStop() error + func (adm *AdminClient) SetAppInfo(appName string, appVersion string) + func (adm *AdminClient) SetConfig(config io.Reader) (err error) + func (adm *AdminClient) SetConfigKV(kv string) (err error) + func (adm *AdminClient) SetCustomTransport(customHTTPTransport http.RoundTripper) + func (adm *AdminClient) SetGroupStatus(group string, status GroupStatus) error + func (adm *AdminClient) SetPolicy(policyName, entityName string, isGroup bool) error + func (adm *AdminClient) SetUser(accessKey, secretKey string, status AccountStatus) error + func (adm *AdminClient) SetUserStatus(accessKey string, status AccountStatus) error + func (adm *AdminClient) StartProfiling(profiler ProfilerType) ([]StartProfilingResult, error) + func (adm *AdminClient) StorageInfo() (StorageInfo, error) + func (adm *AdminClient) TopLocks() (LockEntries, error) + func (adm *AdminClient) TraceOff() + func (adm *AdminClient) TraceOn(outputStream io.Writer) + func (adm *AdminClient) UpdateGroupMembers(g GroupAddRemove) error + func (adm AdminClient) GetLogs(node string, lineCnt int, logKind string, doneCh <-chan struct{}) <-chan LogInfo + func (adm AdminClient) ServiceTrace(allTrace, errTrace bool, doneCh <-chan struct{}) <-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 BackendType int + const Erasure + const FS + const Unknown + type BgHealState struct + LastHealActivity time.Time + ScannedItemsCount int64 + type BucketAccountingUsage struct + AccessList []AccountAccess + Size uint64 + type Buckets struct + Count uint64 + 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 + DrivePath string + Model string + ReadLatency float64 + ReadThroughput float64 + State string + TotalSpace uint64 + UUID string + UsedSpace uint64 + Utilization float64 + WriteLatency float64 + WriteThroughPut float64 + type DriveInfo HealDriveInfo + 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 HardwareType string + const CPU + const HARDWARE + const NETWORK + type HealDriveInfo struct + Endpoint string + State string + UUID string + type HealItemType string + type HealOpts struct + DryRun bool + Recursive bool + Remove bool + ScanMode HealScanMode + 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 + 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 + type HealStartSuccess struct + ClientAddress string + ClientToken string + StartTime time.Time + type HealStopSuccess HealStartSuccess + type HealTaskStatus struct + FailureDetail string + HealSettings HealOpts + Items []HealResultItem + NumDisks int + StartTime time.Time + Summary string + type Help struct + Description string + KeysHelp HelpKVS + MultipleTargets bool + SubSys 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 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) + func (kvs KVS) String() string + type LDAP struct + Status 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 + Resource string + ServerList []string + Source string + Timestamp time.Time + Type string + type LogInfo struct + ConsoleMsg string + Err error + NodeName string + func (l LogInfo) SendLog(node, logKind string) bool + type Logger map[string]Status + type NetPerfInfo struct + Addr string + Error string + ReadThroughput uint64 + type Objects struct + Count uint64 + type ProfilerType string + const ProfilerBlock + const ProfilerCPU + const ProfilerMEM + const ProfilerMutex + const ProfilerThreads + const ProfilerTrace + type ServerCPUHardwareInfo struct + Addr string + CPUInfo []cpu.InfoStat + Error string + type ServerCPULoadInfo struct + Addr string + Error string + HistoricLoad []cpu.Load + Load []cpu.Load + type ServerDrivesPerfInfo struct + Addr string + Error string + Perf []disk.Performance + Size int64 + type ServerMemUsageInfo struct + Addr string + Error string + HistoricUsage []mem.Usage + Usage []mem.Usage + type ServerNetworkHardwareInfo struct + Addr string + Error string + NetworkInfo []net.Interface + type ServerProperties struct + CommitID string + Disks []Disk + Endpoint string + Network map[string]string + 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 Services struct + Audit []Audit + LDAP LDAP + Logger []Logger + Notifications []map[string][]TargetIDStatus + Vault Vault + type StartProfilingResult struct + Error string + NodeName string + Success bool + type Status struct + Status string + type StorageInfo struct + Available []uint64 + Backend struct{ ... } + MountPaths []string + Total []uint64 + Used []uint64 + type Target struct + KVS KVS + SubSystem string + type TargetIDStatus map[string]Status + type Targets []Target + func ParseSubSysTarget(buf []byte) (Targets, error) + func (t *Targets) AddTarget(s string) error + func (t Targets) Count() int + func (t Targets) String() string + type Usage struct + Size uint64 + type UserInfo struct + MemberOf []string + PolicyName string + SecretKey string + Status AccountStatus + type Vault struct + Decrypt string + Encrypt string + Status string + type XlBackend struct + OfflineDisks int + OnlineDisks int + RRSCData int + RRSCParity int + StandardSCData int + StandardSCParity int + Type backendType