Documentation
¶
Index ¶
Constants ¶
View Source
const (
EventSubsystem spec.EventSubsystem = "ingest"
)
Variables ¶
This section is empty.
Functions ¶
func NewHandler ¶
func NewHandler(logger *slog.Logger, metricMeter metric.Meter, publisher publisher.TopicPublisher) (flushhandler.FlushEventHandler, error)
Types ¶
type EventIngested ¶
type EventIngested struct {
Namespace models.NamespaceID `json:"namespace"`
SubjectKey string `json:"subjectKey"`
// MeterSlugs contain the list of slugs that are affected by the event. We
// should not use meterIDs as they are not something present in the open source
// version, thus any code that is in opensource should not rely on them.
MeterSlugs []string `json:"meterSlugs"`
}
func (EventIngested) Spec ¶
func (i EventIngested) Spec() *spec.EventTypeSpec
func (EventIngested) Validate ¶
func (i EventIngested) Validate() error
Click to show internal directories.
Click to hide internal directories.