messages

package

v1.35.7 Latest Latest Go to latest Published: Feb 9, 2026 License: Apache-2.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

func Module() fx.Option

func NewCleanupTask(
	config CleanupConfig,
	messages *messages.Repository,
	logger *zap.Logger,
) executor.PeriodicTask

func NewInitialHashingTask(
	config HashingConfig,
	messages *messages.Repository,
	logger *zap.Logger,
) executor.PeriodicTask

type CleanupConfig struct {
	Interval time.Duration
	MaxAge   time.Duration
}

type Config struct {
	Hashing HashingConfig
	Cleanup CleanupConfig
}

type HashingConfig struct {
	Interval time.Duration
}