Versions in this module Expand all Collapse all v1 v1.3.19 Jun 6, 2023 v1.3.18 Jun 6, 2023 Changes in this version + const AbortReaction + const AwsMultipartDelim + const BadSmapPrefix + const CRC32CObjMD + const DefaultIdleConnTimeout + const DefaultMaxIdleConns + const DefaultMaxIdleConnsPerHost + const DefaultReadBufferSize + const DefaultSendRecvBufferSize + const DefaultWriteBufferSize + const ETag + const EmptyProtoSchemeForURL + const FmtErrBackwardCompat + const FmtErrIntegrity + const FmtErrMorphUnmarshal + const FmtErrUnknown + const FmtErrUnmarshal + const GitHubHome + const IgnoreReaction + const KeepaliveAverageType + const KeepaliveHeartbeatType + const LastModified + const MD5ObjMD + const MaxSliceCount + const MetaverAuthNConfig + const MetaverAuthTokens + const MetaverBMD + const MetaverConfig + const MetaverEtlMD + const MetaverJSP + const MetaverLOM + const MetaverMetasync + const MetaverRMD + const MetaverSmap + const MetaverVMD + const MinSliceCount + const MsgpLsoBufSize + const NetIntraControl + const NetIntraData + const NetPublic + const NsGlobalUname + const OrigURLObjMD + const PropBackendBck + const PropBackendBckName + const PropBackendBckProvider + const PropBucketAccessAttrs + const PropBucketCreated + const PropBucketVerEnabled + const RetryLogOff + const RetryLogQuiet + const RetryLogVerbose + const SourceObjMD + const VersionAIStore + const VersionAuthN + const VersionCLI + const VersionLoader + const VersionObjMD + const WarnReaction + const WebObjMD + var BackendHelpers = struct{ ... } + var ConfigRestartRequired = []string + var ErrNoMountpaths = errors.New("no mountpaths") + var ErrNotEnoughTargets = errors.New("not enough target nodes") + var ErrQuiesceTimeout = errors.New("timed out waiting for quiescence") + var ErrSkip = errors.New("skip") + var ErrStartupTimeout = errors.New("startup timeout") + var ErrXactICNotifAbort = errors.New("IC(notifications) abort") + var ErrXactNoErrAbort = errors.New("no-error abort") + var ErrXactRenewAbort = errors.New("renewal abort") + var ErrXactUserAbort = errors.New("user abort") + var Features feat.Flags + var GCO *globalConfigOwner + var KnownNetworks = []string + var NsAnyRemote = Ns + var NsGlobal = Ns + var SupportedReactions = []string + var Timeout = &timeout + func AppGloghdr(hdr string) + func CustomMD2S(md cos.StrKVs) string + func DelBckFromQuery(query url.Values) url.Values + func DirHasOrIsPrefix(dirPath, prefix string) bool + func FreeBuffer(buf *bytes.Buffer) + func FreeHra(a *HreqArgs) + func FreeHterr(a *ErrHTTP) + func IsErrAborted(err error) bool + func IsErrBckNotFound(err error) bool + func IsErrBucketAlreadyExists(err error) bool + func IsErrBucketLevel(err error) bool + func IsErrBucketNought(err error) bool + func IsErrCapacityExceeded(err error) bool + func IsErrLmetaCorrupted(err error) bool + func IsErrLmetaNotFound(err error) bool + func IsErrMountpathNotFound(err error) bool + func IsErrObjLevel(err error) bool + func IsErrObjNought(err error) bool + func IsErrRemoteBckNotFound(err error) bool + func IsErrSoft(err error) bool + func IsErrStreamTerminated(err error) bool + func IsErrXactNotFound(err error) bool + func IsErrXactUsePrev(err error) bool + func IsFileAlreadyClosed(err error) bool + func IsNestedMpath(a string, la int, b string) (err error) + func IsNotExist(err error) bool + func IsObjNotExist(err error) bool + func IsStatusBadGateway(err error) (yes bool) + func IsStatusGone(err error) (yes bool) + func IsStatusNotFound(err error) (yes bool) + func IsStatusServiceUnavailable(err error) (yes bool) + func IterFields(v any, updf updateFunc, opts ...IterOpts) error + func KeepaliveRetryDuration(cs ...*Config) time.Duration + func LoadConfig(globalConfPath, localConfPath, daeRole string, config *Config) error + func MakeRangeHdr(start, length int64) (hdr http.Header) + func MatchItems(unescapedPath string, itemsAfter int, splitAfter bool, items []string) ([]string, error) + func NetworkCallWithRetry(args *RetryArgs) (err error) + func NetworkIsKnown(net string) bool + func NewBuffer() (buf *bytes.Buffer) + func NewClient(args TransportArgs) *http.Client + func NewTransport(args TransportArgs) *http.Transport + func NormalizeProvider(provider string) (p string, err error) + func ObjHasPrefix(objName, prefix string) bool + func OrigURLBck2Name(origURLBck string) (bckName string) + func ParsePort(p string) (int, error) + func ParseURLScheme(url string) (scheme, address string) + func PrependProtocol(url string, protocol ...string) string + func PromotedObjDstName(objfqn, dirfqn, givenObjName string) (objName string, err error) + func PropToHeader(prop string) string + func ReadBytes(r *http.Request) (b []byte, err error) + func ReadJSON(w http.ResponseWriter, r *http.Request, out any) (err error) + func SaveOverrideConfig(configDir string, toUpdate *ConfigToUpdate) error + func SetLogLevel(loglevel string) (err error) + func SetNodeName(sname string) + func SortLso(bckEntries LsoEntries) + func ToHeader(oah cos.OAH, hdr http.Header) + func TokenGreaterEQ(token, objName string) bool + func UpdateFieldValue(s any, name string, value any) error + func ValidateMpath(mpath string) (string, error) + func ValidatePort(port int) (int, error) + func ValidateRemAlias(alias string) (err error) + func WaitForFunc(f func() error, timeLong time.Duration) error + func WriteErr(w http.ResponseWriter, r *http.Request, err error, opts ...int) + func WriteErr405(w http.ResponseWriter, r *http.Request, methods ...string) + func WriteErrJSON(w http.ResponseWriter, r *http.Request, out any, err error) error + func WriteErrMsg(w http.ResponseWriter, r *http.Request, msg string, opts ...int) + type AllBsummResults []*BsummResult + func (s AllBsummResults) Aggregate(from *BsummResult) AllBsummResults + func (s AllBsummResults) Finalize(dsize map[string]uint64, testingEnv bool) + func (s AllBsummResults) Len() int + func (s AllBsummResults) Less(i, j int) bool + func (s AllBsummResults) Swap(i, j int) + type ArchiveBckMsg struct + ToBck Bck + func (msg *ArchiveBckMsg) Cname() string + type AuthConf struct + Enabled bool + Secret string + type AuthConfToUpdate struct + Enabled *bool + Secret *string + type BackendBckToUpdate struct + Name *string + Provider *string + type BackendConf struct + Conf map[string]any + Providers map[string]Ns + func (c *BackendConf) EqualClouds(o *BackendConf) bool + func (c *BackendConf) EqualRemAIS(o *BackendConf) bool + func (c *BackendConf) Get(provider string) (conf any) + func (c *BackendConf) MarshalJSON() (data []byte, err error) + func (c *BackendConf) Set(provider string, newConf any) + func (c *BackendConf) UnmarshalJSON(data []byte) error + func (c *BackendConf) Validate() (err error) + type BackendConfAIS map[string][]string + func (c BackendConfAIS) String() (s string) + type BackendConfHDFS struct + Addresses []string + UseDatanodeHostname bool + User string + type Bck struct + Name string + Ns Ns + Props *BucketProps + Provider string + func ParseBckObjectURI(uri string, opts ParseURIOpts) (bck Bck, objName string, err error) + func ParseUname(uname string) (b Bck, objName string) + func (b *Bck) AddToQuery(query url.Values) url.Values + func (b *Bck) AddUnameToQuery(query url.Values, uparam string) url.Values + func (b *Bck) Backend() *Bck + func (b *Bck) Cname(objname string) (s string) + func (b *Bck) Copy(src *Bck) + func (b *Bck) DisplayProvider() (p string) + func (b *Bck) HasProvider() bool + func (b *Bck) IsAIS() bool + func (b *Bck) IsCloud() bool + func (b *Bck) IsEmpty() bool + func (b *Bck) IsHDFS() bool + func (b *Bck) IsHTTP() bool + func (b *Bck) IsQuery() bool + func (b *Bck) IsRemote() bool + func (b *Bck) IsRemoteAIS() bool + func (b *Bck) Less(other *Bck) bool + func (b *Bck) MakeUname(objName string) string + func (b *Bck) RemoteBck() *Bck + func (b *Bck) Validate() (err error) + func (b *Bck) ValidateName() (err error) + func (b Bck) Equal(other *Bck) bool + func (b Bck) String() (s string) + func (bck *Bck) DefaultProps(c *ClusterConfig) *BucketProps + type Bcks []Bck + func (bcks Bcks) Equal(other Bcks) bool + func (bcks Bcks) Len() int + func (bcks Bcks) Less(i, j int) bool + func (bcks Bcks) Select(query QueryBcks) (filtered Bcks) + func (bcks Bcks) Swap(i, j int) + type BsummResult struct + func NewBsummResult(bck *Bck, totalDisksSize uint64) (bs *BsummResult) + type BucketProps struct + Access apc.AccessAttrs + BID uint64 + BackendBck Bck + Cksum CksumConf + Created int64 + EC ECConf + Extra ExtraProps + LRU LRUConf + Mirror MirrorConf + Provider string + Renamed string + Versioning VersionConf + WritePolicy WritePolicyConf + func (bp *BucketProps) Apply(propsToUpdate *BucketPropsToUpdate) + func (bp *BucketProps) Clone() *BucketProps + func (bp *BucketProps) Equal(other *BucketProps) (eq bool) + func (bp *BucketProps) SetProvider(provider string) + func (bp *BucketProps) Validate(targetCnt int) error + type BucketPropsToUpdate struct + Access *apc.AccessAttrs + BackendBck *BackendBckToUpdate + Cksum *CksumConfToUpdate + EC *ECConfToUpdate + Extra *ExtraToUpdate + Force bool + LRU *LRUConfToUpdate + Mirror *MirrorConfToUpdate + Versioning *VersionConfToUpdate + WritePolicy *WritePolicyConfToUpdate + func NewBucketPropsToUpdate(nvs cos.StrKVs) (props *BucketPropsToUpdate, err error) + type CksumConf struct + EnableReadRange bool + Type string + ValidateColdGet bool + ValidateObjMove bool + ValidateWarmGet bool + func (c *CksumConf) String() string + func (c *CksumConf) Validate() (err error) + func (c *CksumConf) ValidateAsProps(...any) (err error) + type CksumConfToUpdate struct + EnableReadRange *bool + Type *string + ValidateColdGet *bool + ValidateObjMove *bool + ValidateWarmGet *bool + type ClientConf struct + ListObjTimeout cos.Duration + Timeout cos.Duration + TimeoutLong cos.Duration + func (c *ClientConf) Validate() error + type ClientConfToUpdate struct + ListObjTimeout *cos.Duration + Timeout *cos.Duration + TimeoutLong *cos.Duration + type ClusterConfig struct + Auth AuthConf + Backend BackendConf + Cksum CksumConf + Client ClientConf + DSort DSortConf + Disk DiskConf + Downloader DownloaderConf + EC ECConf + Ext any + FSHC FSHCConf + Features feat.Flags + Keepalive KeepaliveConf + LRU LRUConf + LastUpdated string + Log LogConf + Memsys MemsysConf + Mirror MirrorConf + Net NetConf + Periodic PeriodConf + Proxy ProxyConf + Rebalance RebalanceConf + Resilver ResilverConf + Space SpaceConf + TCB TCBConf + Timeout TimeoutConf + Transport TransportConf + UUID string + Version int64 + Versioning VersionConf + WritePolicy WritePolicyConf + func (*ClusterConfig) JspOpts() jsp.Options + func (c *ClusterConfig) Apply(updateConf *ConfigToUpdate, asType string) error + func (c *ClusterConfig) String() string + type Config struct + func (c *Config) SetRole(role string) + func (c *Config) TestingEnv() bool + func (c *Config) UpdateClusterConfig(updateConf *ConfigToUpdate, asType string) (err error) + func (c *Config) Validate() error + type ConfigToUpdate struct + Auth *AuthConfToUpdate + Backend *BackendConf + Cksum *CksumConfToUpdate + Client *ClientConfToUpdate + DSort *DSortConfToUpdate + Disk *DiskConfToUpdate + Downloader *DownloaderConfToUpdate + EC *ECConfToUpdate + FSHC *FSHCConfToUpdate + FSP *FSPConf + Features *feat.Flags + Keepalive *KeepaliveConfToUpdate + LRU *LRUConfToUpdate + Log *LogConfToUpdate + Memsys *MemsysConfToUpdate + Mirror *MirrorConfToUpdate + Net *NetConfToUpdate + Periodic *PeriodConfToUpdate + Proxy *ProxyConfToUpdate + Rebalance *RebalanceConfToUpdate + Resilver *ResilverConfToUpdate + Space *SpaceConfToUpdate + TCB *TCBConfToUpdate + Timeout *TimeoutConfToUpdate + Transport *TransportConfToUpdate + Versioning *VersionConfToUpdate + WritePolicy *WritePolicyConfToUpdate + func (*ConfigToUpdate) JspOpts() jsp.Options + func (ctu *ConfigToUpdate) FillFromKVS(kvs []string) (err error) + func (ctu *ConfigToUpdate) FillFromQuery(query url.Values) error + func (ctu *ConfigToUpdate) Merge(update *ConfigToUpdate) + type DSortConf struct + CallTimeout cos.Duration + Compression string + DSorterMemThreshold string + DefaultMaxMemUsage string + DuplicatedRecords string + EKMMalformedLine string + EKMMissingKey string + MissingShards string + SbundleMult int + func (c *DSortConf) Validate() (err error) + func (c *DSortConf) ValidateWithOpts(allowEmpty bool) (err error) + type DSortConfToUpdate struct + CallTimeout *cos.Duration + Compression *string + DSorterMemThreshold *string + DefaultMaxMemUsage *string + DuplicatedRecords *string + EKMMalformedLine *string + EKMMissingKey *string + MissingShards *string + SbundleMult *int + type DiskConf struct + DiskUtilHighWM int64 + DiskUtilLowWM int64 + DiskUtilMaxWM int64 + IostatTimeLong cos.Duration + IostatTimeShort cos.Duration + func (c *DiskConf) Validate() (err error) + type DiskConfToUpdate struct + DiskUtilHighWM *int64 + DiskUtilLowWM *int64 + DiskUtilMaxWM *int64 + IostatTimeLong *cos.Duration + IostatTimeShort *cos.Duration + type DownloaderConf struct + Timeout cos.Duration + func (c *DownloaderConf) Validate() error + type DownloaderConfToUpdate struct + Timeout *cos.Duration + type ECConf struct + Compression string + DataSlices int + DiskOnly bool + Enabled bool + ObjSizeLimit int64 + ParitySlices int + SbundleMult int + func (c *ECConf) RequiredEncodeTargets() int + func (c *ECConf) RequiredRestoreTargets() int + func (c *ECConf) String() string + func (c *ECConf) Validate() error + func (c *ECConf) ValidateAsProps(arg ...any) (err error) + type ECConfToUpdate struct + Compression *string + DataSlices *int + DiskOnly *bool + Enabled *bool + ObjSizeLimit *int64 + ParitySlices *int + SbundleMult *int + type ETLErrCtx struct + ETLName string + PodName string + SvcName string + TID string + type ErrAborted struct + func AsErrAborted(err error) (errAborted *ErrAborted) + func NewErrAborted(what, ctx string, err error) *ErrAborted + func (e *ErrAborted) Error() (s string) + func (e *ErrAborted) Unwrap() (err error) + type ErrBckNotFound struct + func NewErrBckNotFound(bck *Bck) *ErrBckNotFound + func (e *ErrBckNotFound) Error() string + type ErrBucketAccessDenied struct + func NewBucketAccessDenied(bucket, oper string, aattrs apc.AccessAttrs) *ErrBucketAccessDenied + func (e *ErrBucketAccessDenied) Error() string + func (e *ErrBucketAccessDenied) String() string + type ErrBucketAlreadyExists struct + func NewErrBckAlreadyExists(bck *Bck) *ErrBucketAlreadyExists + func (e *ErrBucketAlreadyExists) Error() string + type ErrBucketIsBusy struct + func NewErrBckIsBusy(bck *Bck) *ErrBucketIsBusy + func (e *ErrBucketIsBusy) Error() string + type ErrCapacityExceeded struct + func NewErrCapacityExceeded(highWM int64, totalBytesUsed, totalBytes uint64, usedPct int32, oos bool) *ErrCapacityExceeded + func (e *ErrCapacityExceeded) Error() string + type ErrETL struct + Reason string + func NewErrETL(ctx *ETLErrCtx, format string, a ...any) *ErrETL + func (e *ErrETL) Error() string + func (e *ErrETL) WithContext(ctx *ETLErrCtx) *ErrETL + func (e *ErrETL) WithPodName(name string) *ErrETL + type ErrFailedTo struct + func NewErrFailedTo(actor any, action string, what any, err error, errCode ...int) *ErrFailedTo + func (e *ErrFailedTo) Error() string + func (e *ErrFailedTo) Unwrap() (err error) + type ErrHTTP struct + Caller string + Message string + Method string + Node string + RemoteAddr string + Status int + TypeCode string + URLPath string + func Err2HTTPErr(err error) *ErrHTTP + func InitErrHTTP(r *http.Request, err error, errCode int) (e *ErrHTTP) + func NewErrHTTP(r *http.Request, err error, errCode int) (e *ErrHTTP) + func S2HTTPErr(r *http.Request, msg string, status int) *ErrHTTP + func (e *ErrHTTP) Error() (s string) + type ErrInitBackend struct + Provider string + func (e *ErrInitBackend) Error() string + type ErrInvalidBackendProvider struct + func (*ErrInvalidBackendProvider) Is(target error) bool + func (e *ErrInvalidBackendProvider) Error() string + type ErrInvalidCksum struct + func NewErrInvalidCksum(eHash, aHash string) *ErrInvalidCksum + func (e *ErrInvalidCksum) Error() string + func (e *ErrInvalidCksum) Expected() string + type ErrInvalidFSPathsConf struct + func NewErrInvalidFSPathsConf(err error) *ErrInvalidFSPathsConf + func (e *ErrInvalidFSPathsConf) Error() string + func (e *ErrInvalidFSPathsConf) Unwrap() (err error) + type ErrInvalidMountpath struct + func NewErrInvalidaMountpath(mpath, cause string) *ErrInvalidMountpath + func (e *ErrInvalidMountpath) Error() string + type ErrLimitedCoexistence struct + func NewErrLimitedCoexistence(node, xaction, action, detail string) *ErrLimitedCoexistence + func (e *ErrLimitedCoexistence) Error() string + type ErrLmetaCorrupted struct + func NewErrLmetaCorrupted(err error) *ErrLmetaCorrupted + func (e *ErrLmetaCorrupted) Error() string + func (e *ErrLmetaCorrupted) Unwrap() (err error) + type ErrLmetaNotFound struct + func NewErrLmetaNotFound(err error) *ErrLmetaNotFound + func (e *ErrLmetaNotFound) Error() string + func (e *ErrLmetaNotFound) Unwrap() (err error) + type ErrMissingBackend struct + Msg string + Provider string + func (e *ErrMissingBackend) Error() string + type ErrMountpathNotFound struct + func NewErrMountpathNotFound(mpath, fqn string, disabled bool) *ErrMountpathNotFound + func (e *ErrMountpathNotFound) Error() string + type ErrNoNodes struct + func NewErrNoNodes(role string, mmcount int) *ErrNoNodes + func (e *ErrNoNodes) Error() (s string) + type ErrNotImpl struct + func NewErrNotImpl(action, what string) *ErrNotImpl + func (e *ErrNotImpl) Error() string + type ErrObjDefunct struct + func NewErrObjDefunct(name string, d1, d2 uint64) *ErrObjDefunct + func (e *ErrObjDefunct) Error() string + type ErrObjectAccessDenied struct + func NewObjectAccessDenied(object, oper string, aattrs apc.AccessAttrs) *ErrObjectAccessDenied + func (e *ErrObjectAccessDenied) Error() string + func (e *ErrObjectAccessDenied) String() string + type ErrRemoteBckNotFound struct + func NewErrRemoteBckNotFound(bck *Bck) *ErrRemoteBckNotFound + func (e *ErrRemoteBckNotFound) Error() string + type ErrRemoteBucketOffline struct + func NewErrRemoteBckOffline(bck *Bck) *ErrRemoteBucketOffline + func (e *ErrRemoteBucketOffline) Error() string + type ErrSoft struct + func NewErrSoft(what string) *ErrSoft + func (e *ErrSoft) Error() string + type ErrStreamTerminated struct + func NewErrStreamTerminated(stream string, err error, reason, detail string) *ErrStreamTerminated + func (e *ErrStreamTerminated) Error() string + func (e *ErrStreamTerminated) Unwrap() (err error) + type ErrUnsupp struct + func NewErrUnsupp(action, what string) *ErrUnsupp + func (e *ErrUnsupp) Error() string + type ErrXactNotFound struct + func NewErrXactNotFoundError(cause string) *ErrXactNotFound + func (e *ErrXactNotFound) Error() string + type ErrXactTgtInMaint struct + func NewErrXactTgtInMaint(xaction, tname string) *ErrXactTgtInMaint + func (e *ErrXactTgtInMaint) Error() string + type ErrXactUsePrev struct + func NewErrXactUsePrev(xaction string) *ErrXactUsePrev + func (e *ErrXactUsePrev) Error() string + type ExtraProps struct + AWS ExtraPropsAWS + HDFS ExtraPropsHDFS + HTTP ExtraPropsHTTP + func (c *ExtraProps) ValidateAsProps(arg ...any) error + type ExtraPropsAWS struct + AccessKeyID string + CloudRegion string + Endpoint string + SecretAccessKey string + type ExtraPropsAWSToUpdate struct + AccessKeyID *string + CloudRegion *string + Endpoint *string + SecretAccessKey *string + type ExtraPropsHDFS struct + RefDirectory string + type ExtraPropsHDFSToUpdate struct + RefDirectory *string + type ExtraPropsHTTP struct + OrigURLBck string + type ExtraPropsHTTPToUpdate struct + OrigURLBck *string + type ExtraToUpdate struct + AWS *ExtraPropsAWSToUpdate + HDFS *ExtraPropsHDFSToUpdate + HTTP *ExtraPropsHTTPToUpdate + type FSHCConf struct + Enabled bool + ErrorLimit int + TestFileCount int + type FSHCConfToUpdate struct + Enabled *bool + ErrorLimit *int + TestFileCount *int + type FSPConf struct + Paths cos.StrSet + func (c *FSPConf) MarshalJSON() (data []byte, err error) + func (c *FSPConf) UnmarshalJSON(data []byte) (err error) + func (c *FSPConf) Validate(contextConfig *Config) error + type HTTPBckObj struct + Bck Bck + ObjName string + OrigURLBck string + func NewHTTPObj(u *url.URL) *HTTPBckObj + func NewHTTPObjPath(rawURL string) (*HTTPBckObj, error) + type HTTPConf struct + Certificate string + Chunked bool + Key string + Proto string + ReadBufferSize int + SkipVerify bool + UseHTTPS bool + WriteBufferSize int + type HTTPConfToUpdate struct + Certificate *string + Chunked *bool + Key *string + ReadBufferSize *int + SkipVerify *bool + UseHTTPS *bool + WriteBufferSize *int + type HreqArgs struct + Base string + Body []byte + BodyR io.Reader + Header http.Header + Method string + Path string + Query url.Values + RawQuery string + func AllocHra() (a *HreqArgs) + func (u *HreqArgs) Req() (*http.Request, error) + func (u *HreqArgs) ReqWithCancel() (*http.Request, context.Context, context.CancelFunc, error) + func (u *HreqArgs) ReqWithTimeout(timeout time.Duration) (*http.Request, context.Context, context.CancelFunc, error) + func (u *HreqArgs) URL() string + type IterField interface + SetValue func(v any, force ...bool) error + String func() string + Value func() any + type IterOpts struct + Allowed string + OnlyRead bool + VisitAll bool + type KeepaliveConf struct + Proxy KeepaliveTrackerConf + RetryFactor uint8 + Target KeepaliveTrackerConf + func (c *KeepaliveConf) Validate() (err error) + type KeepaliveConfToUpdate struct + Proxy *KeepaliveTrackerConfToUpdate + RetryFactor *uint8 + Target *KeepaliveTrackerConfToUpdate + type KeepaliveTrackerConf struct + Factor uint8 + Interval cos.Duration + Name string + type KeepaliveTrackerConfToUpdate struct + Factor *uint8 + Interval *cos.Duration + Name *string + type L4Conf struct + Proto string + SndRcvBufSize int + type LRUConf struct + CapacityUpdTime cos.Duration + DontEvictTime cos.Duration + Enabled bool + func (c *LRUConf) String() string + func (c *LRUConf) Validate() (err error) + type LRUConfToUpdate struct + CapacityUpdTime *cos.Duration + DontEvictTime *cos.Duration + Enabled *bool + type LocalConfig struct + ConfigDir string + FSP FSPConf + HostNet LocalNetConfig + LogDir string + TestFSP TestFSPConf + func (*LocalConfig) JspOpts() jsp.Options + func (c *LocalConfig) AddPath(mpath string) + func (c *LocalConfig) DelPath(mpath string) + func (c *LocalConfig) TestingEnv() bool + type LocalNetConfig struct + Hostname string + HostnameIntraControl string + HostnameIntraData string + Port int + PortIntraControl int + PortIntraData int + UseIntraControl bool + UseIntraData bool + func (c *LocalNetConfig) Validate(contextConfig *Config) (err error) + type LogConf struct + FlushTime cos.Duration + Level string + MaxSize cos.SizeIEC + MaxTotal cos.SizeIEC + StatsTime cos.Duration + func (c *LogConf) Validate() error + type LogConfToUpdate struct + FlushTime *cos.Duration + Level *string + MaxSize *cos.SizeIEC + MaxTotal *cos.SizeIEC + StatsTime *cos.Duration + type LsoEntries []*LsoEntry + type LsoEntry struct + Atime string + Checksum string + Copies int16 + Custom string + Flags uint16 + Location string + Name string + Size int64 + Version string + func DedupLso(entries LsoEntries, maxSize uint) ([]*LsoEntry, string) + func (be *LsoEntry) CheckExists() bool + func (be *LsoEntry) CopyWithProps(propsSet cos.StrSet) (ne *LsoEntry) + func (be *LsoEntry) IsInsideArch() bool + func (be *LsoEntry) IsStatusOK() bool + func (be *LsoEntry) SetPresent() + func (be *LsoEntry) Status() uint16 + func (be *LsoEntry) String() string + func (z *LsoEntry) DecodeMsg(dc *msgp.Reader) (err error) + func (z *LsoEntry) EncodeMsg(en *msgp.Writer) (err error) + func (z *LsoEntry) Msgsize() (s int) + type LsoResult struct + ContinuationToken string + Entries []*LsoEntry + Flags uint32 + UUID string + func ConcatLso(lists []*LsoResult, maxSize uint) (objs *LsoResult) + func MergeLso(lists []*LsoResult, maxSize uint) *LsoResult + func (z *LsoResult) DecodeMsg(dc *msgp.Reader) (err error) + func (z *LsoResult) EncodeMsg(en *msgp.Writer) (err error) + func (z *LsoResult) Msgsize() (s int) + type MemsysConf struct + DefaultBufSize cos.SizeIEC + HousekeepTime cos.Duration + MinFree cos.SizeIEC + MinPctFree int + MinPctTotal int + SizeToGC cos.SizeIEC + func (c *MemsysConf) Validate() (err error) + type MemsysConfToUpdate struct + DefaultBufSize *cos.SizeIEC + HousekeepTime *cos.Duration + MinFree *cos.SizeIEC + MinPctFree *int + MinPctTotal *int + SizeToGC *cos.SizeIEC + type MirrorConf struct + Burst int + Copies int64 + Enabled bool + func (c *MirrorConf) String() string + func (c *MirrorConf) Validate() error + func (c *MirrorConf) ValidateAsProps(...any) error + type MirrorConfToUpdate struct + Burst *int + Copies *int64 + Enabled *bool + type NetConf struct + HTTP HTTPConf + L4 L4Conf + func (c *NetConf) Validate() (err error) + type NetConfToUpdate struct + HTTP *HTTPConfToUpdate + type Ns struct + Name string + UUID string + func ParseNsUname(s string) (n Ns) + func (n Ns) IsAnyRemote() bool + func (n Ns) IsGlobal() bool + func (n Ns) IsRemote() bool + func (n Ns) String() (res string) + func (n Ns) Uname() string + type OWT int + const OwtFinalize + const OwtGet + const OwtGetLock + const OwtGetPrefetchLock + const OwtGetTryLock + const OwtMigrate + const OwtPromote + const OwtPut + func (owt *OWT) FromS(s string) + func (owt OWT) String() (s string) + func (owt OWT) ToS() (s string) + type ObjAttrs struct + Atime int64 + Cksum *cos.Cksum + CustomMD cos.StrKVs + Size int64 + Ver string + func (oa *ObjAttrs) AtimeUnix() int64 + func (oa *ObjAttrs) Checksum() *cos.Cksum + func (oa *ObjAttrs) CopyFrom(oah cos.OAH, skipCksum ...bool) + func (oa *ObjAttrs) DelCustomKeys(keys ...string) + func (oa *ObjAttrs) Equal(rem cos.OAH) (equal bool) + func (oa *ObjAttrs) FromHeader(hdr http.Header) (cksum *cos.Cksum) + func (oa *ObjAttrs) GetCustomKey(key string) (val string, exists bool) + func (oa *ObjAttrs) GetCustomMD() cos.StrKVs + func (oa *ObjAttrs) SetCksum(ty, val string) + func (oa *ObjAttrs) SetCustomKey(k, v string) + func (oa *ObjAttrs) SetCustomMD(md cos.StrKVs) + func (oa *ObjAttrs) SetSize(size int64) + func (oa *ObjAttrs) SizeBytes(_ ...bool) int64 + func (oa *ObjAttrs) String() string + func (oa *ObjAttrs) Version(_ ...bool) string + type ObjectProps struct + Bck Bck + EC struct{ ... } + Location string + Mirror struct{ ... } + Name string + Present bool + type ParseURIOpts struct + DefaultProvider string + IsQuery bool + type PeriodConf struct + NotifTime cos.Duration + RetrySyncTime cos.Duration + StatsTime cos.Duration + func (c *PeriodConf) Validate() error + type PeriodConfToUpdate struct + NotifTime *cos.Duration + RetrySyncTime *cos.Duration + StatsTime *cos.Duration + type PropsValidator interface + ValidateAsProps func(arg ...any) error + type ProxyConf struct + DiscoveryURL string + NonElectable bool + OriginalURL string + PrimaryURL string + type ProxyConfToUpdate struct + DiscoveryURL *string + NonElectable *bool + OriginalURL *string + PrimaryURL *string + type QueryBcks Bck + func (qbck *QueryBcks) AddToQuery(query url.Values) url.Values + func (qbck *QueryBcks) DisplayProvider() string + func (qbck *QueryBcks) IsAIS() bool + func (qbck *QueryBcks) IsBucket() bool + func (qbck *QueryBcks) IsCloud() bool + func (qbck *QueryBcks) IsEmpty() bool + func (qbck *QueryBcks) IsHDFS() bool + func (qbck *QueryBcks) IsHTTP() bool + func (qbck *QueryBcks) IsRemoteAIS() bool + func (qbck *QueryBcks) Validate() (err error) + func (qbck QueryBcks) Contains(other *Bck) bool + func (qbck QueryBcks) Equal(bck *Bck) bool + func (qbck QueryBcks) String() string + type RebalanceConf struct + Compression string + DestRetryTime cos.Duration + Enabled bool + SbundleMult int + func (c *RebalanceConf) String() string + func (c *RebalanceConf) Validate() error + type RebalanceConfToUpdate struct + Compression *string + DestRetryTime *cos.Duration + Enabled *bool + SbundleMult *int + type ResilverConf struct + Enabled bool + func (*ResilverConf) Validate() error + func (c *ResilverConf) String() string + type ResilverConfToUpdate struct + Enabled *bool + type RetryArgs struct + Action string + BackOff bool + Call func() (int, error) + Caller string + HardErr uint + IsClient bool + IsFatal func(error) bool + Sleep time.Duration + SoftErr uint + Verbosity int + type SpaceConf struct + CleanupWM int64 + HighWM int64 + LowWM int64 + OOS int64 + func (c *SpaceConf) String() string + func (c *SpaceConf) Validate() (err error) + func (c *SpaceConf) ValidateAsProps(...any) error + type SpaceConfToUpdate struct + CleanupWM *int64 + HighWM *int64 + LowWM *int64 + OOS *int64 + type TCBConf struct + Compression string + SbundleMult int + func (c *TCBConf) Validate() error + type TCBConfToUpdate struct + Compression *string + SbundleMult *int + type TCObjsMsg struct + ToBck Bck + type TestFSPConf struct + Count int + Instance int + Root string + func (c *TestFSPConf) Validate(contextConfig *Config) (err error) + func (c *TestFSPConf) ValidateMpath(p string) (err error) + type TimeoutConf struct + CplaneOperation cos.Duration + JoinAtStartup cos.Duration + MaxHostBusy cos.Duration + MaxKeepalive cos.Duration + SendFile cos.Duration + Startup cos.Duration + func (c *TimeoutConf) Validate() error + type TimeoutConfToUpdate struct + CplaneOperation *cos.Duration + JoinAtStartup *cos.Duration + MaxHostBusy *cos.Duration + MaxKeepalive *cos.Duration + SendFile *cos.Duration + Startup *cos.Duration + type TransportArgs struct + DialTimeout time.Duration + IdleConnTimeout time.Duration + IdleConnsPerHost int + MaxIdleConns int + ReadBufferSize int + SkipVerify bool + SndRcvBufSize int + Timeout time.Duration + UseHTTPProxyEnv bool + UseHTTPS bool + WriteBufferSize int + func (args *TransportArgs) ConnControl(_ syscall.RawConn) (cntl func(fd uintptr)) + type TransportConf struct + Burst int + IdleTeardown cos.Duration + LZ4BlockMaxSize cos.SizeIEC + LZ4FrameChecksum bool + MaxHeaderSize int + QuiesceTime cos.Duration + func (c *TransportConf) Validate() (err error) + type TransportConfToUpdate struct + Burst *int + IdleTeardown *cos.Duration + LZ4BlockMaxSize *cos.SizeIEC + LZ4FrameChecksum *bool + MaxHeaderSize *int + QuiesceTime *cos.Duration + type Validator interface + Validate func() error + type VersionConf struct + Enabled bool + ValidateWarmGet bool + func (c *VersionConf) String() string + func (c *VersionConf) Validate() error + type VersionConfToUpdate struct + Enabled *bool + ValidateWarmGet *bool + type WritePolicyConf struct + Data apc.WritePolicy + MD apc.WritePolicy + func (c *WritePolicyConf) Validate() (err error) + func (c *WritePolicyConf) ValidateAsProps(...any) error + type WritePolicyConfToUpdate struct + Data *apc.WritePolicy + MD *apc.WritePolicy
Go to main page