meterevent

type Event struct {
	// The event ID.
	ID string
	// The event type.
	Type string
	// The event source.
	Source string
	// The event subject.
	Subject string
	// The event time.
	Time time.Time
	// The event data as a JSON string.
	Data string
	// The event customer ID.
	CustomerID *string
	// The time the event was ingested.
	IngestedAt time.Time
	// The time the event was stored.
	StoredAt time.Time
	// StoreRowID is the unique per-row identifier assigned at ingest time.
	// Used as the cursor tiebreak to avoid losing events that share the same
	// DateTime-second timestamp.
	StoreRowID string
	// SortBy is the sort column used to generate the cursor.
	SortBy streaming.EventSortField
	// Validation errors.
	ValidationErrors []error
}

type ListEventsParams struct {
	// The namespace.
	Namespace string
	// The client ID.
	ClientID *string
	// Start date-time. Inclusive.
	IngestedAtFrom *time.Time
	// End date-time. Inclusive.
	IngestedAtTo *time.Time
	// The event ID. Accepts partial ID.
	ID *string
	// The event subject. Accepts partial subject.
	Subject *string
	// The event customer ID.
	CustomerIDs *[]string
	// Start date-time. Inclusive.
	From time.Time
	// End date-time. Inclusive.
	To *time.Time
	// Number of events to return.
	Limit int
}

type ListEventsV2Params struct {
	// The namespace.
	Namespace string
	// The client ID.
	ClientID *string
	// The cursor.
	Cursor *pagination.Cursor
	// The limit.
	Limit *int
	// The ID filter.
	ID *filter.FilterString
	// The source filter.
	Source *filter.FilterString
	// The subject filter.
	Subject *filter.FilterString
	// The customer ID filter.
	CustomerID *filter.FilterString
	// The type filter.
	Type *filter.FilterString
	// The time filter.
	Time *filter.FilterTime
	// The ingested at filter.
	IngestedAt *filter.FilterTime
	// The stored at filter.
	StoredAt *filter.FilterTime
	// The sort column; zero value defaults to "time".
	SortBy streaming.EventSortField
	// The sort direction; zero value defaults to DESC.
	SortOrder sortx.Order
}

type Service interface {
	ListEvents(ctx context.Context, params ListEventsParams) ([]Event, error)
	ListEventsV2(ctx context.Context, params ListEventsV2Params) (pagination.Result[Event], error)
}