item

Documentation

Index

• Variables
• type Item
• type ItemMetadata
• type ItemParams
• type ItemStore
  • func NewItemStore(ctx context.Context, database db.Queue, nodeStore dag.NodeStore[dag.IOSpec]) (ItemStore, error)
• type ListParams
  • func NewListParams() ListParams
• type QueueRepository
  • func NewQueueRepository(repo ItemStore, priorityQueue queue.Queue, secondaryQueue queue.Queue, ...) (QueueRepository, error)

Variables

var (
	MaxTime             = time.Unix(1<<63-62135596801, 999999999)
	ErrSortNotSupported = fmt.Errorf("sort parameter not supported")
)

var (
	ErrInvalidRequestID  = fmt.Errorf("invalid request id")
	ErrInvalidRequestCID = fmt.Errorf("invalid request cid")
)

Types

type Item

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

type ItemMetadata

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

type ItemParams

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

type ItemStore

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)
}

ItemStore is an interface to retrieve and store items

func NewItemStore

func NewItemStore(ctx context.Context, database db.Queue, nodeStore dag.NodeStore[dag.IOSpec]) (ItemStore, error)

type ListParams

type ListParams struct {
	PageSize   int
	PageNumber int
	Sort       string
}

func NewListParams

func NewListParams() ListParams

type QueueRepository

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
}

QueueRepository is a repository of Queue items

func NewQueueRepository

func NewQueueRepository(repo ItemStore, priorityQueue queue.Queue, secondaryQueue queue.Queue, taskFactory task.TaskFactory, nodeExecutor dag.NodeExecutor[dag.IOSpec]) (QueueRepository, error)