repository

Documentation

Index

• Variables
• func NewSQLite3Repo(dbfile, directory string) (*dbRepo, error)
• type InMemoryRepo
  • func NewInMemoryRepo() *InMemoryRepo
  • func (repo *InMemoryRepo) Add(queueName, link, dwnDir, filename, description string) error
  • func (repo *InMemoryRepo) Complete(e fafnir.Entry) error
  • func (repo *InMemoryRepo) Create(queueName string) error
  • func (repo *InMemoryRepo) Delete(queueName string) error
  • func (repo *InMemoryRepo) Fetch() ([]*fafnir.Queue, error)
  • func (repo *InMemoryRepo) Get(queueName string, errChan chan error) (*fafnir.Queue, error)
  • func (repo *InMemoryRepo) Update(e fafnir.Entry) error

Variables

var (
	ErrQueueNotFound     = errors.New("queue Not found")
	ErrQueueAlreadyExist = errors.New("queue Already Exist")
	ErrEntryNotFound     = errors.New("entry Not found")
)

Functions

func NewSQLite3Repo

func NewSQLite3Repo(dbfile, directory string) (*dbRepo, error)

Types

type InMemoryRepo

type InMemoryRepo struct {
	Queues  []*fafnir.Queue
	Entries []fafnir.Entry
	EID     int
	// contains filtered or unexported fields
}

func NewInMemoryRepo

func NewInMemoryRepo() *InMemoryRepo

func (*InMemoryRepo) Add

func (repo *InMemoryRepo) Add(queueName, link, dwnDir, filename, description string) error

func (*InMemoryRepo) Complete

func (repo *InMemoryRepo) Complete(e fafnir.Entry) error

func (*InMemoryRepo) Create

func (repo *InMemoryRepo) Create(queueName string) error

func (*InMemoryRepo) Delete

func (repo *InMemoryRepo) Delete(queueName string) error

func (*InMemoryRepo) Fetch

func (repo *InMemoryRepo) Fetch() ([]*fafnir.Queue, error)

func (*InMemoryRepo) Get

func (repo *InMemoryRepo) Get(queueName string, errChan chan error) (*fafnir.Queue, error)

func (*InMemoryRepo) Update

func (repo *InMemoryRepo) Update(e fafnir.Entry) error