downsample

type Service struct {
	services.Base

	MetaClient interface {
		GetDownSamplePolicies() (*meta.DownSamplePoliciesInfoWithDbRp, error)
		GetMstInfoWithInRp(dbName, rpName string, dataTypes []int64) (*meta.RpMeasurementsFieldsInfo, error)
		UpdateShardDownSampleInfo(Ident *meta.ShardIdentifier) error
	}

	Engine interface {
		ResetDownSampleFlag()
		RemoveDeadDownSamplePolicy()
		StartDownSampleTask(sdsp *meta.ShardDownSamplePolicyInfo, schema []hybridqp.Catalog, log *zap.Logger, meta interface {
			UpdateShardDownSampleInfo(Ident *meta.ShardIdentifier) error
		}) error
		UpdateStoreDownSamplePolicies(info *meta.DownSamplePolicyInfo, ident string)
		GetShardDownSamplePolicyInfos(meta interface {
			UpdateShardDownSampleInfo(Ident *meta.ShardIdentifier) error
		}) ([]*meta.ShardDownSamplePolicyInfo, error)
		GetDownSamplePolicy(key string) *meta.StoreDownSamplePolicy
		UpdateDownSampleInfo(policies *meta.DownSamplePoliciesInfoWithDbRp)
	}
}