controller

Documentation

Index

• type DesignDoc
  • func (v DesignDoc) Rebuild(ctx context.Context, task *model.Task, idx port.DocumentIndex) error
  • func (v DesignDoc) ReduceDocs(ctx context.Context, tx *storage.Transaction, idx port.DocumentIndex, ...) (map[any]any, int, error)
• type Task
  • func (c Task) ProcessAllTasks(ctx context.Context) error
  • func (c Task) ProcessTask(ctx context.Context, task *model.Task) error
  • func (c Task) ProcessTasksForDatabase(ctx context.Context, db *storage.Database) error
  • func (c Task) Run(ctx context.Context)

Types

type DesignDoc

type DesignDoc struct {
	DB *storage.Database
}

func (DesignDoc) Rebuild

func (v DesignDoc) Rebuild(ctx context.Context, task *model.Task, idx port.DocumentIndex) error

func (DesignDoc) ReduceDocs

func (v DesignDoc) ReduceDocs(ctx context.Context, tx *storage.Transaction, idx port.DocumentIndex, opts port.AllDocsQuery, view *model.View) (map[any]any, int, error)

type Task

type Task struct {
	Storage *storage.Storage
}

func (Task) ProcessAllTasks

func (c Task) ProcessAllTasks(ctx context.Context) error

func (Task) ProcessTask

func (c Task) ProcessTask(ctx context.Context, task *model.Task) error

func (Task) ProcessTasksForDatabase

func (c Task) ProcessTasksForDatabase(ctx context.Context, db *storage.Database) error

func (Task) Run

func (c Task) Run(ctx context.Context)