package helpers

import "github.com/influxdata/influxdb/services/retention/helpers"

Index ¶

• func DataDeleteShardGroup(targetData *meta.Data, now time.Time, database, policy string, id uint64) error
• func DataNukeShardGroup(targetData *meta.Data, targetDB, targetRP string, targetID uint64) error

Functions ¶

func DataDeleteShardGroup ¶

func DataDeleteShardGroup(targetData *meta.Data, now time.Time, database, policy string, id uint64) error

DataDeleteShardGroup deletes the shard group specified by database, policy, and id from targetData. It does this by setting the shard group's DeletedAt time to now. We have to reimplement DeleteShardGroup instead of using data's so that the DeletedAt time will be deterministic. We are also not testing the functionality of DeleteShardGroup. We are testing if DeleteShardGroup gets called correctly.

func DataNukeShardGroup ¶

func DataNukeShardGroup(targetData *meta.Data, targetDB, targetRP string, targetID uint64) error

DataNukeShardGroup unconditionally removes the shard group identified by targetDB, targetRP, and targetID from targetData. There's no meta.Data method to directly remove a shard group, only to mark it deleted and then prune it. We can't use the functionality we're testing to generate the expected result.

Source Files ¶

test_helpers.go