process

Documentation

Index

• Variables
• type Fetch
  • func NewFetch(remote *storage.RemoteRepository, local storage.LocalRepository, ...) *Fetch
  • func (s *Fetch) Process() (*FetchResult, error)
• type FetchResult
• type Inbox
  • func NewInbox(repo *storage.RemoteRepository) *Inbox
  • func (inbox *Inbox) Process() (*InboxResult, error)
• type InboxResult
• type List
  • func NewList(local storage.LocalRepository, reqs ListReqs) *List
  • func (l *List) Process() (*ListResult, error)
• type ListReqs
  • func (lr ListReqs) Valid() bool
• type ListResult
• type New
  • func NewNew(local storage.LocalRepository, update *task.LocalUpdate) *New
  • func (n *New) Process() error
• type Projects
  • func NewProjects(local storage.LocalRepository) *Projects
  • func (p *Projects) Process() ([]string, error)
• type Recur
  • func NewRecur(repo *storage.RemoteRepository, disp *storage.Dispatcher, daysAhead int) *Recur
  • func (recur *Recur) Process() (*RecurResult, error)
• type RecurResult
• type Send
  • func NewSend(local storage.LocalRepository, disp *storage.Dispatcher) *Send
  • func (s *Send) Process() (int, error)
• type Update
  • func NewUpdate(local storage.LocalRepository, taskId string, update *task.LocalUpdate) *Update
  • func (u *Update) Process() error

Variables

var (
	ErrInvalidReqs = errors.New("could not make sense of requirements")
	ErrListProcess = errors.New("could not fetch task list")
)

var (
	ErrCouldNotFetchProjects = errors.New("could not fetch projects")
)

var (
	ErrFetchProcess = errors.New("could not fetch tasks")
)

var (
	ErrInboxProcess = errors.New("could not process inbox")
)

var (
	ErrNewTask = errors.New("could not add new task")
)

var (
	ErrRecurProcess = errors.New("could not generate tasks from recurrer")
)

var (
	ErrSendTasks = errors.New("could not send tasks")
)

var (
	ErrUpdateTask = errors.New("could not update tsk")
)

Types

type Fetch

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

Fetch fetches all tasks in regular folders from the remote repository and overwrites what is stored locally

func NewFetch

func NewFetch(remote *storage.RemoteRepository, local storage.LocalRepository, folders ...string) *Fetch

func (*Fetch) Process

func (s *Fetch) Process() (*FetchResult, error)

type FetchResult

type FetchResult struct {
	Duration string `json:"duration"`
	Count    int    `json:"count"`
}

type Inbox

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

Inbox processes all messages in INBOX in a remote repository

func NewInbox

func NewInbox(repo *storage.RemoteRepository) *Inbox

func (*Inbox) Process

func (inbox *Inbox) Process() (*InboxResult, error)

type InboxResult

type InboxResult struct {
	Duration string `json:"duration"`
	Count    int    `json:"count"`
}

type List

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

List finds all tasks that satisfy the given requirements

func NewList

func NewList(local storage.LocalRepository, reqs ListReqs) *List

func (*List) Process

func (l *List) Process() (*ListResult, error)

type ListReqs

type ListReqs struct {
	Due           task.Date
	IncludeBefore bool
	Folder        string
	Project       string
	ApplyUpdates  bool
}

ListReqs specifies the requirements in AND fashion for a list of tasks

func (ListReqs) Valid

func (lr ListReqs) Valid() bool

type ListResult

type ListResult struct {
	Tasks []*task.LocalTask
}

type New

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

func NewNew

func NewNew(local storage.LocalRepository, update *task.LocalUpdate) *New

func (*New) Process

func (n *New) Process() error

type Projects

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

func NewProjects

func NewProjects(local storage.LocalRepository) *Projects

func (*Projects) Process

func (p *Projects) Process() ([]string, error)

type Recur

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

Recur generates new tasks from a recurring task for a given day

func NewRecur

func NewRecur(repo *storage.RemoteRepository, disp *storage.Dispatcher, daysAhead int) *Recur

func (*Recur) Process

func (recur *Recur) Process() (*RecurResult, error)

type RecurResult

type RecurResult struct {
	Duration string `json:"duration"`
	Count    int    `json:"count"`
}

type Send

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

Send sends local tasks that need to be dispatched

func NewSend

func NewSend(local storage.LocalRepository, disp *storage.Dispatcher) *Send

func (*Send) Process

func (s *Send) Process() (int, error)

type Update

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

Update updates a local task

func NewUpdate

func NewUpdate(local storage.LocalRepository, taskId string, update *task.LocalUpdate) *Update

func (*Update) Process

func (u *Update) Process() error