prune

package

v1.2.1 Latest Latest Go to latest Published: Aug 27, 2025 License: MIT Imports: 9 Imported by: 0

Details

View Source

const DEFAULT_GROUP_MESSAGE_LIFETIME_DAYS = 30

View Source

const DEFAULT_LIFETIME_OF_INSTALLATIONS = 90

View Source

const DEFAULT_LIFETIME_OF_KEY_PACKAGES = 90

View Source

const DEFAULT_LIFETIME_OF_WELCOME_MESSAGES = 90

This section is empty.

This section is empty.

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

func NewPruneExecutor(
	ctx context.Context,
	log *zap.Logger,
	writerDB *sql.DB,
	config *server.PruneConfig,
) *Executor

func (e *Executor) Run() error

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

func NewGroupMessagesPruner(
	log *zap.Logger,
	querier *queries.Queries,
	batchSize int32,
) *GroupMessagesPruner

func (g *GroupMessagesPruner) Count(ctx context.Context) (int64, error)

func (g *GroupMessagesPruner) Name() string

func (g *GroupMessagesPruner) PruneCycle(ctx context.Context) (int, error)

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

func NewInstallationsPruner(
	log *zap.Logger,
	querier *queries.Queries,
	batchSize int32,
) *InstallationsPruner

func (ip *InstallationsPruner) Count(ctx context.Context) (int64, error)

func (ip *InstallationsPruner) Name() string

func (ip *InstallationsPruner) PruneCycle(ctx context.Context) (int, error)

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

func NewKeyPackagesPruner(
	log *zap.Logger,
	querier *queries.Queries,
	batchSize int32,
) *KeyPackagesPruner

func (ip *KeyPackagesPruner) Count(ctx context.Context) (int64, error)

func (ip *KeyPackagesPruner) Name() string

func (ip *KeyPackagesPruner) PruneCycle(ctx context.Context) (int, error)

type Pruner interface {
	Count(ctx context.Context) (int64, error)
	PruneCycle(ctx context.Context) (int, error)
	Name() string
}

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

func NewWelcomePruner(log *zap.Logger, querier *queries.Queries, batchSize int32) *WelcomePruner

func (w *WelcomePruner) Count(ctx context.Context) (int64, error)

func (w *WelcomePruner) Name() string

func (w *WelcomePruner) PruneCycle(ctx context.Context) (int, error)