Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CleanupService ¶
type CleanupService struct {
// contains filtered or unexported fields
}
CleanupService handles automatic cleanup of old data
func NewCleanupService ¶
func NewCleanupService(config *config.Config, db database.DatabaseInterface, ctx context.Context) *CleanupService
NewCleanupService creates a new cleanup service instance
func (*CleanupService) Start ¶
func (cs *CleanupService) Start()
Start begins the cleanup service with periodic data cleanup
func (*CleanupService) Stop ¶
func (cs *CleanupService) Stop()
Stop gracefully stops the cleanup service
type EventOrderingService ¶
type EventOrderingService struct {
// contains filtered or unexported fields
}
func NewEventOrderingService ¶
func NewEventOrderingService(db database.DatabaseInterface, processFunc func(*models.OrderedEvent) error) *EventOrderingService
func (*EventOrderingService) AddEvent ¶
func (s *EventOrderingService) AddEvent(event *models.OrderedEvent) error
func (*EventOrderingService) Start ¶
func (s *EventOrderingService) Start()
func (*EventOrderingService) Stop ¶
func (s *EventOrderingService) Stop()
type MetricsUpdateService ¶
type MetricsUpdateService struct {
// contains filtered or unexported fields
}
func NewMetricsUpdateService ¶
func NewMetricsUpdateService(db database.DatabaseInterface, interval time.Duration, ctx context.Context) *MetricsUpdateService
func (*MetricsUpdateService) Start ¶
func (s *MetricsUpdateService) Start()
func (*MetricsUpdateService) Stop ¶
func (s *MetricsUpdateService) Stop()
Source Files
Click to show internal directories.
Click to hide internal directories.