item

type Item struct {
	ID        uuid.UUID
	RootNodes []dag.Node[dag.IOSpec]
	CID       string
	Metadata  ItemMetadata
}

type ItemMetadata struct {
	CreatedAt time.Time
	StartedAt time.Time
	EndedAt   time.Time
}

type ItemParams struct {
	ID       uuid.UUID
	CID      string
	Priority bool
}

type ItemStore interface {
	NewItem(ctx context.Context, params ItemParams) error
	ListItems(ctx context.Context, params ListParams) ([]*Item, error)
	CountItems(ctx context.Context) (int64, error)
	GetItem(ctx context.Context, id uuid.UUID) (*Item, error)
}

type ListParams struct {
	PageSize   int
	PageNumber int
	Sort       string
}

type QueueRepository interface {
	List(context.Context, ListParams) ([]*Item, error)
	Count(context.Context) (int64, error)
	Get(context.Context, uuid.UUID) (*Item, error)
	Create(context.Context, ItemParams) error
}