messages

package

v1.34.1 Latest Latest Go to latest Published: Nov 12, 2025 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
}