downsample

Documentation

Index

• type Service
  • func NewService(interval time.Duration) *Service

Types

type Service

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 {
		StartDownSampleTask(sdsp *meta.ShardDownSamplePolicyInfo, schema []hybridqp.Catalog, log *zap.Logger, meta interface {
			UpdateShardDownSampleInfo(Ident *meta.ShardIdentifier) error
		}) error
		GetShardDownSamplePolicyInfos(meta interface {
			UpdateShardDownSampleInfo(Ident *meta.ShardIdentifier) error
		}) ([]*meta.ShardDownSamplePolicyInfo, error)
		GetDownSamplePolicy(key string) *meta.StoreDownSamplePolicy
		UpdateDownSampleInfo(policies *meta.DownSamplePoliciesInfoWithDbRp)
	}
}

include Shard retention polices and Index retention polices

func NewService

func NewService(interval time.Duration) *Service