Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrNilLastHash indicates that there is no last hash entry ErrNilLastHash = errors.New("nil last hash") )
Functions ¶
func GetLashHashKey ¶
GetLashHashKey returns last hash key of a given vdisk ID
Types ¶
type DecodedAggregation ¶
type DecodedAggregation struct {
Agg *schema.TlogAggregation
Err error
}
DecodedAggregation defines a decoded tlog aggregation from decoder.
type Decoder ¶
type Decoder struct {
// contains filtered or unexported fields
}
Decoder defines tlog data decoder
func (*Decoder) Decode ¶
func (d *Decoder) Decode(startTs, endTs uint64) <-chan *DecodedAggregation
Decode decodes all tlog transaction started from startTs timestamp to endTs timestamp. If startTs == 0, it means from the beginning of transaction. If endTs == 0, it means until the end of transaction
func (*Decoder) GetLastHash ¶
GetLastHash returns valid last hash of a vdisk. It checks all data shards to get latest valid hash
Source Files
Click to show internal directories.
Click to hide internal directories.