event

type Delivery struct {
	// contains filtered or unexported fields
}

type Envelope struct {
	SchemaVersion int                `json:"schema_version"`
	ID            string             `json:"event_id"`
	Family        string             `json:"family"`
	Timestamp     time.Time          `json:"timestamp"`
	Attribution   attribution.Value  `json:"attribution"`
	Outcome       string             `json:"outcome"`
	Reason        string             `json:"reason,omitempty"`
	Limiter       *LimiterAdmission  `json:"limiter_admission,omitempty"`
	Mutation      *ExtensionMutation `json:"extension_mutation,omitempty"`
}

type Error struct{ Code string }

type ExtensionMutation struct {
	ModuleID   string `json:"module_id"`
	Operation  string `json:"operation"`
	StateReset bool   `json:"state_reset,omitempty"`
}

type LimiterAdmission struct {
	Dimension  string        `json:"dimension"`
	RetryAfter time.Duration `json:"retry_after_ns"`
	BackendID  string        `json:"backend_id"`
}

type Options struct {
	QueueSize   int
	WriteBudget time.Duration
	Policy      attribution.Policy
}

type Publisher interface {
	Publish(context.Context, Envelope) bool
}

type Registration struct {
	ModuleID    string
	New         func(context.Context) (Sink, error)
	QueueSize   int
	WriteBudget time.Duration
}

type Sink interface {
	Write(context.Context, Envelope) error
	Flush(context.Context) error
	Close(context.Context) error
}

type Stats struct {
	Accepted  uint64 `json:"accepted"`
	Delivered uint64 `json:"delivered"`
	Dropped   uint64 `json:"dropped"`
	Rejected  uint64 `json:"rejected"`
	Failures  uint64 `json:"failures"`
	Healthy   bool   `json:"healthy"`
}