Documentation
¶
Index ¶
Constants ¶
View Source
const (
EventIngestion spec.EventName = "ingestion"
)
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 IngestEvent ¶
type IngestEvent 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 (IngestEvent) Spec ¶
func (i IngestEvent) Spec() *spec.EventTypeSpec
func (IngestEvent) Validate ¶
func (i IngestEvent) Validate() error
Click to show internal directories.
Click to hide internal directories.