Function NewService

coderd/x/chatd/chatdebug/service.go:145–162

NewService constructs a chat debug persistence service.

(db database.Store, log slog.Logger, ps pubsub.Pubsub, opts ...ServiceOption)

// NewService constructs a chat debug persistence service.
func NewService(db database.Store, log slog.Logger, ps pubsub.Pubsub, opts ...ServiceOption) *Service {
	if db == nil {
		panic("chatdebug: nil database.Store")
	}

	s := &Service{
		db:               db,
		log:              log,
		pubsub:           ps,
		clock:            quartz.NewReal(),
		thresholdChanged: make(chan struct{}),
	}
	s.staleAfterNanos.Store(DefaultStaleThreshold.Nanoseconds())
	for _, opt := range opts {
		opt(s)
	}
	return s
}

// SetStaleAfter overrides the in-flight stale threshold used when
// finalizing abandoned debug rows. Zero or negative durations are