binlog

Documentation

Index

• func BuildLogPath(binlogType storage.BinlogType, ...) (string, error)
• func CompressBinLogs(binlogs ...[]*datapb.FieldBinlog) error
• func CompressCompactionBinlogs(binlogs []*datapb.CompactionSegment) error
• func CompressFieldBinlogs(fieldBinlogs []*datapb.FieldBinlog) error
• func CompressSaveBinlogPaths(req *datapb.SaveBinlogPathsRequest) error
• func DecompressBinLog(binlogType storage.BinlogType, ...) error
• func DecompressBinLogs(s *datapb.SegmentInfo) error
• func DecompressCompactionBinlogs(binlogs []*datapb.CompactionSegmentBinlogs) error
• func DecompressMultiBinLogs(infos []*datapb.SegmentInfo) error
• func GetLogIDFromBingLogPath(logPath string) (int64, error)

Functions

func BuildLogPath

func BuildLogPath(binlogType storage.BinlogType, collectionID, partitionID, segmentID, fieldID, logID typeutil.UniqueID) (string, error)

build a binlog path on the storage by metadata

func CompressBinLogs

func CompressBinLogs(binlogs ...[]*datapb.FieldBinlog) error

func CompressCompactionBinlogs

func CompressCompactionBinlogs(binlogs []*datapb.CompactionSegment) error

func CompressFieldBinlogs

func CompressFieldBinlogs(fieldBinlogs []*datapb.FieldBinlog) error

func CompressSaveBinlogPaths

func CompressSaveBinlogPaths(req *datapb.SaveBinlogPathsRequest) error

func DecompressBinLog

func DecompressBinLog(binlogType storage.BinlogType, collectionID, partitionID,
	segmentID typeutil.UniqueID, fieldBinlogs []*datapb.FieldBinlog,
) error

func DecompressBinLogs

func DecompressBinLogs(s *datapb.SegmentInfo) error

func DecompressCompactionBinlogs

func DecompressCompactionBinlogs(binlogs []*datapb.CompactionSegmentBinlogs) error

func DecompressMultiBinLogs

func DecompressMultiBinLogs(infos []*datapb.SegmentInfo) error

func GetLogIDFromBingLogPath

func GetLogIDFromBingLogPath(logPath string) (int64, error)

GetLogIDFromBingLogPath get log id from binlog path