core

package

Go to main page

Versions in this module

v1

v1.4.4

Apr 8, 2026

v1.4.3

Mar 25, 2026

Changes in this version

type LIF

+ Digest uint64

+ Size int64

+ func (lif *LIF) Cname() string

type LOM

+ func (lom *LOM) Hrw(avail fs.MPI) (*fs.Mountpath, bool)

+ func (lom *LOM) HrwWithChunks(avail fs.MPI) (*fs.Mountpath, bool)

+ type LsoS3InvCtx struct

+ EOF bool

+ ID string

+ Lmfh cos.LomReader

+ Lom *LOM

+ Name string

+ SGL *memsys.SGL

+ Schema []string

+ Size int64

type PutParams

+ SkipBackend bool

type Ufest

+ func (u *Ufest) CheckInOrder(partNum int) (bool, hash.Hash)

+ func (u *Ufest) FinalizeStreamChecksum() *cos.Cksum

+ func (u *Ufest) InitStreamingChecksum(cksumType string)

+ func (u *Ufest) StreamWriteDone()

+ func (u *Ufest) WholeChecksum() (*cos.Cksum, error)

type Xact

+ ErrCnt func() int

v1.4.2

Jan 15, 2026

Changes in this version

type LOM

+ func (lom *LOM) CleanupCopies(avail fs.MPI) (exp, got int)

+ func (lom *LOM) ETag(mtime time.Time, allowSyscall bool) string

+ func (lom *LOM) InitCmnBck(bck *cmn.Bck) (err error)

+ func (lom *LOM) IsPrimaryCopy(avail fs.MPI, hmi *fs.Mountpath, sentinel string) (isPrimary, mainExists bool)

+ func (lom *LOM) LastModified() (time.Time, error)

+ func (lom *LOM) LastModifiedLso() (string, time.Time)

+ func (lom *LOM) LastModifiedStr() (string, time.Time)

type Ufest

+ func (u *Ufest) IsHRW(avail fs.MPI) (bool, error)

+ func (u *Ufest) Relocate(hrwMi *fs.Mountpath, buf []byte) (*LOM, error)

+ func (u *Ufest) ValidateChunkLocations(completed bool) error

v1.4.1

Dec 5, 2025

Changes in this version

+ const MaxChunkCount

type BlobParams

+ RespWriter io.Writer

+ type GetStats interface

+ InBytes func() int64

+ InObjsAdd func(int, int64)

+ Objs func() int64

+ ObjsAdd func(int, int64)

+ OutBytes func() int64

+ OutObjsAdd func(int, int64)

type PutParams

+ ChunkSize int64

+ Locked bool

type Snap

+ func (xsnap *Snap) IsFinished() bool

+ func (xsnap *Snap) IsRunning() bool

type Xact

+ CtlMsg func() string

+ IsDone func() bool

+ IsIdle func() bool

+ IsRunning func() bool

v1.4.0

Oct 7, 2025

Changes in this version

+ const MetaverLOM_V1

type Backend

+ AbortMpt func(lom *LOM, r *http.Request, uploadID string) (ecode int, err error)

+ CompleteMpt func(lom *LOM, r *http.Request, uploadID string, body []byte, ...) (version, etag string, ecode int, err error)

+ PutMptPart func(lom *LOM, reader io.ReadCloser, r *http.Request, uploadID string, size int64, ...) (etag string, ecode int, err error)

+ StartMpt func(lom *LOM, r *http.Request) (uploadID string, ecode int, err error)

type CT

+ func NewCTFromParsed(parsed *fs.ParsedFQN, fqn string) *CT

+ func NewDsortCT(bck *cmn.Bck, objName string) (ct *CT, err error)

+ func (ct *CT) GenFQN(cttype string, extras ...string) string

type ETLArgs

+ Pipeline apc.ETLPipeline

+ type GfnParams struct

+ ArchPath string

+ Config *cmn.Config

+ Lom *LOM

+ Size int64

+ Tsi *meta.Snode

type LOM

+ func (lom *LOM) CompleteUfest(u *Ufest) (err error)

+ func (lom *LOM) DelCustomKey(key string)

+ func (lom *LOM) GenFQN(cttype string, extras ...string) string

+ func (lom *LOM) MtimeUTC() (time.Time, error)

+ func (lom *LOM) NewUfestReader() (cos.LomReader, error)

+ func (lom *LOM) OpenCopy() (cos.LomReader, string)

+ func (lom *LOM) ValidateColdGet() bool

type Target

+ GetFromNeighbor func(params *GfnParams) (*http.Response, error)

+ type Uchunk struct

+ ETag string

+ MD5 []byte

+ func (c *Uchunk) Num() uint16

+ func (c *Uchunk) Path() string

+ func (c *Uchunk) SetCksum(cksum *cos.Cksum)

+ func (c *Uchunk) SetETag(etag string)

+ func (c *Uchunk) Size() int64

+ type Ufest struct

+ func NewUfest(id string, lom *LOM, mustExist bool) (*Ufest, error)

+ func (u *Ufest) Abort(lom *LOM)

+ func (u *Ufest) Add(c *Uchunk, size, num int64) error

+ func (u *Ufest) Check() error

+ func (u *Ufest) Completed() bool

+ func (u *Ufest) ComputeWholeChecksum(cksumH *cos.CksumHash) error

+ func (u *Ufest) Count() int

+ func (u *Ufest) Created() time.Time

+ func (u *Ufest) ETagS3() (string, error)

+ func (u *Ufest) GetChunk(num int, locked bool) *Uchunk

+ func (u *Ufest) ID() string

+ func (u *Ufest) LoadCompleted(lom *LOM) error

+ func (u *Ufest) LoadPartial(lom *LOM) error

+ func (u *Ufest) Lock()

+ func (u *Ufest) Lom() *LOM

+ func (u *Ufest) NewChunk(num int, lom *LOM) (*Uchunk, error)

+ func (u *Ufest) NewReader() (*UfestReader, error)

+ func (u *Ufest) Size() int64

+ func (u *Ufest) StorePartial(lom *LOM, locked bool) error

+ func (u *Ufest) Unlock()

+ type UfestReader struct

+ func (r *UfestReader) Close() error

+ func (r *UfestReader) Read(p []byte) (n int, err error)

+ func (r *UfestReader) ReadAt(p []byte, off int64) (n int, err error)

v1.3.31

Jul 25, 2025

Changes in this version

+ type ETLArgs struct

+ Daddr string

+ Local bool

+ TransformArgs string

v1.3.30

Jul 21, 2025

Changes in this version

+ func DrainLIF(workCh chan LIF) (n int)

type LOM

+ func (lom *LOM) Chtimes(atime, mtime time.Time) (err error)

+ func (lom *LOM) Clone() *LOM

+ func (lom *LOM) CloneTo(fqn string) *LOM

+ func (lom *LOM) GetXattr(buf []byte) ([]byte, error)

+ func (lom *LOM) GetXattrN(name string) ([]byte, error)

+ func (lom *LOM) MirrorPaths() []string

+ func (lom *LOM) NewArchpathReader(lmfh cos.LomReader, archpath, mime string) (csl cos.ReadCloseSizer, err error)

+ func (lom *LOM) NewHandle(loaded bool) (*LomHandle, error)

+ func (lom *LOM) SetXattr(data []byte) error

+ func (lom *LOM) SetXattrN(name string, data []byte) error

+ type LomHandle struct

+ func (lh *LomHandle) Open() (cos.ReadOpenCloser, error)

+ type PutWOC func(lom *LOM, latestVer, sync bool, woc io.WriteCloser, args *GetROCArgs) (written int64, ecode int, err error)

v1.3.29

May 22, 2025

v1.3.28

May 9, 2025

Changes in this version

+ func LcacheClear()

+ func LcacheClearBcks(wg *sync.WaitGroup, bcks ...*meta.Bck) bool

+ func LcacheClearMpath(mi *fs.Mountpath)

+ type GetROC func(lom *LOM, latestVer, sync bool, args *GetROCArgs) ReadResp

+ type GetROCArgs struct

+ Daddr string

+ Local bool

+ TransformArgs string

type LIF

+ func (lif *LIF) Name() string

type LOM

+ func (lom *LOM) GetROC(latestVer, sync bool) (resp ReadResp)

+ func (lom *LOM) UncacheDel()

type Node

+ StatsUpdater func() cos.StatsUpdater

+ type ReadResp struct

+ Ecode int

+ Err error

+ OAH cos.OAH

+ R cos.ReadOpenCloser

+ Remote bool

+ func GetDefaultROC(lom *LOM, latestVer, sync bool, _ *GetROCArgs) ReadResp

type Snap

+ Packed int64

+ func (xsnap *Snap) Pack(njoggers, nworkers int, chanFull int64)

+ func (xsnap *Snap) Unpack() (njoggers, nworkers, chanFull int)

v1.3.27

Feb 14, 2025

v1.3.26

Feb 7, 2025

Changes in this version

+ const AisBID

+ const LcacheErrCount

+ const MetaverChunk

+ const MetaverLOM

+ const QuiActiveDontBump

+ func NewBID(serial uint64, isAis bool) uint64

+ func UncacheBcks(wg *sync.WaitGroup, bcks ...*meta.Bck) bool

type LOM

+ func (lom *LOM) IsFntl() bool

+ func (lom *LOM) OrigFntl() []string

+ func (lom *LOM) PopFntl(saved []string)

+ func (lom *LOM) PushFntl(short []string) (saved []string)

+ func (lom *LOM) ShortenFntl() []string

+ func (lom *LOM) TestAtime() error

type Snap

+ CtlMsg string

type Target

+ ECRestoreReq func(ct *CT, si *meta.Snode, uuid string) error

v1.3.25

Oct 6, 2024

v1.3.24

Sep 27, 2024

Changes in this version

type Backend

+ MetricName func(string) string

type CT

+ func (ct *CT) Cname() string

+ func (ct *CT) LoadSliceFromFS() error

+ func (ct *CT) Lsize() int64

+ func (ct *CT) UnamePtr() *string

type LOM

+ func (*LOM) AppendWork(wfqn string) (fh cos.LomWriter, err error)

+ func (lom *LOM) CheckEq(rem cos.OAH) error

+ func (lom *LOM) CopyVersion(oah cos.OAH)

+ func (lom *LOM) Create() (cos.LomWriter, error)

+ func (lom *LOM) CreatePart(wfqn string) (*os.File, error)

+ func (lom *LOM) CreateSlice(wfqn string) (*os.File, error)

+ func (lom *LOM) CreateWork(wfqn string) (cos.LomWriter, error)

+ func (lom *LOM) Fstat(getAtime bool) (size, atimefs int64, mtime time.Time, _ error)

+ func (lom *LOM) IsChunked(special ...bool) bool

+ func (lom *LOM) Lsize(special ...bool) int64

+ func (lom *LOM) Open() (fh cos.LomReader, err error)

+ func (lom *LOM) RemoveMain() (err error)

+ func (lom *LOM) RemoveObj(force ...bool) (err error)

+ func (lom *LOM) RenameFinalize(wfqn string) error

+ func (lom *LOM) RenameMainTo(wfqn string) error

+ func (lom *LOM) RenameToMain(wfqn string) error

+ func (lom *LOM) UnamePtr() *string

+ func (lom *LOM) VersionPtr() *string

type Target

+ HeadCold func(lom *LOM, origReq *http.Request) (objAttrs *cmn.ObjAttrs, ecode int, err error)

type TargetPut

+ GetAllRunning func(inout *AllRunningInOut, periodic bool)

+ OOS func(*fs.CapStatus, *cmn.Config, *fs.Tcdf) fs.CapStatus

v1.3.23

May 27, 2024

Changes in this version

+ type Backend interface

+ CreateBucket func(bck *meta.Bck) (ecode int, err error)

+ DeleteObj func(lom *LOM) (ecode int, err error)

+ GetBucketInv func(bck *meta.Bck, ctx *LsoInvCtx) (ecode int, err error)

+ GetObj func(ctx context.Context, lom *LOM, owt cmn.OWT, origReq *http.Request) (ecode int, err error)

+ GetObjReader func(ctx context.Context, lom *LOM, offset, length int64) GetReaderResult

+ HeadBucket func(ctx context.Context, bck *meta.Bck) (bckProps cos.StrKVs, ecode int, err error)

+ HeadObj func(ctx context.Context, lom *LOM, origReq *http.Request) (objAttrs *cmn.ObjAttrs, ecode int, err error)

+ ListBuckets func(qbck cmn.QueryBcks) (bcks cmn.Bcks, ecode int, err error)

+ ListObjects func(bck *meta.Bck, msg *apc.LsoMsg, lst *cmn.LsoRes) (ecode int, err error)

+ ListObjectsInv func(bck *meta.Bck, msg *apc.LsoMsg, lst *cmn.LsoRes, ctx *LsoInvCtx) error

+ Provider func() string

+ PutObj func(r io.ReadCloser, lom *LOM, origReq *http.Request) (ecode int, err error)

+ type BlobParams struct

+ Lmfh *os.File

+ Lom *LOM

+ Msg *apc.BlobMsg

+ RspW http.ResponseWriter

+ Wfqn string

+ WriteSGL WriteSGL

type LOM

+ func (lom *LOM) IsFeatureSet(f feat.Flags) bool

+ func (lom *LOM) OpenFile() (*os.File, error)

+ func (lom *LOM) PostInit() (err error)

+ func (lom *LOM) PreInit(fqn string) (err error)

+ type LsoInvCtx struct

+ EOF bool

+ ID string

+ Lmfh *os.File

+ Lom *LOM

+ Name string

+ SGL *memsys.SGL

+ Schema []string

+ Size int64

type Node

+ ByteMM func() *memsys.MMSA

+ PageMM func() *memsys.MMSA

+ type NodeCapacity interface

+ GetAllRunning func(inout *AllRunningInOut, periodic bool)

+ OOS func(*fs.CapStatus) fs.CapStatus

type TargetPut

+ GetColdBlob func(params *BlobParams, oa *cmn.ObjAttrs) (xctn Xact, err error)

+ type WriteSGL func(*memsys.SGL) error

v1.3.22

Feb 25, 2024

Changes in this version

+ const AllNodes

+ const DumpLomEnvVar

+ const LcacheCollisionCount

+ const LcacheEvictedCount

+ const LcacheFlushColdCount

+ const Proxies

+ const QuiAborted

+ const QuiActive

+ const QuiActiveRet

+ const QuiDone

+ const QuiInactiveCB

+ const QuiTimeout

+ const Quiescent

+ const RemoteDeletedDelCount

+ const SelectedNodes

+ const Targets

+ const UponProgress

+ const UponTerm

+ const XattrLOM

+ func FreeCOI(a *CopyParams)

+ func FreeLOM(lom *LOM)

+ func FreePutParams(a *PutParams)

+ func HrwFQN(bck *cmn.Bck, contentType, objName string) (fqn string, digest uint64, err error)

+ func InMaintOrDecomm(smap *meta.Smap, tsi *meta.Snode, xact Xact) (err error)

+ func ParseObjLoc(loc string) (tname, mpname string)

+ func Pinit()

+ func ResolveFQN(fqn string) (parsedFQN fs.ParsedFQN, hrwFQN string, err error)

+ func Term()

+ func Tinit(t Target, tstats cos.StatsUpdater, runHK bool)

+ func UncacheBck(b *meta.Bck)

+ func UncacheMountpath(mi *fs.Mountpath)

+ type AllRunningInOut struct

+ Idle []string

+ Kind string

+ Running []string

+ type BackendProvider interface

+ CreateBucket func(bck *meta.Bck) (errCode int, err error)

+ DeleteObj func(lom *LOM) (errCode int, err error)

+ GetObj func(ctx context.Context, lom *LOM, owt cmn.OWT) (errCode int, err error)

+ GetObjReader func(ctx context.Context, lom *LOM, offset, length int64) GetReaderResult

+ HeadBucket func(ctx context.Context, bck *meta.Bck) (bckProps cos.StrKVs, errCode int, err error)

+ HeadObj func(ctx context.Context, lom *LOM) (objAttrs *cmn.ObjAttrs, errCode int, err error)

+ ListBuckets func(qbck cmn.QueryBcks) (bcks cmn.Bcks, errCode int, err error)

+ ListObjects func(bck *meta.Bck, msg *apc.LsoMsg, lst *cmn.LsoResult) (errCode int, err error)

+ Provider func() string

+ PutObj func(r io.ReadCloser, lom *LOM, extraArgs *ExtraArgsPut) (errCode int, err error)

+ type CRMD struct

+ Eq bool

+ Err error

+ ErrCode int

+ ObjAttrs *cmn.ObjAttrs

+ type CT struct

+ func NewCTFromBO(bck *cmn.Bck, objName string, b meta.Bowner, ctType ...string) (ct *CT, err error)

+ func NewCTFromFQN(fqn string, b meta.Bowner) (ct *CT, err error)

+ func NewCTFromLOM(lom *LOM, ctType string) *CT

+ func (ct *CT) Bck() *meta.Bck

+ func (ct *CT) Bucket() *cmn.Bck

+ func (ct *CT) CacheIdx() int

+ func (ct *CT) Clone(ctType string) *CT

+ func (ct *CT) ContentType() string

+ func (ct *CT) Digest() uint64

+ func (ct *CT) FQN() string

+ func (ct *CT) LoadFromFS() error

+ func (ct *CT) Lock(exclusive bool)

+ func (ct *CT) Make(toType string, pref ...string) string

+ func (ct *CT) Mountpath() *fs.Mountpath

+ func (ct *CT) MtimeUnix() int64

+ func (ct *CT) ObjectName() string

+ func (ct *CT) SizeBytes() int64

+ func (ct *CT) Uname() string

+ func (ct *CT) Unlock(exclusive bool)

+ func (ct *CT) Write(reader io.Reader, size int64, workFQN ...string) (err error)

+ type CopyParams struct

+ BckTo *meta.Bck

+ Buf []byte

+ Config *cmn.Config

+ DP DP

+ DryRun bool

+ Finalize bool

+ LatestVer bool

+ OWT cmn.OWT

+ ObjnameTo string

+ Sync bool

+ Xact Xact

+ func AllocCOI() (a *CopyParams)

+ type DM interface

+ Send func(obj *transport.Obj, roc cos.ReadOpenCloser, tsi *meta.Snode) error

+ type DP interface

+ Reader func(lom *LOM, latestVer, sync bool) (reader cos.ReadOpenCloser, oah cos.OAH, err error)

+ type ExtraArgsPut struct

+ DataClient *http.Client

+ Req *http.Request

+ type GetReaderResult struct

+ Err error

+ ErrCode int

+ ExpCksum *cos.Cksum

+ R io.ReadCloser

+ Size int64

+ type LDP struct

+ func (*LDP) Reader(lom *LOM, latestVer, sync bool) (cos.ReadOpenCloser, cos.OAH, error)

+ type LIF struct

+ BID uint64

+ Uname string

+ func (lif *LIF) CacheIdx() int

+ func (lif *LIF) LOM() (lom *LOM, err error)

+ func (lif *LIF) Unlock(exclusive bool)

+ type LOM struct

+ FQN string

+ HrwFQN string

+ ObjName string

+ func AllocLOM(objName string) *LOM

+ func AllocLomFromHdr(hdr *transport.ObjHdr) (lom *LOM, err error)

+ func (lom *LOM) AcquireAtimefs() error

+ func (lom *LOM) AddCopy(copyFQN string, mpi *fs.Mountpath) error

+ func (lom *LOM) Atime() time.Time

+ func (lom *LOM) AtimeUnix() int64

+ func (lom *LOM) Bck() *meta.Bck

+ func (lom *LOM) Bprops() *cmn.Bprops

+ func (lom *LOM) Bucket() *cmn.Bck

+ func (lom *LOM) CacheIdx() int

+ func (lom *LOM) CheckRemoteMD(locked, sync bool) (res CRMD)

+ func (lom *LOM) Checksum() *cos.Cksum

+ func (lom *LOM) CksumConf() *cmn.CksumConf

+ func (lom *LOM) CksumType() string

+ func (lom *LOM) CloneMD(fqn string) *LOM

+ func (lom *LOM) Cname() string

+ func (lom *LOM) ComputeCksum(cksumType string) (cksum *cos.CksumHash, err error)

+ func (lom *LOM) ComputeSetCksum() (*cos.Cksum, error)

+ func (lom *LOM) Copy(mi *fs.Mountpath, buf []byte) (err error)

+ func (lom *LOM) Copy2FQN(dstFQN string, buf []byte) (dst *LOM, err error)

+ func (lom *LOM) CopyAttrs(oah cos.OAH, skipCksum bool)

+ func (lom *LOM) CreateFile(fqn string) (fh *os.File, err error)

+ func (lom *LOM) CreateFileRW(fqn string) (fh *os.File, err error)

+ func (lom *LOM) DelAllCopies() (err error)

+ func (lom *LOM) DelCopies(copiesFQN ...string) (err error)

+ func (lom *LOM) DelExtraCopies(fqn ...string) (removed bool, err error)

+ func (lom *LOM) Digest() uint64

+ func (lom *LOM) DowngradeLock()

+ func (lom *LOM) ECEnabled() bool

+ func (lom *LOM) EqCksum(cksum *cos.Cksum) bool

+ func (lom *LOM) Equal(rem cos.OAH) bool

+ func (lom *LOM) FromFS() error

+ func (lom *LOM) GetCopies() fs.MPI

+ func (lom *LOM) GetCustomKey(key string) (string, bool)

+ func (lom *LOM) GetCustomMD() cos.StrKVs

+ func (lom *LOM) HasCopies() bool

+ func (lom *LOM) HrwTarget(smap *meta.Smap) (tsi *meta.Snode, local bool, err error)

+ func (lom *LOM) IncVersion() error

+ func (lom *LOM) InitBck(bck *cmn.Bck) (err error)

+ func (lom *LOM) InitCT(ct *CT)

+ func (lom *LOM) InitFQN(fqn string, expbck *cmn.Bck) (err error)

+ func (lom *LOM) IsCopy() bool

+ func (lom *LOM) IsHRW() bool

+ func (lom *LOM) IsLocked() (int, bool)

+ func (lom *LOM) LBGet() (fqn string)

+ func (lom *LOM) LIF() (lif LIF)

+ func (lom *LOM) LeastUtilNoCopy() (mi *fs.Mountpath)

+ func (lom *LOM) Load(cacheit, locked bool) error

+ func (lom *LOM) LoadLatest(latest bool) (oa *cmn.ObjAttrs, deleted bool, err error)

+ func (lom *LOM) LoadMetaFromFS() error

+ func (lom *LOM) LoadUnsafe() (err error)

+ func (lom *LOM) Location() string

+ func (lom *LOM) Lock(exclusive bool)

+ func (lom *LOM) MirrorConf() *cmn.MirrorConf

+ func (lom *LOM) Mountpath() *fs.Mountpath

+ func (lom *LOM) NewDeferROC() (cos.ReadOpenCloser, error)

+ func (lom *LOM) NumCopies() int

+ func (lom *LOM) ObjAttrs() *cmn.ObjAttrs

+ func (lom *LOM) ObjectName() string

+ func (lom *LOM) Persist() (err error)

+ func (lom *LOM) PersistMain() (err error)

+ func (lom *LOM) Recache()

+ func (lom *LOM) Remove(force ...bool) (err error)

+ func (lom *LOM) RenameFrom(workfqn string) error

+ func (lom *LOM) RestoreToLocation() (exists bool)

+ func (lom *LOM) SetAtimeUnix(tu int64)

+ func (lom *LOM) SetCksum(cksum *cos.Cksum)

+ func (lom *LOM) SetCustomKey(key, value string)

+ func (lom *LOM) SetCustomMD(md cos.StrKVs)

+ func (lom *LOM) SetSize(size int64)

+ func (lom *LOM) SetVersion(ver string)

+ func (lom *LOM) SizeBytes(special ...bool) int64

+ func (lom *LOM) String() string

+ func (lom *LOM) ToMpath() (mi *fs.Mountpath, isHrw bool)

+ func (lom *LOM) TryLock(exclusive bool) bool

+ func (lom *LOM) Uname() string

+ func (lom *LOM) Uncache()

+ func (lom *LOM) UncacheUnless()

+ func (lom *LOM) Unlock(exclusive bool)

+ func (lom *LOM) UpgradeLock() (finished bool)

+ func (lom *LOM) ValidateContentChecksum() (err error)

+ func (lom *LOM) ValidateMetaChecksum() error

+ func (lom *LOM) ValidateWarmGet(qparam string) bool

+ func (lom *LOM) Version(special ...bool) string

+ func (lom *LOM) VersionConf() cmn.VersionConf

+ func (lom *LOM) WritePolicy() (p apc.WritePolicy)

+ type NLP interface

+ Lock func()

+ TryLock func(timeout time.Duration) bool

+ TryRLock func(timeout time.Duration) bool

+ Unlock func()

+ func NewNLP(name string) NLP

+ type Node interface

+ Bowner func() meta.Bowner

+ ClusterStarted func() bool

+ NodeStarted func() bool

+ SID func() string

+ Snode func() *meta.Snode

+ Sowner func() meta.Sowner

+ String func() string

+ type NodeMemCap interface

+ ByteMM func() *memsys.MMSA

+ GetAllRunning func(inout *AllRunningInOut, periodic bool)

+ OOS func(*fs.CapStatus) fs.CapStatus

+ PageMM func() *memsys.MMSA

+ type Notif interface

+ LastNotifTime func() int64

+ NotifyInterval func() time.Duration

+ OnFinishedCB func() func(Notif, error, bool)

+ OnProgressCB func() func(Notif)

+ SetLastNotified func(now int64)

+ Subscribers func() []string

+ ToNotifMsg func(aborted bool) NotifMsg

+ Upon func(u Upon) bool

+ type NotifMsg struct

+ AbortedX bool

+ Data []byte

+ ErrMsg string

+ Kind string

+ NodeID string

+ UUID string

+ func (msg *NotifMsg) String() (s string)

+ type OnFinishObj = func(lom *LOM, err error)

+ type PromoteParams struct

+ Bck *meta.Bck

+ Cksum *cos.Cksum

+ Config *cmn.Config

+ Xact Xact

+ type PutParams struct

+ Atime time.Time

+ Cksum *cos.Cksum

+ ColdGET bool

+ OWT cmn.OWT

+ Reader io.ReadCloser

+ Size int64

+ SkipEC bool

+ WorkTag string

+ Xact Xact

+ func AllocPutParams() (a *PutParams)

+ type QuiCB func(elapsed time.Duration) QuiRes

+ type QuiRes int

+ type Snap struct

+ AbortErr string

+ AbortedX bool

+ Bck cmn.Bck

+ DstBck cmn.Bck

+ EndTime time.Time

+ Err string

+ Ext any

+ ID string

+ IdleX bool

+ Kind string

+ RebID int64

+ SrcBck cmn.Bck

+ StartTime time.Time

+ Stats Stats

+ func (snp *Snap) Finished() bool

+ func (snp *Snap) IsAborted() bool

+ func (snp *Snap) IsIdle() bool

+ func (snp *Snap) Running() bool

+ func (snp *Snap) Started() bool

+ type Stats struct

+ Bytes int64

+ InBytes int64

+ InObjs int64

+ Objs int64

+ OutBytes int64

+ OutObjs int64

+ type Target interface

+ BMDVersionFixup func(r *http.Request, bck ...cmn.Bck)

+ CopyObject func(lom *LOM, dm DM, coi *CopyParams) (int64, error)

+ DataClient func() *http.Client

+ DeleteObject func(lom *LOM, evict bool) (errCode int, err error)

+ EvictObject func(lom *LOM) (errCode int, err error)

+ FinalizeObj func(lom *LOM, workFQN string, xctn Xact, owt cmn.OWT) (errCode int, err error)

+ GetCold func(ctx context.Context, lom *LOM, owt cmn.OWT) (errCode int, err error)

+ GetColdBlob func(lom *LOM, oa *cmn.ObjAttrs) (xctn Xact, err error)

+ HeadObjT2T func(lom *LOM, si *meta.Snode) bool

+ Promote func(params *PromoteParams) (errCode int, err error)

+ var T Target

+ type TargetLoc interface

+ Backend func(*meta.Bck) BackendProvider

+ FSHC func(err error, path string)

+ Health func(si *meta.Snode, timeout time.Duration, query url.Values) (body []byte, errCode int, err error)

+ type TargetPut interface

+ PutObject func(lom *LOM, params *PutParams) (err error)

+ type Upon int

+ type Xact interface

+ Abort func(error) bool

+ AbortErr func() error

+ AbortedAfter func(time.Duration) error

+ AddErr func(error, ...int)

+ AddNotif func(n Notif)

+ Bck func() *meta.Bck

+ ChanAbort func() <-chan error

+ Cname func() string

+ EndTime func() time.Time

+ Finish func()

+ Finished func() bool

+ FromTo func() (*meta.Bck, *meta.Bck)

+ ID func() string

+ InBytes func() int64

+ InObjsAdd func(int, int64)

+ IsAborted func() bool

+ Kind func() string

+ Name func() string

+ Objs func() int64

+ ObjsAdd func(int, int64)

+ OutBytes func() int64

+ OutObjsAdd func(int, int64)

+ Quiesce func(time.Duration, QuiCB) QuiRes

+ Run func(*sync.WaitGroup)

+ Running func() bool

+ Snap func() *Snap

+ StartTime func() time.Time

+ String func() string

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