retention

Documentation

Index

• func GetDataRetentionExpiredTime(duration string) (time.Time, error)
• type RetentionController
• type RetentionControllerImpl
  • 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 WithAlerter(a hatcheterrors.Alerter) RetentionControllerOpt
  • func WithDataDecoderValidator(dv datautils.DataDecoderValidator) RetentionControllerOpt
  • func WithLogger(l *zerolog.Logger) RetentionControllerOpt
  • func WithPartitionId(partitionId string) RetentionControllerOpt
  • func WithRepository(r repository.EngineRepository) RetentionControllerOpt
  • func WithTenantAlerter(ta *alerting.TenantAlertManager) RetentionControllerOpt
• type RetentionControllerOpts

Functions

func GetDataRetentionExpiredTime

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

Types

type RetentionController

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

type RetentionControllerImpl

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

func New

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

func (*RetentionControllerImpl) ForTenants

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

func (*RetentionControllerImpl) Start

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

type RetentionControllerOpt

type RetentionControllerOpt func(*RetentionControllerOpts)

func WithAlerter

func WithAlerter(a hatcheterrors.Alerter) RetentionControllerOpt

func WithDataDecoderValidator

func WithDataDecoderValidator(dv datautils.DataDecoderValidator) RetentionControllerOpt

func WithLogger

func WithLogger(l *zerolog.Logger) RetentionControllerOpt

func WithPartitionId

func WithPartitionId(partitionId string) RetentionControllerOpt

func WithRepository

func WithRepository(r repository.EngineRepository) RetentionControllerOpt

func WithTenantAlerter

func WithTenantAlerter(ta *alerting.TenantAlertManager) RetentionControllerOpt

type RetentionControllerOpts

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