ec

Dec 5, 2025

Changes in this version

type XactBckEncode

+ func (r *XactBckEncode) CtlMsg() (s string)

type XactGet

+ func (*XactGet) CtlMsg() string

type XactPut

+ func (*XactPut) CtlMsg() string

type XactRespond

+ func (*XactRespond) CtlMsg() string

Feb 7, 2025

Changes in this version

type Manager

+ func (mgr *Manager) Recover(lom *core.LOM) error

type XactBckEncode

+ func (r *XactBckEncode) RecvRecover(lom *core.LOM)

Sep 27, 2024

Changes in this version

type Manager

+ func (mgr *Manager) CloseStreams(justRefc bool)

+ func (mgr *Manager) IsActive() bool

+ func (mgr *Manager) OpenStreams(withRefc bool)

May 27, 2024

Changes in this version

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

Feb 25, 2024

Changes in this version

type Manager

+ func (mgr *Manager) BMDChanged() error

Mar 31, 2023

Changes in this version

type XactBckEncode

+ func (r *XactBckEncode) Snap() (snap *cluster.Snap)

Nov 7, 2022

Changes in this version

+ const ActClearRequests

+ const ActDelete

+ const ActEnableRequests

+ const ActRestore

+ const ActSplit

+ const MDVersionLast

+ const ReqStreamName

+ const RespStreamName

+ const URLCT

+ const URLMeta

+ var ErrorECDisabled = errors.New("EC is disabled for bucket")

+ var ErrorNoMetafile = errors.New("no metafile")

+ var ErrorNotFound = errors.New("not found")

+ func Init(t cluster.Target)

+ func IsECCopy(size int64, ecConf *cmn.ECConf) bool

+ func SliceSize(fileSize int64, slices int) int64

+ func WriteReplicaAndMeta(t cluster.Target, lom *cluster.LOM, args *WriteArgs) (err error)

+ func WriteSliceAndMeta(t cluster.Target, hdr *transport.ObjHdr, args *WriteArgs) error

+ type BckXacts struct

+ func (xacts *BckXacts) AbortGet()

+ func (xacts *BckXacts) AbortPut()

+ func (xacts *BckXacts) Get() *XactGet

+ func (xacts *BckXacts) Put() *XactPut

+ func (xacts *BckXacts) Req() *XactRespond

+ func (xacts *BckXacts) SetGet(xctn *XactGet)

+ func (xacts *BckXacts) SetPut(xctn *XactPut)

+ func (xacts *BckXacts) SetReq(xctn *XactRespond)

+ type ExtECGetStats struct

+ AvgObjTime cos.Duration

+ AvgQueueLen float64

+ AvgTime cos.Duration

+ ErrCount int64

+ IsIdle bool

+ type ExtECPutStats struct

+ AvgDeleteTime cos.Duration

+ AvgEncodeTime cos.Duration

+ AvgObjTime cos.Duration

+ AvgQueueLen float64

+ DeleteCount int64

+ DeleteErrCount int64

+ EncodeCount int64

+ EncodeErrCount int64

+ EncodeSize int64

+ IsIdle bool

+ type Manager struct

+ var ECM *Manager

+ func (*Manager) String() string

+ func (mgr *Manager) BucketsMDChanged() error

+ func (mgr *Manager) CleanupObject(lom *cluster.LOM)

+ func (mgr *Manager) EncodeObject(lom *cluster.LOM, cb ...cluster.OnFinishObj) error

+ func (mgr *Manager) ListenSmapChanged()

+ func (mgr *Manager) NewGetXact(bck *cmn.Bck) *XactGet

+ func (mgr *Manager) NewPutXact(bck *cmn.Bck) *XactPut

+ func (mgr *Manager) NewRespondXact(bck *cmn.Bck) *XactRespond

+ func (mgr *Manager) RestoreBckGetXact(bck *cluster.Bck) (xget *XactGet)

+ func (mgr *Manager) RestoreBckPutXact(bck *cluster.Bck) (xput *XactPut)

+ func (mgr *Manager) RestoreBckRespXact(bck *cluster.Bck) (xrsp *XactRespond)

+ func (mgr *Manager) RestoreObject(lom *cluster.LOM) error

+ type Metadata struct

+ CksumType string

+ CksumValue string

+ Daemons cos.MapStrUint16

+ Data int

+ FullReplica string

+ Generation int64

+ IsCopy bool

+ MDVersion uint32

+ ObjCksum string

+ ObjVersion string

+ Parity int

+ Size int64

+ SliceID int

+ func LoadMetadata(fqn string) (*Metadata, error)

+ func MetaFromReader(reader io.Reader) (*Metadata, error)

+ func NewMetadata() *Metadata

+ func ObjectMetadata(bck *cluster.Bck, objName string) (*Metadata, error)

+ func RequestECMeta(bck *cmn.Bck, objName string, si *cluster.Snode, client *http.Client) (md *Metadata, err error)

+ func (md *Metadata) Clone() *Metadata

+ func (md *Metadata) NewPack() []byte

+ func (md *Metadata) Pack(packer *cos.BytePack)

+ func (md *Metadata) PackedSize() int

+ func (md *Metadata) RemoteTargets(t cluster.Target) []*cluster.Snode

+ func (md *Metadata) Unpack(unpacker *cos.ByteUnpack) (err error)

+ type RequestsControlMsg struct

+ Action string

+ type Stats struct

+ Bck cmn.Bck

+ DecodeErr int64

+ DecodeTime time.Duration

+ DelReq int64

+ DeleteErr int64

+ DeleteTime time.Duration

+ EncodeErr int64

+ EncodeSize int64

+ EncodeTime time.Duration

+ GetReq int64

+ IsIdle bool

+ ObjTime time.Duration

+ PutReq int64

+ QueueLen float64

+ WaitTime time.Duration

+ func (s *Stats) String() string

+ type WriteArgs struct

+ BID uint64

+ Cksum *cos.Cksum

+ Generation int64

+ MD []byte

+ Reader io.Reader

+ Xact cluster.Xact

+ type XactBckEncode struct

+ func (r *XactBckEncode) Run(wg *sync.WaitGroup)

+ type XactGet struct

+ func NewGetXact(t cluster.Target, bck *cmn.Bck, mgr *Manager) *XactGet

+ func (r *XactGet) ClearRequests()

+ func (r *XactGet) DispatchResp(iReq intraReq, hdr *transport.ObjHdr, bck *cluster.Bck, reader io.Reader)

+ func (r *XactGet) ECStats() *Stats

+ func (r *XactGet) EnableRequests()

+ func (r *XactGet) Run(*sync.WaitGroup)

+ func (r *XactGet) Snap() cluster.XactSnap

+ func (r *XactGet) Stop(err error)

+ type XactPut struct

+ func NewPutXact(t cluster.Target, bck *cmn.Bck, mgr *Manager) *XactPut

+ func (r *XactPut) ClearRequests()

+ func (r *XactPut) ECStats() *Stats

+ func (r *XactPut) EnableRequests()

+ func (r *XactPut) Run(*sync.WaitGroup)

+ func (r *XactPut) Snap() cluster.XactSnap

+ func (r *XactPut) Stop(err error)

+ type XactRespond struct

+ func NewRespondXact(t cluster.Target, bck *cmn.Bck, mgr *Manager) *XactRespond

+ func (r *XactRespond) DispatchReq(iReq intraReq, hdr *transport.ObjHdr, bck *cluster.Bck)

+ func (r *XactRespond) DispatchResp(iReq intraReq, hdr *transport.ObjHdr, object io.Reader)

+ func (r *XactRespond) ECStats() *Stats

+ func (r *XactRespond) Run(*sync.WaitGroup)

+ func (r *XactRespond) Snap() cluster.XactSnap

+ func (r *XactRespond) Stop(err error)