pathtask

Documentation

Index

• Variables
• type Repo
  • func NewRepository(db *sqlx.DB) *Repo
  • func (r *Repo) Create(from, to string) (*Task, error)
  • func (r *Repo) Get(id uuid.UUID) (*Task, error)
  • func (r *Repo) SetResult(id uuid.UUID, result *Result) error
  • func (r *Repo) UpdateStatus(id uuid.UUID, oldStatus, newStatus Status) error
• type Repository
• type Result
  • func (r *Result) Scan(value interface{}) error
  • func (r *Result) Value() (driver.Value, error)
• type Status
• type Task

Variables

var ErrNotFound = errors.New("not found")

Types

type Repo

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

func NewRepository

func NewRepository(db *sqlx.DB) *Repo

func (*Repo) Create

func (r *Repo) Create(from, to string) (*Task, error)

func (*Repo) Get

func (r *Repo) Get(id uuid.UUID) (*Task, error)

func (*Repo) SetResult

func (r *Repo) SetResult(id uuid.UUID, result *Result) error

func (*Repo) UpdateStatus

func (r *Repo) UpdateStatus(id uuid.UUID, oldStatus, newStatus Status) error

type Repository

type Repository interface {
	Create(from, to string) (*Task, error)
	Get(id uuid.UUID) (*Task, error)
	UpdateStatus(id uuid.UUID, oldStatus, newStatus Status) error
	SetResult(id uuid.UUID, result *Result) error
}

type Result

type Result struct {
	ShortestPath []string `json:"shortest_path"`
}

func (*Result) Scan

func (r *Result) Scan(value interface{}) error

func (*Result) Value

func (r *Result) Value() (driver.Value, error)

type Status

type Status uint

const (
	StatusPending Status = iota + 1
	StatusProcessing
	StatusDone
)

type Task

type Task struct {
	ID        uuid.UUID `db:"id"`
	CreatedAt time.Time `db:"created_at"`
	UpdatedAt time.Time `db:"updated_at"`

	From string `db:"from_page"`
	To   string `db:"to_page"`

	Status Status `db:"status"`

	Result *Result `db:"result"`
}