cluster

package

Go to main page

Versions in this module

v1

v1.3.21

Nov 5, 2023

Changes in this version

+ const LcacheCollisionCount

+ const LcacheEvictedCount

+ const LcacheFlushColdCount

+ func Pinit()

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

+ func UncacheBck(b *meta.Bck)

+ func UncacheMountpath(mi *fs.Mountpath)

type CT

+ func (ct *CT) Digest() uint64

+ type GetReaderResult struct

+ Err error

+ ErrCode int

+ ExpCksum *cos.Cksum

+ R io.ReadCloser

+ Size int64

type LOM

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

+ func (lom *LOM) Digest() uint64

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

+ func (lom *LOM) UncacheUnless()

type PutObjectParams

+ ColdGET bool

+ SkipEC bool

v1.3.20

Sep 12, 2023

Changes in this version

+ type AllRunningInOut struct

+ Idle []string

+ Kind string

+ Running []string

v1.3.19

Aug 29, 2023

v1.3.18

Jul 9, 2023

Changes in this version

type LOM

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

+ 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 Snap

+ AbortErr string

+ Err string

type Xact

+ AddErr func(error)

v1.3.17

Apr 10, 2023

v1.3.16

Mar 31, 2023

Changes in this version

type Bck

+ func (b *Bck) Cname(name string) string

type CT

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

type LOM

+ func (lom *LOM) Cname() string

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

type Node

+ SID func() string

+ String func() string

+ type NodeMemCap interface

+ ByteMM func() *memsys.MMSA

+ GetAllRunning func(xactKind string, separateIdle bool) (running, idle []string)

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

+ PageMM func() *memsys.MMSA

type Smap

+ func (m *Smap) CountActivePs() (count int)

+ func (m *Smap) CountActiveTs() (count int)

+ func (m *Smap) GetActiveNode(sid string) (si *Snode)

+ func (m *Smap) HasActiveTargetPeers() bool

+ func (m *Smap) InMaintOrDecomm(si *Snode) (ok bool)

+ type Snap struct

+ AbortedX bool

+ Bck cmn.Bck

+ DstBck cmn.Bck

+ EndTime time.Time

+ 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 Snode

+ func (d *Snode) InMaintOrDecomm() bool

+ type Stats struct

+ Bytes int64

+ InBytes int64

+ InObjs int64

+ Objs int64

+ OutBytes int64

+ OutObjs int64

type Target

+ DataClient func() *http.Client

+ type TargetExt interface

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

+ type TargetLoc interface

+ Backend func(*Bck) BackendProvider

+ FSHC func(err error, path string)

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

+ type TargetPut interface

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

v1.3.15

Nov 13, 2022

v1.3.13

Nov 9, 2022

v1.3.12

Nov 7, 2022

Changes in this version

+ const AllNodes

+ const DumpLomEnvVar

+ const MaxBcastMultiplier

+ const NodeFlagDecomm

+ const NodeFlagMaint

+ const NodeFlagsMaintDecomm

+ const PnamePrefix

+ const Proxies

+ const QuiAborted

+ const QuiActive

+ const QuiActiveRet

+ const QuiDone

+ const QuiInactiveCB

+ const QuiTimeout

+ const Quiescent

+ const SnameSuffix

+ const SnodeIC

+ const SnodeNonElectable

+ const Targets

+ const TnamePrefix

+ const UponProgress

+ const UponTerm

+ const XattrLOM

+ func EvictLomCache(b *Bck)

+ func FreeCpObjParams(a *CopyObjectParams)

+ func FreeLOM(lom *LOM)

+ func FreeNodes(nodes Nodes)

+ func FreePutObjParams(a *PutObjectParams)

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

+ func HrwMpath(uname string) (mi *fs.MountpathInfo, digest uint64, err error)

+ func Init(t Target)

+ func MaxBcastParallel() int

+ func N2ID(name string) string

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

+ func Pname(pid string) string

+ func RegLomCacheWithHK(t Target)

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

+ func Tname(tid string) string

+ type BMD struct

+ Ext any

+ Providers Providers

+ UUID string

+ Version int64

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

+ func (m *BMD) Add(bck *Bck)

+ func (m *BMD) Del(bck *Bck) (deleted bool)

+ func (m *BMD) Exists(bck *Bck, bckID uint64) (exists bool)

+ func (m *BMD) Get(bck *Bck) (p *cmn.BucketProps, present bool)

+ func (m *BMD) IsECUsed() (yes bool)

+ func (m *BMD) Range(providerQuery *string, nsQuery *cmn.Ns, callback func(*Bck) bool)

+ func (m *BMD) Select(qbck *cmn.QueryBcks) cmn.Bcks

+ func (m *BMD) Set(bck *Bck, p *cmn.BucketProps)

+ func (m *BMD) String() string

+ func (m *BMD) StringEx() string

+ type BackendProvider interface

+ CreateBucket func(bck *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) (r io.ReadCloser, expectedCksum *cos.Cksum, errCode int, err error)

+ HeadBucket func(ctx context.Context, bck *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 *Bck, msg *apc.LsoMsg, lst *cmn.LsoResult) (errCode int, err error)

+ MaxPageSize func() uint

+ Provider func() string

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

+ type Bck cmn.Bck

+ func CloneBck(bck *cmn.Bck) *Bck

+ func InitByNameOnly(bckName string, bowner Bowner) (bck *Bck, err error, errCode int)

+ func NewBck(name, provider string, ns cmn.Ns, optProps ...*cmn.BucketProps) *Bck

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

+ func (b *Bck) AddUnameToQuery(q url.Values, uparam string) url.Values

+ func (b *Bck) Allow(bit apc.AccessAttrs) error

+ func (b *Bck) Backend() *Bck

+ func (b *Bck) Bucket() *cmn.Bck

+ func (b *Bck) CksumConf() (conf *cmn.CksumConf)

+ func (b *Bck) Clone() cmn.Bck

+ func (b *Bck) Equal(other *Bck, sameID, sameBackend bool) bool

+ func (b *Bck) GetNameLockPair() (nlp *NameLockPair)

+ func (b *Bck) HasProvider() bool

+ func (b *Bck) Init(bowner Bowner) (err error)

+ func (b *Bck) InitNoBackend(bowner Bowner) error

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

+ func (b *Bck) MaskBID(i int64) uint64

+ func (b *Bck) RemoteBck() *cmn.Bck

+ func (b *Bck) String() string

+ func (b *Bck) Validate() error

+ func (b *Bck) VersionConf() cmn.VersionConf

+ type Bowner interface

+ Get func() (bmd *BMD)

+ type Buckets map[string]*cmn.BucketProps

+ type CT struct

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

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

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

+ func (ct *CT) Bck() *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) 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) MpathInfo() *fs.MountpathInfo

+ 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(t Target, reader io.Reader, size int64, workFQN ...string) (err error)

+ type CopyObjectParams struct

+ BckTo *Bck

+ Buf []byte

+ DM DataMover

+ DP DP

+ ObjNameTo string

+ Xact Xact

+ func AllocCpObjParams() (a *CopyObjectParams)

+ type DP interface

+ Reader func(lom *LOM) (reader cos.ReadOpenCloser, objMeta cmn.ObjAttrsHolder, err error)

+ type DataMover interface

+ ACK func(hdr transport.ObjHdr, cb transport.ObjSentCB, tsi *Snode) error

+ Close func(err error)

+ GetXact func() Xact

+ OWT func() cmn.OWT

+ Open func()

+ RegRecv func() error

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

+ UnregRecv func()

+ type LDP struct

+ func (*LDP) Reader(lom *LOM) (cos.ReadOpenCloser, cmn.ObjAttrsHolder, 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.MountpathInfo) error

+ func (lom *LOM) AllowDisconnectedBackend(loaded bool) (err error)

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

+ func (lom *LOM) AtimeUnix() int64

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

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

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

+ func (lom *LOM) CacheIdx() int

+ 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) ComputeCksum(cksumType string) (cksum *cos.CksumHash, err error)

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

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

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

+ func (lom *LOM) CopyAttrs(oah cmn.ObjAttrsHolder, skipCksum bool)

+ func (lom *LOM) CreateFile(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) DowngradeLock()

+ func (lom *LOM) ECEnabled() bool

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

+ func (lom *LOM) Equal(rem cmn.ObjAttrsHolder) (equal bool)

+ func (lom *LOM) FromFS() error

+ func (lom *LOM) FullName() string

+ 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 *Smap) (tsi *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.MountpathInfo)

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

+ func (lom *LOM) LoadMetaFromFS() error

+ func (lom *LOM) Location() string

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

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

+ func (lom *LOM) MpathInfo() *fs.MountpathInfo

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

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

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

+ func (lom *LOM) Uname() string

+ func (lom *LOM) Uncache(delDirty bool)

+ 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) Version(special ...bool) string

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

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

+ type NameLockPair struct

+ func (nlp *NameLockPair) Lock()

+ func (nlp *NameLockPair) TryLock(timeout time.Duration) (ok bool)

+ func (nlp *NameLockPair) TryRLock(timeout time.Duration) (ok bool)

+ func (nlp *NameLockPair) Unlock()

+ type Namespaces map[string]Buckets

+ type NetInfo struct

+ Hostname string

+ Port string

+ URL string

+ func NewNetInfo(proto, hostname, port string) *NetInfo

+ func (ni *NetInfo) Equals(other NetInfo) bool

+ func (ni *NetInfo) String() string

+ func (ni *NetInfo) TCPEndpoint() string

+ type Node interface

+ Bowner func() Bowner

+ ClusterStarted func() bool

+ DataClient func() *http.Client

+ NodeStarted func() bool

+ Snode func() *Snode

+ Sowner func() Sowner

+ type NodeMap map[string]*Snode

+ func NodeMapDelta(oldNodeMap, newNodeMap []NodeMap) (added, removed NodeMap)

+ func (m NodeMap) ActiveMap() (clone NodeMap)

+ func (m NodeMap) ActiveNodes() []*Snode

+ func (m NodeMap) Add(snode *Snode)

+ func (m NodeMap) Contains(daeID string) (exists bool)

+ type Nodes []*Snode

+ func AllocNodes(capacity int) (nodes Nodes)

+ func HrwTargetList(uname string, smap *Smap, count int) (sis Nodes, err error)

+ type Notif interface

+ LastNotifTime func() int64

+ NotifyInterval func() time.Duration

+ OnFinishedCB func() func(Notif, error)

+ OnProgressCB func() func(Notif)

+ SetLastNotified func(now int64)

+ Subscribers func() []string

+ ToNotifMsg func() NotifMsg

+ Upon func(u Upon) bool

+ type NotifMsg struct

+ Data []byte

+ ErrMsg string

+ Kind string

+ NodeID string

+ UUID string

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

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

+ type PromoteArgs struct

+ DaemonID string

+ DeleteSrc bool

+ ObjName string

+ OverwriteDst bool

+ Recursive bool

+ SrcFQN string

+ SrcIsNotFshare bool

+ type PromoteParams struct

+ Bck *Bck

+ Cksum *cos.Cksum

+ Xact Xact

+ type Providers map[string]Namespaces

+ type PutObjectParams struct

+ Atime time.Time

+ Cksum *cos.Cksum

+ OWT cmn.OWT

+ Reader io.ReadCloser

+ SkipEncode bool

+ WorkTag string

+ Xact Xact

+ func AllocPutObjParams() (a *PutObjectParams)

+ type QuiCB func(elapsed time.Duration) QuiRes

+ type QuiRes int

+ type RMD struct

+ Ext any

+ Resilver string

+ TargetIDs []string

+ Version int64

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

+ type RemAis struct

+ Alias string

+ Smap *Smap

+ URL string

+ UUID string

+ type Remotes struct

+ A []*RemAis

+ Ver int64

+ type Slistener interface

+ ListenSmapChanged func()

+ String func() string

+ type Smap struct

+ CreationTime string

+ Ext any

+ Pmap NodeMap

+ Primary *Snode

+ Tmap NodeMap

+ UUID string

+ Version int64

+ func (*Smap) DefaultICSize() int

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

+ func (m *Smap) Compare(other *Smap) (uuid string, sameOrigin, sameVersion, eq bool)

+ func (m *Smap) CompareTargets(other *Smap) (equal bool)

+ func (m *Smap) Count() int

+ func (m *Smap) CountActiveProxies() (count int)

+ func (m *Smap) CountActiveTargets() (count int)

+ func (m *Smap) CountNonElectable() (count int)

+ func (m *Smap) CountProxies() int

+ func (m *Smap) CountTargets() int

+ func (m *Smap) GetNode(id string) *Snode

+ func (m *Smap) GetNodeNotMaint(sid string) (si *Snode)

+ func (m *Smap) GetProxy(pid string) *Snode

+ func (m *Smap) GetRandProxy(excludePrimary bool) (si *Snode, err error)

+ func (m *Smap) GetRandTarget() (tsi *Snode, err error)

+ func (m *Smap) GetTarget(sid string) *Snode

+ func (m *Smap) ICCount() int

+ func (m *Smap) InitDigests()

+ func (m *Smap) IsDuplicate(nsi *Snode) (osi *Snode, err error)

+ func (m *Smap) IsIC(psi *Snode) (ok bool)

+ func (m *Smap) IsPrimary(si *Snode) bool

+ func (m *Smap) NewTmap(tids []string) (tmap NodeMap, err error)

+ func (m *Smap) NonElectable(psi *Snode) (ok bool)

+ func (m *Smap) PresentInMaint(si *Snode) (ok bool)

+ func (m *Smap) StrIC(node *Snode) string

+ func (m *Smap) String() string

+ func (m *Smap) StringEx() string

+ type SmapListeners interface

+ Reg func(sl Slistener)

+ Unreg func(sl Slistener)

+ type Snode struct

+ ControlNet NetInfo

+ DaeID string

+ DaeType string

+ DataNet NetInfo

+ Ext any

+ Flags cos.BitFlags

+ LocalNet *net.IPNet

+ PubNet NetInfo

+ func HrwIC(smap *Smap, uuid string) (pi *Snode, err error)

+ func HrwProxy(smap *Smap, idToSkip string) (pi *Snode, err error)

+ func HrwTarget(uname string, smap *Smap) (si *Snode, err error)

+ func HrwTargetAll(uname string, smap *Smap) (si *Snode, err error)

+ func HrwTargetTask(uuid string, smap *Smap) (si *Snode, err error)

+ func NewSnode(id, daeType string, publicNet, intraControlNet, intraDataNet NetInfo) (snode *Snode)

+ func (d *Snode) Clone() *Snode

+ func (d *Snode) Digest() uint64

+ func (d *Snode) Equals(o *Snode) (eq bool)

+ func (d *Snode) ID() string

+ func (d *Snode) Init(id, daeType string)

+ func (d *Snode) IsAnySet(flags cos.BitFlags) bool

+ func (d *Snode) IsProxy() bool

+ func (d *Snode) IsTarget() bool

+ func (d *Snode) Name() string

+ func (d *Snode) SetName()

+ func (d *Snode) String() string

+ func (d *Snode) StringEx() string

+ func (d *Snode) Type() string

+ func (d *Snode) URL(network string) string

+ func (d *Snode) Validate() error

+ type Sowner interface

+ Get func() (smap *Smap)

+ Listeners func() SmapListeners

+ type Target interface

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

+ Backend func(*Bck) BackendProvider

+ ByteMM func() *memsys.MMSA

+ CompareObjects func(ctx context.Context, lom *LOM) (equal bool, errCode int, err error)

+ CopyObject func(lom *LOM, params *CopyObjectParams, dryRun bool) (int64, error)

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

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

+ FSHC func(err error, path string)

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

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

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

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

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

+ PageMM func() *memsys.MMSA

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

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

+ RebalanceNamespace func(si *Snode) (body []byte, errCode int, err error)

+ SID func() string

+ String func() string

+ var T Target

+ type Upon int

+ type Xact interface

+ Abort func(error) bool

+ AbortErr func() error

+ AbortedAfter func(time.Duration) error

+ AddNotif func(n Notif)

+ Bck func() *Bck

+ ChanAbort func() <-chan error

+ EndTime func() time.Time

+ Finish func(error)

+ Finished func() bool

+ FromTo func() (*Bck, *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

+ Result func() (any, error)

+ Run func(*sync.WaitGroup)

+ Running func() bool

+ Snap func() XactSnap

+ StartTime func() time.Time

+ String func() string

+ type XactSnap interface

+ Finished func() bool

+ IsAborted func() bool

+ Running func() bool

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