query

type Attribute struct {
	Name string
	// contains filtered or unexported fields
}

type Cursor interface {
	// Err returns the last error seen by the Cursor, or nil if no error has occurred.
	Err() error

	// Next prepares the next result to be read with the Scan method.
	// It returns true on success, or false if there is no next result row or an error
	// happened while preparing it. Err should be consulted to distinguish between the
	// two cases.
	//
	// Every call to Scan, even the first one, must be preceded by a call to Next.
	Next() bool

	// Scan copies the query row into the pointed values.
	Scan(values ...any) error

	// Close closes the cursor preventing further iterations.
	// If Next is called and returns false and there are no further result sets,
	// the cursor is closed automatically and it will suffice to check the result of Err.
	// This method is idempotent meaning that after the first call, any subsequent calls
	// will not change the state.
	Close() error
}

type Event struct {
	ID         int64
	TXHash     string
	Index      uint64
	Type       string
	Attributes []Attribute
	CreatedAt  time.Time
}

type EventQuery interface {
	Pager
	Filterer
}

type Filter interface {
	fmt.Stringer

	// Field returns the name of the filtered field.
	Field() string

	// Value returns the value to use for filtering.
	Value() any
}

type Filterer interface {
	// Filters returns the list of filters to apply to the query.
	Filters() []Filter
}

type Option func(*Query)

type Pager interface {
	// PageSize returns the size for each query result set.
	PageSize() uint32

	// AtPage returns the result set page to query.
	AtPage() uint32

	// IsPagingEnabled checks if the query results should be paginated.
	IsPagingEnabled() bool
}

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

type SortBy struct {
	Field string
	Order string
}