store

Documentation

Index

• func CreateBuild(c context.Context, build *model.Build, procs ...*model.Proc) error
• func CreateRepo(c context.Context, repo *model.Repo) error
• func CreateUser(c context.Context, user *model.User) error
• func DeleteRepo(c context.Context, repo *model.Repo) error
• func DeleteUser(c context.Context, user *model.User) error
• func GetBuild(c context.Context, id int64) (*model.Build, error)
• func GetBuildCommit(c context.Context, repo *model.Repo, sha, branch string) (*model.Build, error)
• func GetBuildLast(c context.Context, repo *model.Repo, branch string) (*model.Build, error)
• func GetBuildLastBefore(c context.Context, repo *model.Repo, branch string, number int64) (*model.Build, error)
• func GetBuildList(c context.Context, repo *model.Repo) ([]*model.Build, error)
• func GetBuildNumber(c context.Context, repo *model.Repo, num int) (*model.Build, error)
• func GetBuildQueue(c context.Context) ([]*model.Feed, error)
• func GetBuildRef(c context.Context, repo *model.Repo, ref string) (*model.Build, error)
• func GetRepo(c context.Context, id int64) (*model.Repo, error)
• func GetRepoName(c context.Context, name string) (*model.Repo, error)
• func GetRepoOwnerName(c context.Context, owner, name string) (*model.Repo, error)
• func GetUser(c context.Context, id int64) (*model.User, error)
• func GetUserCount(c context.Context) (int, error)
• func GetUserList(c context.Context) ([]*model.User, error)
• func GetUserLogin(c context.Context, login string) (*model.User, error)
• func ToContext(c Setter, store Store)
• func UpdateBuild(c context.Context, build *model.Build) error
• func UpdateRepo(c context.Context, repo *model.Repo) error
• func UpdateUser(c context.Context, user *model.User) error
• type Setter
• type Store
  • func FromContext(c context.Context) Store

Functions

func CreateBuild

func CreateBuild(c context.Context, build *model.Build, procs ...*model.Proc) error

func CreateRepo

func CreateRepo(c context.Context, repo *model.Repo) error

func CreateUser

func CreateUser(c context.Context, user *model.User) error

func DeleteRepo

func DeleteRepo(c context.Context, repo *model.Repo) error

func DeleteUser

func DeleteUser(c context.Context, user *model.User) error

func GetBuild

func GetBuild(c context.Context, id int64) (*model.Build, error)

func GetBuildCommit

func GetBuildCommit(c context.Context, repo *model.Repo, sha, branch string) (*model.Build, error)

func GetBuildLast

func GetBuildLast(c context.Context, repo *model.Repo, branch string) (*model.Build, error)

func GetBuildLastBefore

func GetBuildLastBefore(c context.Context, repo *model.Repo, branch string, number int64) (*model.Build, error)

func GetBuildList

func GetBuildList(c context.Context, repo *model.Repo) ([]*model.Build, error)

func GetBuildNumber

func GetBuildNumber(c context.Context, repo *model.Repo, num int) (*model.Build, error)

func GetBuildQueue

func GetBuildQueue(c context.Context) ([]*model.Feed, error)

func GetBuildRef

func GetBuildRef(c context.Context, repo *model.Repo, ref string) (*model.Build, error)

func GetRepo

func GetRepo(c context.Context, id int64) (*model.Repo, error)

func GetRepoName

func GetRepoName(c context.Context, name string) (*model.Repo, error)

func GetRepoOwnerName

func GetRepoOwnerName(c context.Context, owner, name string) (*model.Repo, error)

func GetUser

func GetUser(c context.Context, id int64) (*model.User, error)

GetUser gets a user by unique ID.

func GetUserCount

func GetUserCount(c context.Context) (int, error)

GetUserCount gets a count of all users in the system.

func GetUserList

func GetUserList(c context.Context) ([]*model.User, error)

GetUserList gets a list of all users in the system.

func GetUserLogin

func GetUserLogin(c context.Context, login string) (*model.User, error)

GetUserLogin gets a user by unique Login name.

func ToContext

func ToContext(c Setter, store Store)

ToContext adds the Store to this context if it supports the Setter interface.

func UpdateBuild

func UpdateBuild(c context.Context, build *model.Build) error

func UpdateRepo

func UpdateRepo(c context.Context, repo *model.Repo) error

func UpdateUser

func UpdateUser(c context.Context, user *model.User) error

Types

type Setter

type Setter interface {
	Set(string, interface{})
}

Setter defines a context that enables setting values.

type Store

type Store interface {
	// GetUser gets a user by unique ID.
	GetUser(int64) (*model.User, error)

	// GetUserLogin gets a user by unique Login name.
	GetUserLogin(string) (*model.User, error)

	// GetUserList gets a list of all users in the system.
	GetUserList() ([]*model.User, error)

	// GetUserCount gets a count of all users in the system.
	GetUserCount() (int, error)

	// CreateUser creates a new user account.
	CreateUser(*model.User) error

	// UpdateUser updates a user account.
	UpdateUser(*model.User) error

	// DeleteUser deletes a user account.
	DeleteUser(*model.User) error

	// GetRepo gets a repo by unique ID.
	GetRepo(int64) (*model.Repo, error)

	// GetRepoName gets a repo by its full name.
	GetRepoName(string) (*model.Repo, error)

	// GetRepoCount gets a count of all repositories in the system.
	GetRepoCount() (int, error)

	// CreateRepo creates a new repository.
	CreateRepo(*model.Repo) error

	// UpdateRepo updates a user repository.
	UpdateRepo(*model.Repo) error

	// DeleteRepo deletes a user repository.
	DeleteRepo(*model.Repo) error

	// GetBuild gets a build by unique ID.
	GetBuild(int64) (*model.Build, error)

	// GetBuildNumber gets a build by number.
	GetBuildNumber(*model.Repo, int) (*model.Build, error)

	// GetBuildRef gets a build by its ref.
	GetBuildRef(*model.Repo, string) (*model.Build, error)

	// GetBuildCommit gets a build by its commit sha.
	GetBuildCommit(*model.Repo, string, string) (*model.Build, error)

	// GetBuildLast gets the last build for the branch.
	GetBuildLast(*model.Repo, string) (*model.Build, error)

	// GetBuildLastBefore gets the last build before build number N.
	GetBuildLastBefore(*model.Repo, string, int64) (*model.Build, error)

	// GetBuildList gets a list of builds for the repository
	GetBuildList(*model.Repo) ([]*model.Build, error)

	// GetBuildQueue gets a list of build in queue.
	GetBuildQueue() ([]*model.Feed, error)

	// GetBuildCount gets a count of all builds in the system.
	GetBuildCount() (int, error)

	// CreateBuild creates a new build and jobs.
	CreateBuild(*model.Build, ...*model.Proc) error

	// UpdateBuild updates a build.
	UpdateBuild(*model.Build) error

	UserFeed(*model.User) ([]*model.Feed, error)

	RepoList(*model.User) ([]*model.Repo, error)
	RepoListLatest(*model.User) ([]*model.Feed, error)
	RepoBatch([]*model.Repo) error

	PermFind(user *model.User, repo *model.Repo) (*model.Perm, error)
	PermUpsert(perm *model.Perm) error
	PermBatch(perms []*model.Perm) error
	PermDelete(perm *model.Perm) error
	PermFlush(user *model.User, before int64) error

	ConfigLoad(int64) (*model.Config, error)
	ConfigFind(*model.Repo, string) (*model.Config, error)
	ConfigFindApproved(*model.Config) (bool, error)
	ConfigCreate(*model.Config) error

	SenderFind(*model.Repo, string) (*model.Sender, error)
	SenderList(*model.Repo) ([]*model.Sender, error)
	SenderCreate(*model.Sender) error
	SenderUpdate(*model.Sender) error
	SenderDelete(*model.Sender) error

	SecretFind(*model.Repo, string) (*model.Secret, error)
	SecretList(*model.Repo) ([]*model.Secret, error)
	SecretCreate(*model.Secret) error
	SecretUpdate(*model.Secret) error
	SecretDelete(*model.Secret) error

	RegistryFind(*model.Repo, string) (*model.Registry, error)
	RegistryList(*model.Repo) ([]*model.Registry, error)
	RegistryCreate(*model.Registry) error
	RegistryUpdate(*model.Registry) error
	RegistryDelete(*model.Registry) error

	ProcLoad(int64) (*model.Proc, error)
	ProcFind(*model.Build, int) (*model.Proc, error)
	ProcChild(*model.Build, int, string) (*model.Proc, error)
	ProcList(*model.Build) ([]*model.Proc, error)
	ProcCreate([]*model.Proc) error
	ProcUpdate(*model.Proc) error
	ProcClear(*model.Build) error

	LogFind(*model.Proc) (io.ReadCloser, error)
	LogSave(*model.Proc, io.Reader) error

	FileList(*model.Build) ([]*model.File, error)
	FileFind(*model.Proc, string) (*model.File, error)
	FileRead(*model.Proc, string) (io.ReadCloser, error)
	FileCreate(*model.File, io.Reader) error

	TaskList() ([]*model.Task, error)
	TaskInsert(*model.Task) error
	TaskDelete(string) error

	Ping() error
}

func FromContext

func FromContext(c context.Context) Store

FromContext returns the Store associated with this context.