Method WriteLTXFile

vfs_write_test.go:76–98

(ctx context.Context, level int, minTXID, maxTXID ltx.TXID, r io.Reader)

}

func (c *writeTestReplicaClient) WriteLTXFile(ctx context.Context, level int, minTXID, maxTXID ltx.TXID, r io.Reader) (*ltx.FileInfo, error) {
	data, err := io.ReadAll(r)
	if err != nil {
		return nil, err
	}

	c.mu.Lock()
	defer c.mu.Unlock()

	key := ltxKey(level, minTXID, maxTXID)
	c.ltxData[key] = data

	info := &ltx.FileInfo{
		Level:     level,
		MinTXID:   minTXID,
		MaxTXID:   maxTXID,
		CreatedAt: time.Now(),
		Size:      int64(len(data)),
	}
	c.ltxFiles[level] = append(c.ltxFiles[level], info)

	return info, nil
}

func (c *writeTestReplicaClient) DeleteLTXFiles(ctx context.Context, a []*ltx.FileInfo) error {
	return nil