filter

type DefaultWALFilter struct {
	WALFilter
	// contains filtered or unexported fields
}

type S3VersionFetcher struct {
	VersionHeaderName string
}

type StorageState struct {
	// contains filtered or unexported fields
}

type VersionFetcher interface {
	//Fetch should fetch object's version
	Fetch(auth *s3.MigrationAuth, bucketName string, key string) (*StorageState, error)
}

type WALFilter interface {
	Filter(walEntriesChannel <-chan *model.WALEntry) <-chan *model.WALTask
}