Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RedisSink ¶
type RedisSink struct {
// contains filtered or unexported fields
}
RedisSink writes execution counts to Redis. Best-effort: errors are logged internally and never propagated.
func NewRedisSink ¶
NewRedisSink creates a new Redis analytics sink.
func (*RedisSink) Record ¶
func (s *RedisSink) Record(ctx context.Context, event domain.TriggerEvent, config domain.AnalyticsConfig)
Record increments the execution count for the given event's minute bucket. Returns immediately if analytics is not enabled. Errors are logged but never returned; analytics must not affect dispatch correctness.
Source Files
Click to show internal directories.
Click to hide internal directories.