cmn

package

Go to main page

Versions in this module

v1

v1.3.25

Oct 6, 2024

Changes in this version

type ErrInvalidObjName

+ func ValidOname(name string) *ErrInvalidObjName

+ func ValidateOname(name string) (err *ErrInvalidObjName)

+ type ErrInvalidPrefix struct

+ func (e *ErrInvalidPrefix) Error() string

type ErrUnsupp

+ func NewErrUnsuppErr(err error) *ErrUnsupp

v1.3.24

Sep 27, 2024

Changes in this version

+ const DfltTransportBurst

+ const DfltTransportHeader

+ const EcStreamsDflt

+ const EcStreamsEver

+ const EcStreamsMini

+ const IOErrTimeDflt

+ const IOErrsLimit

+ const MaxTransportBurst

+ const MaxTransportHeader

+ const MetaverChunk

+ func CopyProps(src, dst any, asType string) error

+ func InitObjProps2Hdr()

+ func IsErrGetCap(err error) bool

+ func IsErrMpathCheck(err error) bool

+ func IsErrMpathNewDisk(err error) bool

+ func IsErrMpathNotFound(err error) bool

+ func IsErrWarning(err error) bool

+ func NewErrRemoteMetadataMismatch(cause error) error

type Bck

+ func (b *Bck) IsBuiltTagged() bool

+ func (b *Bck) IsHT() bool

type ErrETL

+ func NewErrETLf(ctx *ETLErrCtx, format string, a ...any) *ErrETL

+ type ErrGetCap struct

+ func NewErrGetCap(err error) *ErrGetCap

+ func (e *ErrGetCap) Error() string

+ type ErrMpathCheck struct

+ func NewErrMpathCheck(err error) *ErrMpathCheck

+ func (e *ErrMpathCheck) Error() string

+ type ErrMpathLostDisk struct

+ func NewErrMpathLostDisk(mpath, fs, lostd string, disks, fsdisks []string) *ErrMpathLostDisk

+ func (e *ErrMpathLostDisk) Error() string

+ type ErrMpathNewDisk struct

+ func NewErrMpathNewDisk(mpath, fs string, disks, fsdisks []string) *ErrMpathNewDisk

+ func (e *ErrMpathNewDisk) Error() string

+ type ErrMpathNoDisks struct

+ func NewErrMpathNoDisks(mpath, fs string, err error) *ErrMpathNoDisks

+ func (e *ErrMpathNoDisks) Error() string

+ type ErrMpathNotFound struct

+ func NewErrMpathNotFound(mpath, fqn string, disabled bool) *ErrMpathNotFound

+ func (e *ErrMpathNotFound) Disabled() bool

+ func (e *ErrMpathNotFound) Error() string

+ func (e *ErrMpathNotFound) Mpath() string

+ type ErrRemoteMetadataMismatch struct

+ func (e *ErrRemoteMetadataMismatch) Error() string

+ type ErrWarning struct

+ func NewErrWarning(what string) *ErrWarning

+ func (e *ErrWarning) Error() string

type FSHCConf

+ HardErrs int

+ IOErrTime cos.Duration

+ IOErrs int

+ func (c *FSHCConf) UnmarshalJSON(data []byte) (err error)

+ func (c *FSHCConf) Validate() error

+ type FSHCConfRC3 FSHCConf

type FSHCConfToSet

+ HardErrs *int

+ IOErrTime *cos.Duration

+ IOErrs *int

type ObjAttrs

+ func (oa *ObjAttrs) CheckEq(rem cos.OAH) error

+ func (oa *ObjAttrs) CopyVersion(oah cos.OAH)

+ func (oa *ObjAttrs) Lsize(_ ...bool) int64

+ func (oa *ObjAttrs) SetVersion(ver string)

+ func (oa *ObjAttrs) VersionPtr() *string

type QueryBcks

+ func (qbck *QueryBcks) IsHT() bool

+ type TCOMsg struct

+ ToBck Bck

type TimeoutConf

+ EcStreams cos.Duration

type TimeoutConfToSet

+ EcStreams *cos.Duration

v1.3.23

May 27, 2024

Changes in this version

+ var AllowSharedDisksAndNoDisks bool

+ func Host2IP(host string) (net.IP, error)

+ func ParseHost2IP(host string) (net.IP, error)

type Bprops

+ Features feat.Flags

type BpropsToSet

+ Features *feat.Flags

+ type FSPConfV322 struct

+ Paths cos.StrSet

+ func (c *FSPConfV322) MarshalJSON() ([]byte, error)

type LogConf

+ ToStderr bool

type LogConfToSet

+ ToStderr *bool

+ type LsoEnt struct

+ Atime string

+ Checksum string

+ Copies int16

+ Custom string

+ Flags uint16

+ Location string

+ Name string

+ Size int64

+ Version string

+ func HandleNoRecurs(prefix, relPath string) (*LsoEnt, error)

+ func (be *LsoEnt) CopyWithProps(propsSet cos.StrSet) (ne *LsoEnt)

+ func (be *LsoEnt) IsDir() bool

+ func (be *LsoEnt) IsInsideArch() bool

+ func (be *LsoEnt) IsListedArch() bool

+ func (be *LsoEnt) IsPresent() bool

+ func (be *LsoEnt) IsStatusOK() bool

+ func (be *LsoEnt) IsVerChanged() bool

+ func (be *LsoEnt) IsVerRemoved() bool

+ func (be *LsoEnt) SetPresent()

+ func (be *LsoEnt) SetVerChanged()

+ func (be *LsoEnt) SetVerRemoved()

+ func (be *LsoEnt) Status() uint16

+ func (be *LsoEnt) String() string

+ func (z *LsoEnt) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *LsoEnt) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *LsoEnt) Msgsize() (s int)

+ type LsoRes struct

+ ContinuationToken string

+ Entries LsoEntries

+ Flags uint32

+ UUID string

+ func (z *LsoRes) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z *LsoRes) EncodeMsg(en *msgp.Writer) (err error)

+ func (z *LsoRes) Msgsize() (s int)

v1.3.22

Feb 25, 2024

Changes in this version

+ const AwsDefaultRegion

+ const HostnameListSepa

+ const IterFieldNameSepa

+ const ObjSizeToAlwaysReplicate

+ func IsErrRangeNotSatisfiable(err error) bool

+ func IsS3MultipartEtag(etag string) bool

+ func MaxParallelism() int

+ func NewDefaultClients(timeout time.Duration) (clientH, clientTLS *http.Client)

+ func ParseReadHeaderTimeout() (_ time.Duration, isSet bool)

+ func S2CustomMD(custom, version string) (md cos.StrKVs)

+ func UnquoteCEV(val string) string

type Bck

+ func (b *Bck) HasVersioningMD() bool

+ type ErrInvalidObjName struct

+ func ValidateObjName(name string) (err *ErrInvalidObjName)

+ func (e *ErrInvalidObjName) Error() string

+ type ErrNotRemoteBck struct

+ func ValidateRemoteBck(act string, bck *Bck) (err *ErrNotRemoteBck)

+ func (e *ErrNotRemoteBck) Error() string

+ type ErrRangeNotSatisfiable struct

+ func NewErrRangeNotSatisfiable(err error, ranges []string, size int64) *ErrRangeNotSatisfiable

+ func (e *ErrRangeNotSatisfiable) Error() string

type ExtraPropsAWS

+ MaxPageSize uint

type ExtraPropsAWSToSet

+ MaxPageSize *uint

type HTTPConf

+ func (c *HTTPConf) Validate() error

type LsoEntries

+ func (z *LsoEntries) DecodeMsg(dc *msgp.Reader) (err error)

+ func (z LsoEntries) EncodeMsg(en *msgp.Writer) (err error)

+ func (z LsoEntries) Msgsize() (s int)

type LsoEntry

+ func (be *LsoEntry) IsVerChanged() bool

+ func (be *LsoEntry) IsVerRemoved() bool

+ func (be *LsoEntry) SetVerChanged()

+ func (be *LsoEntry) SetVerRemoved()

type OWT

+ const OwtArchive

+ const OwtCopy

+ const OwtNone

+ const OwtRebalance

+ const OwtTransform

type ObjAttrs

+ func (oa *ObjAttrs) FromLsoEntry(e *LsoEntry)

type VersionConf

+ Sync bool

type VersionConfToSet

+ Sync *bool

v1.3.21

Nov 5, 2023

Changes in this version

+ var Rom readMostly

+ func EnvToTLS(sargs *TLSArgs)

+ func MaxBcastParallel() int

+ func NewClientTLS(cargs TransportArgs, sargs TLSArgs) *http.Client

+ func NewIntraClientTLS(cargs TransportArgs, config *Config) *http.Client

+ func NewTLS(sargs TLSArgs) (tlsConf *tls.Config, _ error)

+ type AuthConfToSet struct

+ Enabled *bool

+ Secret *string

+ type BackendBckToSet struct

+ Name *string

+ Provider *string

type Bck

+ func (b *Bck) LenUnameGlob(objName string) int

+ func (b *Bck) NewQuery() (q url.Values)

+ type Bprops 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 *Bprops) Apply(propsToSet *BpropsToSet)

+ func (bp *Bprops) Clone() *Bprops

+ func (bp *Bprops) Equal(other *Bprops) (eq bool)

+ func (bp *Bprops) SetProvider(provider string)

+ func (bp *Bprops) Validate(targetCnt int) error

+ type BpropsToSet struct

+ Access *apc.AccessAttrs

+ BackendBck *BackendBckToSet

+ Cksum *CksumConfToSet

+ EC *ECConfToSet

+ Extra *ExtraToSet

+ Force bool

+ LRU *LRUConfToSet

+ Mirror *MirrorConfToSet

+ Versioning *VersionConfToSet

+ WritePolicy *WritePolicyConfToSet

+ func NewBpropsToSet(nvs cos.StrKVs) (props *BpropsToSet, err error)

+ type CksumConfToSet struct

+ EnableReadRange *bool

+ Type *string

+ ValidateColdGet *bool

+ ValidateObjMove *bool

+ ValidateWarmGet *bool

+ type ClientConfToSet struct

+ ListObjTimeout *cos.Duration

+ Timeout *cos.Duration

+ TimeoutLong *cos.Duration

type ClusterConfig

+ Dsort DsortConf

+ type ConfigToSet struct

+ Auth *AuthConfToSet

+ Backend *BackendConf

+ Cksum *CksumConfToSet

+ Client *ClientConfToSet

+ Disk *DiskConfToSet

+ Downloader *DownloaderConfToSet

+ Dsort *DsortConfToSet

+ EC *ECConfToSet

+ FSHC *FSHCConfToSet

+ FSP *FSPConf

+ Features *feat.Flags

+ Keepalive *KeepaliveConfToSet

+ LRU *LRUConfToSet

+ Log *LogConfToSet

+ Memsys *MemsysConfToSet

+ Mirror *MirrorConfToSet

+ Net *NetConfToSet

+ Periodic *PeriodConfToSet

+ Proxy *ProxyConfToSet

+ Rebalance *RebalanceConfToSet

+ Resilver *ResilverConfToSet

+ Space *SpaceConfToSet

+ TCB *TCBConfToSet

+ Timeout *TimeoutConfToSet

+ Transport *TransportConfToSet

+ Versioning *VersionConfToSet

+ WritePolicy *WritePolicyConfToSet

+ func (*ConfigToSet) JspOpts() jsp.Options

+ func (ctu *ConfigToSet) FillFromKVS(kvs []string) (err error)

+ func (ctu *ConfigToSet) FillFromQuery(query url.Values) error

+ func (ctu *ConfigToSet) Merge(update *ConfigToSet)

+ type DiskConfToSet struct

+ DiskUtilHighWM *int64

+ DiskUtilLowWM *int64

+ DiskUtilMaxWM *int64

+ IostatTimeLong *cos.Duration

+ IostatTimeShort *cos.Duration

+ type DownloaderConfToSet struct

+ Timeout *cos.Duration

+ type DsortConf struct

+ CallTimeout cos.Duration

+ Compression string

+ DefaultMaxMemUsage string

+ DsorterMemThreshold 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 DsortConfToSet struct

+ CallTimeout *cos.Duration

+ Compression *string

+ DefaultMaxMemUsage *string

+ DsorterMemThreshold *string

+ DuplicatedRecords *string

+ EKMMalformedLine *string

+ EKMMissingKey *string

+ MissingShards *string

+ SbundleMult *int

+ type ECConfToSet struct

+ Compression *string

+ DataSlices *int

+ DiskOnly *bool

+ Enabled *bool

+ ObjSizeLimit *int64

+ ParitySlices *int

+ SbundleMult *int

+ type ErrBusy struct

+ func NewErrBusy(what string, name fmt.Stringer, detail string) *ErrBusy

+ func (e *ErrBusy) Error() string

+ type ExtraPropsAWSToSet struct

+ CloudRegion *string

+ Endpoint *string

+ Profile *string

+ type ExtraPropsHDFSToSet struct

+ RefDirectory *string

+ type ExtraPropsHTTPToSet struct

+ OrigURLBck *string

+ type ExtraToSet struct

+ AWS *ExtraPropsAWSToSet

+ HDFS *ExtraPropsHDFSToSet

+ HTTP *ExtraPropsHTTPToSet

+ type FSHCConfToSet struct

+ Enabled *bool

+ ErrorLimit *int

+ TestFileCount *int

type HTTPConf

+ CertKey string

+ ClientAuthTLS int

+ ClientCA string

+ ServerNameTLS string

+ SkipVerifyCrt bool

+ func (c *HTTPConf) ToTLS() TLSArgs

+ type HTTPConfToSet struct

+ CertKey *string

+ Certificate *string

+ Chunked *bool

+ ClientAuthTLS *int

+ ClientCA *string

+ ReadBufferSize *int

+ ServerNameTLS *string

+ SkipVerifyCrt *bool

+ UseHTTPS *bool

+ WriteBufferSize *int

+ type KeepaliveConfToSet struct

+ Proxy *KeepaliveTrackerConfToSet

+ RetryFactor *uint8

+ Target *KeepaliveTrackerConfToSet

+ type KeepaliveTrackerConfToSet struct

+ Factor *uint8

+ Interval *cos.Duration

+ Name *string

+ type LRUConfToSet struct

+ CapacityUpdTime *cos.Duration

+ DontEvictTime *cos.Duration

+ Enabled *bool

+ type LogConfToSet struct

+ FlushTime *cos.Duration

+ Level *cos.LogLevel

+ MaxSize *cos.SizeIEC

+ MaxTotal *cos.SizeIEC

+ StatsTime *cos.Duration

type LsoEntry

+ func (be *LsoEntry) IsPresent() bool

+ type MemsysConfToSet struct

+ DefaultBufSize *cos.SizeIEC

+ HousekeepTime *cos.Duration

+ MinFree *cos.SizeIEC

+ MinPctFree *int

+ MinPctTotal *int

+ SizeToGC *cos.SizeIEC

+ type MirrorConfToSet struct

+ Burst *int

+ Copies *int64

+ Enabled *bool

+ type NetConfToSet struct

+ HTTP *HTTPConfToSet

type Ns

+ func (n Ns) Len() int

+ type PeriodConfToSet struct

+ NotifTime *cos.Duration

+ RetrySyncTime *cos.Duration

+ StatsTime *cos.Duration

+ type ProxyConfToSet struct

+ DiscoveryURL *string

+ NonElectable *bool

+ OriginalURL *string

+ PrimaryURL *string

type QueryBcks

+ func (qbck *QueryBcks) NewQuery() url.Values

+ type RebalanceConfToSet struct

+ Compression *string

+ DestRetryTime *cos.Duration

+ Enabled *bool

+ SbundleMult *int

+ type ResilverConfToSet struct

+ Enabled *bool

+ type SpaceConfToSet struct

+ CleanupWM *int64

+ HighWM *int64

+ LowWM *int64

+ OOS *int64

+ type TCBConfToSet struct

+ Compression *string

+ SbundleMult *int

+ type TLSArgs struct

+ Certificate string

+ ClientCA string

+ Key string

+ SkipVerify bool

+ type TimeoutConfToSet struct

+ CplaneOperation *cos.Duration

+ JoinAtStartup *cos.Duration

+ MaxHostBusy *cos.Duration

+ MaxKeepalive *cos.Duration

+ SendFile *cos.Duration

+ Startup *cos.Duration

+ type TransportConfToSet struct

+ Burst *int

+ IdleTeardown *cos.Duration

+ LZ4BlockMaxSize *cos.SizeIEC

+ LZ4FrameChecksum *bool

+ MaxHeaderSize *int

+ QuiesceTime *cos.Duration

+ type VersionConfToSet struct

+ Enabled *bool

+ ValidateWarmGet *bool

+ type WritePolicyConfToSet struct

+ Data *apc.WritePolicy

+ MD *apc.WritePolicy

v1.3.20

Sep 12, 2023

v1.3.19

Aug 29, 2023

Changes in this version

+ const StartupMayTimeout

+ func IsErrCapExceeded(err error) bool

+ func TypeCodeHTTPErr(s string) (tcode string)

+ type ErrCapExceeded struct

+ func NewErrCapExceeded(totalBytesUsed, totalBytes uint64, highWM, cleanupWM int64, usedPct int32, ...) *ErrCapExceeded

+ func (e *ErrCapExceeded) Error() string

type ExtraPropsAWS

+ Profile string

type ExtraPropsAWSToUpdate

+ Profile *string

v1.3.18

Jul 9, 2023

Changes in this version

+ const BadSmapPrefix

+ const PropBackendBck

+ const PropBackendBckName

+ const PropBackendBckProvider

+ const PropBucketAccessAttrs

+ const PropBucketCreated

+ const PropBucketVerEnabled

+ func FastV(verbosity, fl int) bool

+ func FreeBuffer(buf *bytes.Buffer)

+ func InitErrs(a string, b func(error))

+ func IsErrXactUsePrev(err error) bool

+ func NewBuffer() (buf *bytes.Buffer)

+ func ParseURL(unescapedPath string, itemsAfter int, splitAfter bool, items []string) ([]string, error)

+ func ValidateObjname(s string) error

+ func ValidatePrefix(s string) error

+ type ArchiveBckMsg struct

+ ToBck Bck

+ func (msg *ArchiveBckMsg) Cname() string

type Config

+ func (c *Config) FastV(verbosity, fl int) bool

type ErrHTTP

+ func Str2HTTPErr(msg string) *ErrHTTP

+ func (e *ErrHTTP) StringEx() (s 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 LsoEntry

+ func (be *LsoEntry) IsListedArch() bool

v1.3.17

Apr 10, 2023

v1.3.16

Mar 31, 2023

Changes in this version

+ func DirHasOrIsPrefix(dirPath, prefix string) bool

+ func IsErrStreamTerminated(err error) bool

+ func IsErrXactNotFound(err error) bool

+ func IsFileAlreadyClosed(err error) bool

+ func MakeRangeHdr(start, length int64) (hdr http.Header)

+ func ObjHasPrefix(objName, prefix string) bool

type ArchiveMsg

+ func (msg *ArchiveMsg) Cname() string

type BackendConf

+ func (c *BackendConf) Get(provider string) (conf any)

+ func (c *BackendConf) Set(provider string, newConf any)

type Bck

+ func (b *Bck) Cname(objname string) (s string)

type BsummCtrlMsg

+ Prefix string

+ type ETLErrCtx struct

+ ETLName string

+ PodName string

+ SvcName string

+ TID 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 ErrXactNotFound struct

+ func (e *ErrXactNotFound) Error() string

+ type ListRange struct

+ ObjNames []string

+ Template string

+ func (lrm *ListRange) HasTemplate() bool

+ func (lrm *ListRange) IsList() bool

type LsoEntry

+ func DedupLso(entries LsoEntries, maxSize uint) ([]*LsoEntry, string)

type ObjAttrs

+ func (oa *ObjAttrs) SetSize(size int64)

v1.3.15

Nov 13, 2022

v1.3.13

Nov 9, 2022

v1.3.12

Nov 7, 2022

Changes in this version

+ const AbortReaction

+ const AwsMultipartDelim

+ const CRC32CObjMD

+ const ContentEncoding

+ 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 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 DirNameContainsPrefix(dirPath, prefix string) bool

+ func FreeHra(a *HreqArgs)

+ func FreeHterr(a *ErrHTTP)

+ func IsCloudProvider(p string) bool

+ 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 IsErrNotFound(err error) bool

+ func IsErrObjLevel(err error) bool

+ func IsErrObjNought(err error) bool

+ func IsErrRemoteBckNotFound(err error) bool

+ func IsErrSoft(err error) bool

+ func IsErrUsePrevXaction(err error) bool

+ func IsNestedMpath(a string, la int, b string) (err error)

+ func IsNotExist(err error) bool

+ func IsObjNotExist(err error) bool

+ func IsRemoteProvider(p string) 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 MatchItems(unescapedPath string, itemsAfter int, splitAfter bool, items []string) ([]string, error)

+ func NetworkCallWithRetry(args *RetryArgs) (err error)

+ func NetworkIsKnown(net string) bool

+ func NewClient(args TransportArgs) *http.Client

+ func NewTransport(args TransportArgs) *http.Transport

+ func NormalizeProvider(provider string) (p string, err error)

+ func ObjNameContainsPrefix(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 RangeHdr(start, length int64) (hdr http.Header)

+ 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 ObjAttrsHolder, 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 ArchiveMsg struct

+ AllowAppendToExisting bool

+ ArchName string

+ ContinueOnError bool

+ FromBckName string

+ InclSrcBname bool

+ Mime string

+ ToBck Bck

+ TxnUUID string

+ func (msg *ArchiveMsg) FullName() 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) MarshalJSON() (data []byte, err error)

+ func (c *BackendConf) ProviderConf(provider string, newConf ...any) (conf any, ok bool)

+ 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) Copy(src *Bck)

+ func (b *Bck) DisplayName() string

+ 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() string

+ func (bck *Bck) DefaultProps(cs ...*Config) *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 BsummCtrlMsg struct

+ BckPresent bool

+ Fast bool

+ ObjCached bool

+ UUID string

+ type BsummResult struct

+ IsBckPresent bool

+ ObjCount struct{ ... }

+ ObjSize struct{ ... }

+ TotalSize struct{ ... }

+ UsedPct uint64

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

+ ETLName string

+ PodName string

+ SvcName string

+ TID string

+ UUID 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 *ETLErrorContext, format string, a ...any) *ErrETL

+ func (e *ErrETL) Error() string

+ func (e *ErrETL) WithContext(ctx *ETLErrorContext) *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) *ErrNoNodes

+ func (e *ErrNoNodes) Error() string

+ type ErrNotFound struct

+ func NewErrNotFound(format string, a ...any) *ErrNotFound

+ func (e *ErrNotFound) Error() 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 ErrRangeNoOverlap struct

+ func (e *ErrRangeNoOverlap) Error() 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 ErrUnsupp struct

+ func NewErrUnsupp(action, what string) *ErrUnsupp

+ func (e *ErrUnsupp) Error() string

+ type ErrUsePrevXaction struct

+ func NewErrUsePrevXaction(xaction string) *ErrUsePrevXaction

+ func (e *ErrUsePrevXaction) Error() string

+ type ErrXactionNotFound struct

+ func NewErrXactNotFoundError(cause string) *ErrXactionNotFound

+ func (e *ErrXactionNotFound) Error() string

+ type ExtraProps struct

+ AWS ExtraPropsAWS

+ HDFS ExtraPropsHDFS

+ HTTP ExtraPropsHTTP

+ func (c *ExtraProps) ValidateAsProps(arg ...any) error

+ type ExtraPropsAWS struct

+ CloudRegion string

+ Endpoint string

+ type ExtraPropsAWSToUpdate struct

+ CloudRegion *string

+ Endpoint *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 GenShard map[string][]byte

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

+ Length int64

+ Start int64

+ func ParseMultiRange(s string, size int64) (ranges []HTTPRange, err error)

+ func (r HTTPRange) ContentRange(size int64) string

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

+ MaxTotal cos.Size

+ StatsTime cos.Duration

+ func (c *LogConf) Validate() error

+ type LogConfToUpdate struct

+ FlushTime *cos.Duration

+ Level *string

+ MaxSize *cos.Size

+ MaxTotal *cos.Size

+ 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 (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.Size

+ HousekeepTime cos.Duration

+ MinFree cos.Size

+ MinPctFree int

+ MinPctTotal int

+ SizeToGC cos.Size

+ func (c *MemsysConf) Validate() (err error)

+ type MemsysConfToUpdate struct

+ DefaultBufSize *cos.Size

+ HousekeepTime *cos.Duration

+ MinFree *cos.Size

+ MinPctFree *int

+ MinPctTotal *int

+ SizeToGC *cos.Size

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

+ Lock func()

+ TryLock func(timeout time.Duration) bool

+ TryRLock func(timeout time.Duration) bool

+ Unlock func()

+ 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 ObjAttrsHolder, skipCksum ...bool)

+ func (oa *ObjAttrs) DelCustomKeys(keys ...string)

+ func (oa *ObjAttrs) Equal(rem ObjAttrsHolder) (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) SizeBytes(_ ...bool) int64

+ func (oa *ObjAttrs) String() string

+ func (oa *ObjAttrs) Version(_ ...bool) string

+ type ObjAttrsHolder interface

+ AtimeUnix func() int64

+ Checksum func() *cos.Cksum

+ GetCustomKey func(key string) (val string, exists bool)

+ GetCustomMD func() cos.StrKVs

+ SetCustomKey func(k, v string)

+ SizeBytes func(special ...bool) int64

+ String func() string

+ Version func(special ...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 SelectObjsMsg struct

+ ObjNames []string

+ Template string

+ func (lrm *SelectObjsMsg) HasTemplate() bool

+ func (lrm *SelectObjsMsg) IsList() bool

+ 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

+ ContinueOnError bool

+ ToBck Bck

+ TxnUUID string

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

+ LZ4FrameChecksum bool

+ MaxHeaderSize int

+ QuiesceTime cos.Duration

+ func (c *TransportConf) Validate() (err error)

+ type TransportConfToUpdate struct

+ Burst *int

+ IdleTeardown *cos.Duration

+ LZ4BlockMaxSize *cos.Size

+ 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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL