ingestnotification

package
v1.0.0-beta.136 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 5, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

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 (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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL