Versions in this module Expand all Collapse all v0 v0.1.0 Jul 8, 2026 Changes in this version + const AmzObjectLockLegalHold + const AmzObjectLockMode + const AmzObjectLockRetainUntilDate + const HelpTmpl + const History + const Ping + const PingDist + var Century = Year * 100 + var CommitID = "DEVELOPMENT.GOGET" + var CopyrightYear = "0000" + var Day = Hour * 24 + var Decade = Year * 10 + var ErrInvalidFileSystemAttribute = errors.New("Error in parsing file system attribute") + var ErrInvalidMetadata = errors.New("specified metadata should be of form key1=value1;key2=value2;... and so on") + var EventTypeDelete = []notify.Event — darwin/amd64, linux/amd64, windows/amd64 + var EventTypeGet = []notify.Event — darwin/amd64 + var EventTypeGet = []notify.Event — linux/amd64, windows/amd64 + var EventTypePut = []notify.Event — darwin/amd64, linux/amd64, windows/amd64 + var Fortnight = Week * 2 + var GlobalDevMode = false + var GlobalSubnetProxyURL *url.URL + var GlobalTrapSignals = true + var HelpEnvTemplate = template.Must(template.New("config-help-env").Funcs(funcMap).Parse(HelpTmpl)) + var HelpTemplate = template.Must(template.New("config-help").Funcs(funcMap).Parse(HelpTmpl)) + var HistoryTemplate = template.Must(template.New("history-list").Funcs(funcMap).Parse(History)) + var Hour = Duration(time.Hour) + var Microsecond = Duration(time.Microsecond) + var Millennium = Year * 1000 + var Millisecond = Duration(time.Millisecond) + var Minute = Duration(time.Minute) + var Month = Day * 30 + var Nanosecond = Duration(time.Nanosecond) + var PingTemplate = template.Must(template.New("ping-list").Funcs(colorMap).Parse(Ping)) + var PingTemplateDist = template.Must(template.New("ping-list").Funcs(colorMap).Parse(PingDist)) + var ReleaseTag = "DEVELOPMENT.GOGET" + var S3New = newFactory() + var Second = Duration(time.Second) + var ShortCommitID = CommitID[:12] + var Version = "DEVELOPMENT.GOGET" + var Week = Day * 7 + var Year = Day * 365 + func DownloadReleaseData(customReleaseURL string, timeout time.Duration) (data string, err *probe.Error) + func GetCurrentReleaseTime() (releaseTime time.Time, err *probe.Error) + func IsDCOS() bool + func IsDeleteEvent(event notify.Event) bool — darwin/amd64, linux/amd64, windows/amd64 + func IsDocker() bool + func IsGetEvent(_ notify.Event) bool — darwin/amd64 + func IsGetEvent(event notify.Event) bool — linux/amd64, windows/amd64 + func IsKubernetes() bool + func IsPutEvent(event notify.Event) bool — darwin/amd64, linux/amd64, windows/amd64 + func IsSourceBuild() bool + func Main(args []string) error + func NewAdminFactory() func(config *Config) (*madmin.AdminClient, *probe.Error) + func ParseForm(r *http.Request) error + func PipeChan(capacity int) (inputCh, outputCh chan notify.EventInfo) + func SubnetBaseURL() string + func SubnetLicenseAuthHeaders(lic string) map[string]string + func SubnetPostReq(reqURL string, payload any, headers map[string]string) (string, error) + func SubnetRegisterURL() string + func SubnetUploadURL(uploadType string) string + func TarGZHealthInfo(healthInfo any, version string) ([]byte, error) + func UTCNow() time.Time + type APINotImplemented struct + API string + APIType string + func (e APINotImplemented) Error() string + type BrokenSymlink GenericFileError + func (e BrokenSymlink) Error() string + type BucketDoesNotExist GenericBucketError + func (e BucketDoesNotExist) Error() string + type BucketExists GenericBucketError + func (e BucketExists) Error() string + type BucketInfo struct + Date time.Time + Encryption struct{ ... } + ILM struct{ ... } + Key string + Location string + Locking struct{ ... } + Notification struct{ ... } + Policy struct{ ... } + Prefix bool + Replication struct{ ... } + Size int64 + Tagging map[string]string + Type os.FileMode + URL ClientURL + Versioning struct{ ... } + func (i BucketInfo) Tags() string + type BucketInvalid struct + Bucket string + func (e BucketInvalid) Error() string + type BucketNameEmpty struct + func (e BucketNameEmpty) Error() string + type BucketStatOptions struct + type Client interface + AddUserAgent func(app, version string) + Copy func(ctx context.Context, source string, opts CopyOptions, progress io.Reader) *probe.Error + DeleteBucketCors func(ctx context.Context) *probe.Error + DeleteEncryption func(ctx context.Context) *probe.Error + DeleteTags func(ctx context.Context, versionID string) *probe.Error + Get func(ctx context.Context, opts GetOptions) (reader io.ReadCloser, content *ClientContent, err *probe.Error) + GetAccess func(ctx context.Context) (access, policyJSON string, err *probe.Error) + GetAccessRules func(ctx context.Context) (policyRules map[string]string, err *probe.Error) + GetBucketCors func(ctx context.Context) (*cors.Config, *probe.Error) + GetBucketInfo func(ctx context.Context) (BucketInfo, *probe.Error) + GetEncryption func(ctx context.Context) (string, string, *probe.Error) + GetLifecycle func(ctx context.Context) (*lifecycle.Configuration, time.Time, *probe.Error) + GetObjectLegalHold func(ctx context.Context, versionID string) (minio.LegalHoldStatus, *probe.Error) + GetObjectLockConfig func(ctx context.Context) (status string, mode minio.RetentionMode, validity uint64, ...) + GetObjectRetention func(ctx context.Context, versionID string) (minio.RetentionMode, time.Time, *probe.Error) + GetPart func(ctx context.Context, part int) (io.ReadCloser, *probe.Error) + GetReplication func(ctx context.Context) (replication.Config, *probe.Error) + GetReplicationMetrics func(ctx context.Context) (replication.MetricsV2, *probe.Error) + GetTags func(ctx context.Context, versionID string) (map[string]string, *probe.Error) + GetURL func() ClientURL + GetVersion func(ctx context.Context) (minio.BucketVersioningConfiguration, *probe.Error) + List func(ctx context.Context, opts ListOptions) <-chan *ClientContent + ListBuckets func(ctx context.Context) ([]*ClientContent, *probe.Error) + MakeBucket func(ctx context.Context, region string, ignoreExisting, withLock bool) *probe.Error + Put func(ctx context.Context, reader io.Reader, size int64, progress io.Reader, ...) (n int64, err *probe.Error) + PutObjectLegalHold func(ctx context.Context, versionID string, hold minio.LegalHoldStatus) *probe.Error + PutObjectRetention func(ctx context.Context, versionID string, mode minio.RetentionMode, ...) *probe.Error + PutPart func(ctx context.Context, reader io.Reader, size int64, progress io.Reader, ...) (n int64, err *probe.Error) + Remove func(ctx context.Context, isIncomplete, isRemoveBucket, isBypass, isForceDel bool, ...) (errorCh <-chan RemoveResult) + RemoveBucket func(ctx context.Context, forceRemove bool) *probe.Error + RemoveReplication func(ctx context.Context) *probe.Error + ReplicationResyncStatus func(ctx context.Context, arn string) (rinfo replication.ResyncTargetsInfo, err *probe.Error) + ResetReplication func(ctx context.Context, before time.Duration, arn string) (replication.ResyncTargetsInfo, *probe.Error) + Restore func(ctx context.Context, versionID string, days int) *probe.Error + Select func(ctx context.Context, expression string, sse encrypt.ServerSide, ...) (io.ReadCloser, *probe.Error) + SetAccess func(ctx context.Context, access string, isJSON bool) *probe.Error + SetBucketCors func(ctx context.Context, corsXML []byte) *probe.Error + SetEncryption func(ctx context.Context, algorithm, kmsKeyID string) *probe.Error + SetLifecycle func(ctx context.Context, config *lifecycle.Configuration) *probe.Error + SetObjectLockConfig func(ctx context.Context, mode minio.RetentionMode, validity uint64, ...) *probe.Error + SetReplication func(ctx context.Context, cfg *replication.Config, opts replication.Options) *probe.Error + SetTags func(ctx context.Context, versionID, tags string) *probe.Error + SetVersion func(ctx context.Context, status string, prefixes []string, excludeFolders bool) *probe.Error + ShareDownload func(ctx context.Context, versionID string, expires time.Duration) (string, *probe.Error) + ShareUpload func(context.Context, bool, time.Duration, string) (string, map[string]string, *probe.Error) + Stat func(ctx context.Context, opts StatOptions) (content *ClientContent, err *probe.Error) + Watch func(ctx context.Context, options WatchOptions) (*WatchObject, *probe.Error) + type ClientContent struct + BucketName string + BypassGovernance bool + Checksum map[string]string + ETag string + Err *probe.Error + Expiration time.Time + ExpirationRuleID string + Expires time.Time + IsDeleteMarker bool + IsLatest bool + LegalHold string + LegalHoldEnabled bool + Metadata map[string]string + ReplicationStatus string + Restore *minio.RestoreInfo + RetentionDuration string + RetentionEnabled bool + RetentionMode string + Size int64 + StorageClass string + Tags map[string]string + Time time.Time + Type os.FileMode + URL ClientURL + UserMetadata map[string]string + VersionID string + type ClientResult struct + BytesSent uint64 + Endpoint string + Error string + TimeSpent int64 + type ClientURL struct + Host string + Path string + Scheme string + SchemeSeparator string + Separator rune + Type ClientURLType + func (u ClientURL) Clone() ClientURL + func (u ClientURL) String() string + type ClientURLType int + type ClusterHealthV1 struct + Error string + Hardware HwServersV1 + Software SwInfoV1 + Status string + TimeStamp time.Time + func MapHealthInfoToV1(healthInfo madmin.HealthInfoV0, err error) ClusterHealthV1 + func (ch ClusterHealthV1) GetError() string + func (ch ClusterHealthV1) GetStatus() string + func (ch ClusterHealthV1) GetTimestamp() time.Time + func (ch ClusterHealthV1) JSON() string + func (ch ClusterHealthV1) String() string + 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 + func GetClusterRegInfo(admInfo madmin.InfoMessage, clusterName string) ClusterRegistrationInfo + type ClusterRegistrationReq struct + Token string + type Config struct + AccessKey string + Alias string + AppName string + AppVersion string + ConnReadDeadline time.Duration + ConnWriteDeadline time.Duration + Debug bool + DownloadLimit int64 + HostURL string + Insecure bool + Lookup minio.BucketLookupType + SecretKey string + SessionToken string + Signature string + Transport http.RoundTripper + UploadLimit int64 + func BuildS3Config(ctx context.Context, alias, url, accessKey, secretKey, api, path string, ...) (*Config, *probe.Error) + func NewS3Config(alias, urlStr string, aliasCfg *aliasConfigV10) *Config + type ConfigAnyVersion struct + Version string + type CopyOptions struct + type DirOpt int8 + const DirFirst + const DirLast + const DirNone + type DriveTestResult struct + Endpoint string + Error string + Perf []madmin.DrivePerf + type DriveTestResults struct + Results []DriveTestResult + type Duration time.Duration + func ParseDuration(s string) (Duration, error) + func (d Duration) Days() float64 + type EmptyPath struct + func (e EmptyPath) Error() string + type EndPointStats struct + DNS string + Endpoint *url.URL + Error string + Status string + Time string + type EventInfo struct + Host string + Path string + Port string + Size int64 + Time string + Type notification.EventType + UserAgent string + UserMetadata map[string]string + type Field struct + type GenericBucketError struct + Bucket string + type GenericFileError struct + Path string + type GetOptions struct + PartNumber int + Preserve bool + RangeStart int64 + SSE encrypt.ServerSide + VersionID string + Zip bool + type Health struct + Health SchemaVersion + type HealthDataTypeFlag struct + EnvVar string + Hidden bool + Name string + Usage string + Value *HealthDataTypeSlice + func (f HealthDataTypeFlag) Apply(set *flag.FlagSet) + func (f HealthDataTypeFlag) ApplyWithError(set *flag.FlagSet) error + func (f HealthDataTypeFlag) GetName() string + func (f HealthDataTypeFlag) String() string + type HealthDataTypeSlice []madmin.HealthDataType + func GetGlobalHealthDataTypeSlice(c *cli.Context, name string) *HealthDataTypeSlice + func GetHealthDataTypeSlice(c *cli.Context, name string) *HealthDataTypeSlice + func (d *HealthDataTypeSlice) Get() any + func (d *HealthDataTypeSlice) Set(value string) error + func (d *HealthDataTypeSlice) String() string + func (d *HealthDataTypeSlice) Value() []madmin.HealthDataType + type HealthReportHeader struct + Subnet Health + type HealthReportInfo interface + GetError func() string + GetStatus func() string + GetTimestamp func() time.Time + type HwCPUV1 struct + CPUStat []cpu.InfoStat + Error string + TimesStat []cpu.TimesStat + type HwDrivePerfV1 struct + Error string + Parallel []madmin.DrivePerfInfoV0 + Serial []madmin.DrivePerfInfoV0 + type HwDriveV1 struct + Counters map[string]disk.IOCountersStat + Error string + Partitions []madmin.PartitionStat + Usage []*disk.UsageStat + type HwMemV1 struct + Error string + SwapMem *mem.SwapMemoryStat + VirtualMem *mem.VirtualMemoryStat + type HwNetPerfV1 struct + Parallel []madmin.NetPerfInfoV0 + Serial []madmin.NetPerfInfoV0 + type HwPerfV1 struct + Drive HwDrivePerfV1 + Net HwNetPerfV1 + type HwServerV1 struct + Addr string + CPUs []HwCPUV1 + Drives []HwDriveV1 + MemInfo HwMemV1 + Perf HwPerfV1 + type HwServersV1 struct + Servers []HwServerV1 + type InvalidArgument struct + func (e InvalidArgument) Error() string + type ListOptions struct + Count int + Incomplete bool + ListZip bool + Recursive bool + ShowDir DirOpt + TimeRef time.Time + WithDeleteMarkers bool + WithMetadata bool + WithOlderVersions bool + type MinioHealthInfoV1 struct + Config any + Error string + Info madmin.InfoMessage + ProcInfo []madmin.ServerProcInfo + type NetStats struct + RX uint64 + TX uint64 + type NetTestResult struct + Endpoint string + Error string + Perf NetStats + type NetTestResults struct + Results []NetTestResult + type NotificationConfig struct + Arn string + Events []string + ID string + Prefix string + Suffix string + type ObjGETPerfResults struct + Perf ObjGETStats + Servers []ObjStatServer + type ObjGETStats struct + TTFB madmin.Timings + type ObjPUTPerfResults struct + Perf ObjPUTStats + Servers []ObjStatServer + type ObjPUTStats struct + ObjectsPerSec uint64 + Response madmin.Timings + Throughput uint64 + type ObjStatServer struct + Endpoint string + Error string + Perf ObjStats + type ObjStats struct + ObjectsPerSec uint64 + Throughput uint64 + type ObjTestResults struct + GETResults ObjGETPerfResults + ObjectSize int + PUTResults ObjPUTPerfResults + Threads int + type ObjectAlreadyExists struct + Object string + func (e ObjectAlreadyExists) Error() string + type ObjectAlreadyExistsAsDirectory struct + Object string + func (e ObjectAlreadyExistsAsDirectory) Error() string + type ObjectIsDeleteMarker struct + func (e ObjectIsDeleteMarker) Error() string + type ObjectMissing struct + func (e ObjectMissing) Error() string + type ObjectNameEmpty struct + func (e ObjectNameEmpty) Error() string + type ObjectOnGlacier struct + Object string + func (e ObjectOnGlacier) Error() string + type ParallelManager struct + func (p *ParallelManager) Read(b []byte) (n int, err error) + type PathInsufficientPermission GenericFileError + func (e PathInsufficientPermission) Error() string + type PathIsNotRegular GenericFileError + func (e PathIsNotRegular) Error() string + type PathNotADirectory GenericFileError + func (e PathNotADirectory) Error() string + type PathNotFound GenericFileError + func (e PathNotFound) Error() string + type PerfTestOutput struct + ClientResults *ClientResult + DriveResults *DriveTestResults + Error string + NetResults *NetTestResults + ObjectResults *ObjTestResults + SiteReplicationResults *SiteReplicationTestResults + func (p PerfTestOutput) JSON() string + func (p PerfTestOutput) String() string + type PerfTestResult struct + ClientResult *madmin.ClientPerfResult + DriveResult []madmin.DriveSpeedTestResult + Err string + Final bool + NetResult *madmin.NetperfResult + ObjectResult *madmin.SpeedTestResult + SiteReplicationResult *madmin.SiteNetPerfResult + Type PerfTestType + type PerfTestType byte + const ClientPerfTest + const DrivePerfTest + const NetPerfTest + const ObjectPerfTest + const SiteReplicationPerfTest + func (p PerfTestType) Name() string + type PingResult struct + Counter string + EndPointsStats []EndPointStats + Status string + func (pr PingResult) JSON() string + func (pr PingResult) String() string + type PingSummary struct + ServerMap map[string]ServerStats + Status string + func (ps PingSummary) JSON() string + func (ps PingSummary) String() string + type PrettyRecord struct + type PrettyTable struct + type Progress interface + Get func() int64 + SetTotal func(int64) + type ProgressReader interface + type ProgressStatus struct + func (p ProgressStatus) Set64(length int64) *progressBar + func (ps *ProgressStatus) Add(v int64) Status + func (ps *ProgressStatus) AddCounts(v int64) + func (ps *ProgressStatus) Finish() + func (ps *ProgressStatus) Get() int64 + func (ps *ProgressStatus) GetCounts() int64 + func (ps *ProgressStatus) PrintMsg(_ message) + func (ps *ProgressStatus) Println(data ...any) + func (ps *ProgressStatus) Read(p []byte) (n int, err error) + func (ps *ProgressStatus) SetCaption(s string) + func (ps *ProgressStatus) SetCounts(v int64) + func (ps *ProgressStatus) SetTotal(v int64) Status + func (ps *ProgressStatus) Start() + func (ps *ProgressStatus) Total() int64 + func (ps *ProgressStatus) Update() + type PrometheusConfig struct + ScrapeConfigs []ScrapeConfig + func (c PrometheusConfig) JSON() string + func (c PrometheusConfig) String() string + type PutOptions struct + type QuietStatus struct + func (a QuietStatus) Set(n int64) *accounter + func (a QuietStatus) Stat() accountStat + func (qs *QuietStatus) Add(v int64) Status + func (qs *QuietStatus) AddCounts(v int64) + func (qs *QuietStatus) Finish() + func (qs *QuietStatus) Get() int64 + func (qs *QuietStatus) GetCounts() int64 + func (qs *QuietStatus) PrintMsg(msg message) + func (qs *QuietStatus) Println(_ ...any) + func (qs *QuietStatus) Read(p []byte) (n int, err error) + func (qs *QuietStatus) SetCaption(_ string) + func (qs *QuietStatus) SetCounts(v int64) + func (qs *QuietStatus) SetTotal(v int64) Status + func (qs *QuietStatus) Start() + func (qs *QuietStatus) Total() int64 + func (qs *QuietStatus) Update() + type RemoveResult struct + BucketName string + Err *probe.Error + type Row struct + type S3Client struct + func (c *S3Client) AddNotificationConfig(ctx context.Context, arn string, events []string, prefix, suffix string, ...) *probe.Error + func (c *S3Client) AddUserAgent(app, version string) + func (c *S3Client) Copy(ctx context.Context, source string, opts CopyOptions, progress io.Reader) *probe.Error + func (c *S3Client) DeleteBucketCors(ctx context.Context) *probe.Error + func (c *S3Client) DeleteEncryption(ctx context.Context) *probe.Error + func (c *S3Client) DeleteTags(ctx context.Context, versionID string) *probe.Error + func (c *S3Client) Get(ctx context.Context, opts GetOptions) (io.ReadCloser, *ClientContent, *probe.Error) + func (c *S3Client) GetAccess(ctx context.Context) (string, string, *probe.Error) + func (c *S3Client) GetAccessRules(ctx context.Context) (map[string]string, *probe.Error) + func (c *S3Client) GetBucketCors(ctx context.Context) (*cors.Config, *probe.Error) + func (c *S3Client) GetBucketInfo(ctx context.Context) (BucketInfo, *probe.Error) + func (c *S3Client) GetEncryption(ctx context.Context) (algorithm, keyID string, err *probe.Error) + func (c *S3Client) GetLifecycle(ctx context.Context) (*lifecycle.Configuration, time.Time, *probe.Error) + func (c *S3Client) GetObjectLegalHold(ctx context.Context, versionID string) (minio.LegalHoldStatus, *probe.Error) + func (c *S3Client) GetObjectLockConfig(ctx context.Context) (string, minio.RetentionMode, uint64, minio.ValidityUnit, *probe.Error) + func (c *S3Client) GetObjectRetention(ctx context.Context, versionID string) (minio.RetentionMode, time.Time, *probe.Error) + func (c *S3Client) GetPart(ctx context.Context, part int) (io.ReadCloser, *probe.Error) + func (c *S3Client) GetReplication(ctx context.Context) (replication.Config, *probe.Error) + func (c *S3Client) GetReplicationMetrics(ctx context.Context) (replication.MetricsV2, *probe.Error) + func (c *S3Client) GetTags(ctx context.Context, versionID string) (map[string]string, *probe.Error) + func (c *S3Client) GetURL() ClientURL + func (c *S3Client) GetVersion(ctx context.Context) (config minio.BucketVersioningConfiguration, err *probe.Error) + func (c *S3Client) List(ctx context.Context, opts ListOptions) <-chan *ClientContent + func (c *S3Client) ListBuckets(ctx context.Context) ([]*ClientContent, *probe.Error) + func (c *S3Client) ListNotificationConfigs(ctx context.Context, arn string) ([]NotificationConfig, *probe.Error) + func (c *S3Client) MakeBucket(ctx context.Context, region string, ignoreExisting, withLock bool) *probe.Error + func (c *S3Client) Put(ctx context.Context, reader io.Reader, size int64, progress io.Reader, ...) (int64, *probe.Error) + func (c *S3Client) PutObjectLegalHold(ctx context.Context, versionID string, lhold minio.LegalHoldStatus) *probe.Error + func (c *S3Client) PutObjectRetention(ctx context.Context, versionID string, mode minio.RetentionMode, ...) *probe.Error + func (c *S3Client) PutPart(ctx context.Context, reader io.Reader, size int64, progress io.Reader, ...) (int64, *probe.Error) + func (c *S3Client) Remove(ctx context.Context, isIncomplete, isRemoveBucket, isBypass, isForceDel bool, ...) <-chan RemoveResult + func (c *S3Client) RemoveBucket(ctx context.Context, forceRemove bool) *probe.Error + func (c *S3Client) RemoveNotificationConfig(ctx context.Context, arn, event, prefix, suffix string) *probe.Error + func (c *S3Client) RemoveReplication(ctx context.Context) *probe.Error + func (c *S3Client) ReplicationResyncStatus(ctx context.Context, arn string) (rinfo replication.ResyncTargetsInfo, err *probe.Error) + func (c *S3Client) ResetReplication(ctx context.Context, before time.Duration, tgtArn string) (rinfo replication.ResyncTargetsInfo, err *probe.Error) + func (c *S3Client) Restore(ctx context.Context, versionID string, days int) *probe.Error + func (c *S3Client) Select(ctx context.Context, expression string, sse encrypt.ServerSide, ...) (io.ReadCloser, *probe.Error) + func (c *S3Client) SetAccess(ctx context.Context, bucketPolicy string, isJSON bool) *probe.Error + func (c *S3Client) SetBucketCors(ctx context.Context, corsXML []byte) *probe.Error + func (c *S3Client) SetEncryption(ctx context.Context, encType, kmsKeyID string) *probe.Error + func (c *S3Client) SetLifecycle(ctx context.Context, config *lifecycle.Configuration) *probe.Error + func (c *S3Client) SetObjectLockConfig(ctx context.Context, mode minio.RetentionMode, validity uint64, ...) *probe.Error + func (c *S3Client) SetReplication(ctx context.Context, cfg *replication.Config, opts replication.Options) *probe.Error + func (c *S3Client) SetTags(ctx context.Context, versionID, tagString string) *probe.Error + func (c *S3Client) SetVersion(ctx context.Context, status string, prefixes []string, excludeFolders bool) *probe.Error + func (c *S3Client) ShareDownload(ctx context.Context, versionID string, expires time.Duration) (string, *probe.Error) + func (c *S3Client) ShareUpload(ctx context.Context, isRecursive bool, expires time.Duration, ...) (string, map[string]string, *probe.Error) + func (c *S3Client) Stat(ctx context.Context, opts StatOptions) (*ClientContent, *probe.Error) + func (c *S3Client) Watch(ctx context.Context, options WatchOptions) (*WatchObject, *probe.Error) + type SameFile struct + Destination string + Source string + func (e SameFile) Error() string + type SchemaVersion struct + Version string + type ScrapeConfig struct + BearerToken string + JobName string + MetricsPath string + Scheme string + StaticConfigs []StatConfig + type SelectObjectOpts struct + CompressionType minio.SelectCompressionType + InputSerOpts map[string]map[string]string + OutputSerOpts map[string]map[string]string + type ServerStats struct + Avg uint64 + Counter int + DNS uint64 + Endpoint *url.URL + Err string + ErrorCount int + Max uint64 + Min uint64 + Sum uint64 + type SiteNetStats struct + RX uint64 + RXTotalDuration time.Duration + TX uint64 + TXTotalDuration time.Duration + TotalConn uint64 + type SiteReplicationTestNodeResult struct + Endpoint string + Error string + Perf SiteNetStats + type SiteReplicationTestResults struct + Results []SiteReplicationTestNodeResult + type StatConfig struct + Targets []string + func (t StatConfig) JSON() string + func (t StatConfig) String() string + type StatOptions struct + type Status interface + Add func(int64) Status + AddCounts func(int64) + Finish func() + Get func() int64 + GetCounts func() int64 + PrintMsg func(msg message) + Println func(data ...any) + Read func(p []byte) (n int, err error) + SetCaption func(string) + SetCounts func(int64) + SetTotal func(int64) Status + Start func() + Total func() int64 + Update func() + func NewProgressStatus(hook io.Reader) Status + func NewQuietStatus(hook io.Reader) Status + type SubnetFileUploader struct + AutoCompress bool + AutoEncrypt bool + DeleteAfterUpload bool + FilePath string + Headers SubnetHeaders + Params url.Values + PubKey []byte + ReqURL string + func (i *SubnetFileUploader) UploadFileToSubnet() (string, error) + type SubnetHeaders map[string]string + func SubnetAPIKeyAuthHeaders(apiKey string) SubnetHeaders + type SubnetLoginReq struct + Password string + Username string + type SubnetMFAReq struct + OTP string + Token string + Username string + type SwInfoV1 struct + Minio MinioHealthInfoV1 + OsInfo []madmin.ServerOsInfo + type TooManyLevelsSymlink GenericFileError + func (e TooManyLevelsSymlink) Error() string + type URLs struct + DisableMultipart bool + Error *probe.Error + ErrorCond differType + MD5 bool + SourceAlias string + SourceContent *ClientContent + TargetAlias string + TargetContent *ClientContent + TotalCount int64 + TotalSize int64 + func (m URLs) Equal(n URLs) bool + func (m URLs) WithError(err *probe.Error) URLs + type UnexpectedEOF struct + TotalSize int64 + TotalWritten int64 + func (e UnexpectedEOF) Error() string + type UnexpectedExcessRead UnexpectedEOF + func (e UnexpectedExcessRead) Error() string + type UnexpectedShortWrite struct + InputSize int + WriteSize int + func (e UnexpectedShortWrite) Error() string + type WatchObject struct + DoneChan chan struct{} + ErrorChan chan *probe.Error + EventInfoChan chan []EventInfo + func (w *WatchObject) Errors() chan *probe.Error + func (w *WatchObject) Events() chan []EventInfo + type WatchOptions struct + Events []string + Prefix string + Recursive bool + Suffix string + type Watcher struct + ErrorChan chan *probe.Error + EventInfoChan chan []EventInfo + func NewWatcher(sessionStartTime time.Time) *Watcher + func (w *Watcher) Errors() chan *probe.Error + func (w *Watcher) Events() chan []EventInfo + func (w *Watcher) Join(ctx context.Context, client Client, recursive bool) *probe.Error + func (w *Watcher) Stop()
Go to main page