retention

package

v0.52.7 Latest Latest Go to latest Published: Dec 6, 2024 License: MIT Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

func GetDataRetentionExpiredTime(duration string) (time.Time, error)

type RetentionController interface {
	Start(ctx context.Context) error
}

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

func New(fs ...RetentionControllerOpt) (*RetentionControllerImpl, error)

func (wc *RetentionControllerImpl) ForTenants(ctx context.Context, f func(ctx context.Context, tenant dbsqlc.Tenant) error) error

func (rc *RetentionControllerImpl) Start() (func() error, error)

type RetentionControllerOpt func(*RetentionControllerOpts)

func WithAlerter(a hatcheterrors.Alerter) RetentionControllerOpt

func WithDataDecoderValidator(dv datautils.DataDecoderValidator) RetentionControllerOpt

func WithDataRetention(b bool) RetentionControllerOpt

func WithLogger(l *zerolog.Logger) RetentionControllerOpt

func WithPartition(p *partition.Partition) RetentionControllerOpt

func WithRepository(r repository.EngineRepository) RetentionControllerOpt

func WithTenantAlerter(ta *alerting.TenantAlertManager) RetentionControllerOpt

func WithWorkerRetention(b bool) RetentionControllerOpt

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