ec

type ExtECGetStats struct {
	AvgTime     cos.Duration `json:"ec.decode.ns"`
	ErrCount    int64        `json:"ec.decode.err.n,string"`
	AvgObjTime  cos.Duration `json:"ec.obj.process.ns"`
	AvgQueueLen float64      `json:"ec.queue.len.f"`
	IsIdle      bool         `json:"is_idle"`
}

type ExtECPutStats struct {
	AvgEncodeTime  cos.Duration `json:"ec.encode.ns"`
	AvgDeleteTime  cos.Duration `json:"ec.delete.ns"`
	EncodeCount    int64        `json:"ec.encode.n,string"`
	DeleteCount    int64        `json:"ec.delete.n,string"`
	EncodeSize     int64        `json:"ec.encode.size,string"`
	EncodeErrCount int64        `json:"ec.encode.err.n,string"`
	DeleteErrCount int64        `json:"ec.delete.err.n,string"`
	AvgObjTime     cos.Duration `json:"ec.obj.process.ns"`
	AvgQueueLen    float64      `json:"ec.queue.len.f"`
	IsIdle         bool         `json:"is_idle"`
}

type Manager struct {
	// contains filtered or unexported fields
}

type Metadata struct {
	Size        int64            `json:"obj_size"`      // obj size (after EC'ing sum size of slices differs from the original)
	Generation  int64            `json:"generation"`    // Timestamp when the object was EC'ed
	ObjCksum    string           `json:"obj_cksum"`     // checksum of the original object
	ObjVersion  string           `json:"obj_version"`   // object version
	CksumType   string           `json:"cksum_type"`    // slice checksum type
	CksumValue  string           `json:"slice_cksum"`   // slice checksum of the slice if EC is used
	FullReplica string           `json:"replica_node"`  // daemon ID where full(main) replica is
	Daemons     cos.MapStrUint16 `json:"nodes"`         // Locations of all slices: DaemonID <-> SliceID
	Data        int              `json:"data_slices"`   // the number of data slices
	Parity      int              `json:"parity_slices"` // the number of parity slices
	SliceID     int              `json:"slice_id"`      // 0 for full replica, 1 to N for slices
	MDVersion   uint32           `json:"md_version"`    // Metadata format version
	IsCopy      bool             `json:"is_copy"`       // object is replicated(true) or encoded(false)
}

type RequestsControlMsg struct {
	Action string
}

type Stats struct {
	// mpathrunner(not ecrunner) queue len
	QueueLen float64
	// time between ecrunner receives an object and mpathrunner starts processing it
	WaitTime time.Duration
	// EC encoding time (for both EC'ed and replicated objects)
	EncodeTime time.Duration
	// size of a file put into encode queue
	EncodeSize int64
	// total number of errors while encoding objects
	EncodeErr int64
	// total number of errors while restoring objects
	DecodeErr int64
	// time to restore an object(for both EC'ed and replicated objects)
	DecodeTime time.Duration
	// time to cleanup object's slices(for both EC'ed and replicated objects)
	DeleteTime time.Duration
	// total number of errors while cleaning up object slices
	DeleteErr int64
	// total object processing time: from putting to ecrunner queue to
	// completing the request by mpathrunner
	ObjTime time.Duration
	// total number of cleanup requests
	DelReq int64
	// total number of restore requests
	GetReq int64
	// total number of encode requests
	PutReq int64
	// name of the bucket
	Bck cmn.Bck
	// xaction state: working or waiting for commands
	IsIdle bool
}

type WriteArgs struct {
	MD         []byte     // CT's metafile content
	Reader     io.Reader  // CT content
	BID        uint64     // bucket ID
	Cksum      *cos.Cksum // object checksum
	Generation int64      // EC Generation
	Xact       core.Xact  // xaction that drives it
}

type XactBckEncode struct {
	xact.Base
	// contains filtered or unexported fields
}

type XactGet struct {
	// contains filtered or unexported fields
}

type XactPut struct {
	// contains filtered or unexported fields
}

type XactRespond struct {
	// contains filtered or unexported fields
}