borges

Nov 28, 2018

Changes in this version

+ const TemporaryError

+ var ErrCannotProcessRepository = errors.NewKind("cannot process repository")

+ var ErrEmptySiva = errors.NewKind("unexpected empty siva file found")

+ var ErrFatal = errors.NewKind("fatal, %v: stacktrace: %s")

+ var ErrObjectTypeNotSupported = errors.NewKind("object type %q not supported")

+ var ErrProcessedWithErrors = errors.NewKind("repository processed with errors")

+ var StrRemoveTmpFiles = "could not remove tmp files"

+ type RepositoryStore interface

+ Create func(repo *model.Repository) error

+ Get func(id kallax.ULID) (*model.Repository, error)

+ GetByEndpoints func(endpoints ...string) ([]*model.Repository, error)

+ GetRefsByInit func(init model.SHA1) ([]*model.Reference, error)

+ InitHasRefs func(init model.SHA1) (bool, error)

+ SetEndpoints func(repo *model.Repository, endpoints ...string) error

+ SetStatus func(repo *model.Repository, status model.FetchStatus) error

+ UpdateFailed func(repo *model.Repository, status model.FetchStatus) error

+ UpdateFetched func(repo *model.Repository, fetchedAt time.Time) error

+ type WorkerFunc func(context.Context, log.Logger, *Job) error

type WorkerPool

+ func (wp *WorkerPool) Stop() error

Oct 31, 2017

Changes in this version

type Archiver

+ Store storage.RepoStore

+ type Executor struct

+ func NewExecutor(log log15.Logger, q queue.Queue, pool *WorkerPool, store storage.RepoStore, ...) *Executor

+ func (p *Executor) Execute() error

Aug 10, 2017

Changes in this version

+ var ErrAlreadyFetching = errors.NewKind("repository %s was already in a fetching status")

+ var ErrSetStatus = errors.NewKind("unable to set repository to status: %s")

+ func StoreConfig(r *git.Repository, mr *model.Repository) error

type Archiver

+ Timeout time.Duration

Aug 2, 2017

Changes in this version

+ const Create

+ const Delete

+ const FetchHEAD

+ const FetchRefSpec

+ const Invalid

+ const Update

+ var ErrAlreadyStopped = errors.NewKind("already stopped: %s")

+ var ErrArchivingRoots = errors.NewKind("archiving %d out of %d roots failed: %s")

+ var ErrChanges = errors.NewKind("error computing changes")

+ var ErrCleanRepositoryDir = errors.NewKind("cleaning up local repo dir failed")

+ var ErrClone = errors.NewKind("cloning %s failed")

+ var ErrEndpointsEmpty = errors.NewKind("endpoints is empty")

+ var ErrPushToRootedRepository = errors.NewKind("push to rooted repo %s failed")

+ var ErrReferencedObjectTypeNotSupported error = stderrors.New("referenced object type not supported")

+ var ErrRepositoryIDNotFound = errors.NewKind("repository id not found: %s")

+ var ErrWaitForJobs = errors.NewKind("no more jobs at the moment")

+ func CreateRepositoryTable()

+ func DropIndexes(names ...string)

+ func DropTables(names ...string)

+ func RepositoryID(endpoints []string, isFork *bool, storer *model.RepositoryStore) (uuid.UUID, error)

+ func ResolveCommit(r *git.Repository, h plumbing.Hash) (*object.Commit, error)

+ func WithInProcRepository(r *git.Repository, f func(string) error) error

+ type Action string

+ type Archiver struct

+ LockSession lock.Session

+ RepositoryStorage *model.RepositoryStore

+ RootedTransactioner repository.RootedTransactioner

+ TemporaryCloner TemporaryCloner

+ func NewArchiver(log log15.Logger, r *model.RepositoryStore, tx repository.RootedTransactioner, ...) *Archiver

+ func (a *Archiver) Do(j *Job) error

+ type Changes map[model.SHA1][]*Command

+ func NewChanges(old, new Referencer) (Changes, error)

+ func (c Changes) Add(new *model.Reference)

+ func (c Changes) Delete(old *model.Reference)

+ func (c Changes) Update(old, new *model.Reference)

+ type Command struct

+ New *model.Reference

+ Old *model.Reference

+ func (c *Command) Action() Action

+ type Consumer struct

+ Notifiers struct{ ... }

+ Queue queue.Queue

+ WorkerPool *WorkerPool

+ func NewConsumer(queue queue.Queue, pool *WorkerPool) *Consumer

+ func (c *Consumer) Start()

+ func (c *Consumer) Stop()

+ type Job struct

+ RepositoryID uuid.UUID

+ type JobIter interface

+ Next func() (*Job, error)

+ func NewLineJobIter(r io.ReadCloser, storer *model.RepositoryStore) JobIter

+ func NewMentionJobIter(q queue.Queue, storer *model.RepositoryStore) JobIter

+ type Producer struct

+ func NewProducer(log log15.Logger, jobIter JobIter, queue queue.Queue) *Producer

+ func (p *Producer) Start()

+ func (p *Producer) Stop()

+ type Referencer interface

+ References func() ([]*model.Reference, error)

+ func NewGitReferencer(r *git.Repository) Referencer

+ func NewModelReferencer(r *model.Repository) Referencer

+ type TemporaryCloner interface

+ Clone func(ctx context.Context, id, url string) (TemporaryRepository, error)

+ func NewTemporaryCloner(tmpFs billy.Filesystem) TemporaryCloner

+ type TemporaryRepository interface

+ Push func(ctx context.Context, url string, refspecs []config.RefSpec) error

+ StoreConfig func(mr *model.Repository) error

+ type Worker struct

+ func NewWorker(log log15.Logger, do func(log15.Logger, *Job) error, ch chan *WorkerJob) *Worker

+ func (w *Worker) IsRunning() bool

+ func (w *Worker) Start()

+ func (w *Worker) Stop()

+ type WorkerJob struct

+ type WorkerPool struct

+ func NewArchiverWorkerPool(log log15.Logger, r *model.RepositoryStore, tx repository.RootedTransactioner, ...) *WorkerPool

+ func NewWorkerPool(log log15.Logger, f func(log15.Logger, *Job) error) *WorkerPool

+ func (wp *WorkerPool) Close() error

+ func (wp *WorkerPool) Do(j *WorkerJob)

+ func (wp *WorkerPool) Len() int

+ func (wp *WorkerPool) SetWorkerCount(workers int)