retention

Documentation

Index

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

Types

type Service

type Service struct {
	services.Base

	MetaClient interface {
		PruneGroupsCommand(shardGroup bool, id uint64) error
		GetShardDurationInfo(index uint64) (*meta.ShardDurationResponse, error)
		DeleteShardGroup(database, policy string, id uint64) error
		DeleteIndexGroup(database, policy string, id uint64) error
	}

	Engine interface {
		DeleteIndex(db string, ptId uint32, indexID uint64) error
		UpdateShardDurationInfo(info *meta.ShardDurationInfo) error
		ExpiredShards() []*meta.ShardIdentifier
		ExpiredIndexes() []*meta.IndexIdentifier
		ExpiredCacheIndexes() []*meta.IndexIdentifier
		DeleteShard(db string, ptId uint32, shardID uint64) error
		ClearIndexCache(db string, ptId uint32, indexID uint64) error
	}
	// contains filtered or unexported fields
}

include Shard retention polices and Index retention polices

func NewService

func NewService(interval time.Duration) *Service