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, config HandlerConfig) (flushhandler.FlushEventHandler, error)
Types ¶
type EventBatchedIngest ¶
type EventBatchedIngest struct {
Events []IngestEventData `json:"events"`
}
func (EventBatchedIngest) Spec ¶
func (b EventBatchedIngest) Spec() *spec.EventTypeSpec
func (EventBatchedIngest) Validate ¶
func (b EventBatchedIngest) Validate() error
type HandlerConfig ¶
type HandlerConfig struct {
MaxEventsInBatch int
}
type IngestEventData ¶
type IngestEventData 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 (IngestEventData) Validate ¶
func (i IngestEventData) Validate() error
Click to show internal directories.
Click to hide internal directories.