rotator

Documentation

Index

• Constants
• Variables
• func PrefilledSourceAndTarget() (mongodataagent.MongoSource, ytcommon.YtDestination)
• func ScenarioCheckActivation(t *testing.T, source mongodataagent.MongoSource, target ytcommon.YtDestination, ...)

Constants

const (
	TimeColumnName = "partition_time"
)

constants (begin)

Variables

var (
	NoneRotation *server.RotatorConfig = nil
	DayRotation                        = &server.RotatorConfig{
		KeepPartCount:     14,
		PartType:          server.RotatorPartDay,
		PartSize:          1,
		TimeColumn:        TimeColumnName,
		TableNameTemplate: "",
	}
)

var (
	GlobalUID = 0
)

Functions

func PrefilledSourceAndTarget

func PrefilledSourceAndTarget() (mongodataagent.MongoSource, ytcommon.YtDestination)

func ScenarioCheckActivation

func ScenarioCheckActivation(
	t *testing.T,
	source mongodataagent.MongoSource,
	target ytcommon.YtDestination,
	table abstract.TableID,
	rotationTime time.Time,
	expectedTablePath ypath.Path,
)