eventhub

type Config struct {
	PollInterval    time.Duration
	CleanupInterval time.Duration
	RetentionPeriod time.Duration
}

type Event struct {
	GatewayID           string    `json:"gateway_id"`
	ProcessedTimestamp  time.Time `json:"processed_timestamp"`
	OriginatedTimestamp time.Time `json:"originated_timestamp"`
	EventType           EventType `json:"event_type"`
	Action              string    `json:"action"`
	EntityID            string    `json:"entity_id"`
	EventID             string    `json:"event_id"`
	// EventData carries optional event-specific details that are not already
	// represented by top-level fields such as Action and EntityID.
	EventData string `json:"event_data"`
}

type EventHub interface {
	// Initialize sets up the event hub
	Initialize() error
	// RegisterGateway registers a new gateway for event tracking.
	RegisterGateway(gatewayID string) error
	// PublishEvent publishes an event for a gateway.
	PublishEvent(gatewayID string, event Event) error
	// Subscribe subscribes to events for a gateway.
	Subscribe(gatewayID string) (<-chan Event, error)
	// Unsubscribe removes a specific subscription for a gateway.
	Unsubscribe(gatewayID string, subscriber <-chan Event) error
	// UnsubscribeAll removes all subscriptions for a gateway.
	UnsubscribeAll(gatewayID string) error
	// CleanUpEvents removes old events
	CleanUpEvents() error
	// Close gracefully shuts down the event hub
	Close() error
}

type EventType string

type EventhubImpl interface {
	// Initialize sets up the backend
	Initialize() error
	// RegisterGateway registers a new gateway for event tracking.
	RegisterGateway(gatewayID string) error
	// Publish publishes an event for a gateway.
	Publish(gatewayID string, event Event) error
	// Subscribe subscribes to events for a gateway, returning a channel.
	Subscribe(gatewayID string) (<-chan Event, error)
	// Unsubscribe removes a specific subscription for a gateway.
	Unsubscribe(gatewayID string, subscriber <-chan Event) error
	// UnsubscribeAll removes all subscriptions for a gateway.
	UnsubscribeAll(gatewayID string) error
	// Cleanup removes events older than the retention period
	Cleanup(retentionPeriod time.Duration) error
	// CleanupRange removes events in a time range for a gateway.
	CleanupRange(gatewayID string, before time.Time) error
	// Close gracefully shuts down the backend
	Close() error
}

type GatewayState struct {
	GatewayID string    `json:"gateway_id"`
	VersionID string    `json:"version_id"`
	UpdatedAt time.Time `json:"updated_at"`
}

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

type SQLBackendConfig struct {
	PollInterval         time.Duration
	CleanupInterval      time.Duration
	RetentionPeriod      time.Duration
	GatewayStatePageSize int
}