libevents

type Config struct {
	// TablePrefix prefixes every table this package owns:
	// {prefix}cursors, {prefix}firings, {prefix}listeners,
	// {prefix}listener_topics, {prefix}staging.
	TablePrefix string
	// ScopeColumn is the tenancy column present on every table.
	ScopeColumn string
}

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

type Firing struct {
	Scope       string
	TriggerName string
	NID         int64
	Status      string
	Error       string
	RequestID   string
	CreatedAt   time.Time
	UpdatedAt   time.Time
}

type FiringFilter struct {
	// SinceNID keeps firings whose event nid is greater than it; 0 keeps all.
	SinceNID int64
	// Status keeps one FiringStatus* value; "" keeps all.
	Status string
	// TriggerName keeps one trigger's firings; "" keeps all.
	TriggerName string
	// Limit caps the page: <= 0 means DefaultFiringLimit, more than
	// MaxFiringLimit is clamped to it.
	Limit int
}

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

type FiringStoreOption func(*FiringStore)

type Listener struct {
	ID    string
	Scope string
	// Kind is ListenerKindStart or ListenerKindWake.
	Kind string
	// Target is opaque to this package; the dispatcher that owns the
	// listener interprets it.
	Target string
	// Owner keys bulk cleanup: every listener registered by one instance,
	// session, or configuration unit dies with it via DeleteListenersByOwner.
	Owner string
	// OneShot listeners are deleted by their consumer when they fire; the
	// store carries the flag, the dispatcher enforces it.
	OneShot bool
	// Types are the exact event types subscribed.
	Types []string
	// ContextFilters narrows matching beyond the type: per event type, a map
	// of attribute to glob pattern, all of which must match.
	ContextFilters map[string]map[string]string
	// Metadata is opaque JSON for the importer's extensions.
	Metadata  string
	CreatedAt time.Time
	UpdatedAt time.Time
}

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

type StagedEvent struct {
	ID           string
	Scope        string
	Payload      []byte
	DelayedUntil time.Time
	CreatedAt    time.Time
}

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