executor

type ExecuteFunc func(repoProvider provider.RepoProvider) error

type Executor interface {
	// Read schedules a function that can read files from the filesystem.
	Read(FileReadFunc) Executor
	// Write schedules a function that can write files to the filesystem.
	Write(FileWriteFunc) Executor
	// GitRead schedules a function that can read .git repository, but not the files on the filesystem.
	GitRead(fn GitReadFunc) Executor
	// GitWrite schedules a function that can read and write .git repository, but not the files on the filesystem.
	GitWrite(fn GitWriteFunc) Executor
	// FileReadGitWrite schedules a function that can read files from the filesystem, as well as read/write files in .git
	FileReadGitWrite(fn FileReadGitWriteFunc) Executor

	// Schedule schedules a function that can access repo provider. It is deprecated, prefer to use
	// Read, Write or Git functions instead to get more granular locking.
	Schedule(fn ExecuteFunc) Executor

	// AllowRebasingState allows the executor to open a repo in a rebasing state. By default this is not allowed.
	AllowRebasingState() Executor
	// AssertBranchName asserts that the repo is in the expected branch.
	AssertBranchName(string) Executor

	// ExecView executes all of the scheduled functions for the given view repository.
	ExecView(codebaseID, viewID, actionName string) error
	// ExecTrunk executes all of the scheduled functions for the given trunk repository.
	ExecTrunk(codebaseID, actionName string) error
	// ExecTemporaryView creates a view for the given codebase, cloning it from the trunk,
	// executes all the scheduled functions, and then deletes the view.
	ExecTemporaryView(codebaseID, actionName string) error
}

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

type FileReadFunc func(vcs.RepoReader) error

type FileReadGitWriteFunc func(repo vcs.RepoReaderGitWriter) error

type FileWriteFunc func(vcs.RepoWriter) error

type GitReadFunc func(repo vcs.RepoGitReader) error

type GitWriteFunc func(repo vcs.RepoGitWriter) error

type Provider interface {
	New() Executor
}