Versions in this module Expand all Collapse all v1 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