store

Documentation

Index

• type BoltStore
  • func NewBoltStore() *BoltStore
  • func (s *BoltStore) CreatePipelineGet() ([]gaia.CreatePipeline, error)
  • func (s *BoltStore) CreatePipelinePut(p *gaia.CreatePipeline) error
  • func (s *BoltStore) Init() error
  • func (s *BoltStore) PipelineDelete(id int) error
  • func (s *BoltStore) PipelineGet(id int) (*gaia.Pipeline, error)
  • func (s *BoltStore) PipelineGetAllRuns(pipelineID int) ([]gaia.PipelineRun, error)
  • func (s *BoltStore) PipelineGetByName(n string) (*gaia.Pipeline, error)
  • func (s *BoltStore) PipelineGetLatestRun(pipelineID int) (*gaia.PipelineRun, error)
  • func (s *BoltStore) PipelineGetRunByPipelineIDAndID(pipelineid int, runid int) (*gaia.PipelineRun, error)
  • func (s *BoltStore) PipelineGetRunHighestID(p *gaia.Pipeline) (int, error)
  • func (s *BoltStore) PipelineGetScheduled(limit int) ([]*gaia.PipelineRun, error)
  • func (s *BoltStore) PipelinePut(p *gaia.Pipeline) error
  • func (s *BoltStore) PipelinePutRun(r *gaia.PipelineRun) error
  • func (s *BoltStore) UserAuth(u *gaia.User, updateLastLogin bool) (*gaia.User, error)
  • func (s *BoltStore) UserDelete(u string) error
  • func (s *BoltStore) UserGet(username string) (*gaia.User, error)
  • func (s *BoltStore) UserGetAll() ([]gaia.User, error)
  • func (s *BoltStore) UserPut(u *gaia.User, encryptPassword bool) error
• type GaiaStore

Types

type BoltStore

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

BoltStore represents the access type for store

func NewBoltStore

func NewBoltStore() *BoltStore

NewBoltStore creates a new instance of Store.

func (*BoltStore) CreatePipelineGet

func (s *BoltStore) CreatePipelineGet() ([]gaia.CreatePipeline, error)

CreatePipelineGet returns all available create pipeline objects in the store.

func (*BoltStore) CreatePipelinePut

func (s *BoltStore) CreatePipelinePut(p *gaia.CreatePipeline) error

CreatePipelinePut adds a pipeline which is not yet compiled but is about to.

func (*BoltStore) Init

func (s *BoltStore) Init() error

Init creates the data folder if not exists, generates private key and bolt database. This should be called only once per database because bolt holds a lock on the database file.

func (*BoltStore) PipelineDelete

func (s *BoltStore) PipelineDelete(id int) error

PipelineDelete deletes the pipeline with the given id.

func (*BoltStore) PipelineGet

func (s *BoltStore) PipelineGet(id int) (*gaia.Pipeline, error)

PipelineGet gets a pipeline by given id.

func (*BoltStore) PipelineGetAllRuns

func (s *BoltStore) PipelineGetAllRuns(pipelineID int) ([]gaia.PipelineRun, error)

PipelineGetAllRuns looks for all pipeline runs by the given pipeline id.

func (*BoltStore) PipelineGetByName

func (s *BoltStore) PipelineGetByName(n string) (*gaia.Pipeline, error)

PipelineGetByName looks up a pipeline by the given name. Returns nil if pipeline was not found.

func (*BoltStore) PipelineGetLatestRun

func (s *BoltStore) PipelineGetLatestRun(pipelineID int) (*gaia.PipelineRun, error)

PipelineGetLatestRun returns the latest run by the given pipeline id.

func (*BoltStore) PipelineGetRunByPipelineIDAndID

func (s *BoltStore) PipelineGetRunByPipelineIDAndID(pipelineid int, runid int) (*gaia.PipelineRun, error)

PipelineGetRunByPipelineIDAndID looks for pipeline run by given pipeline id and run id.

func (*BoltStore) PipelineGetRunHighestID

func (s *BoltStore) PipelineGetRunHighestID(p *gaia.Pipeline) (int, error)

PipelineGetRunHighestID looks for the highest public id for the given pipeline.

func (*BoltStore) PipelineGetScheduled

func (s *BoltStore) PipelineGetScheduled(limit int) ([]*gaia.PipelineRun, error)

PipelineGetScheduled returns the scheduled pipelines with a return limit.

func (*BoltStore) PipelinePut

func (s *BoltStore) PipelinePut(p *gaia.Pipeline) error

PipelinePut puts a pipeline into the store. On persist, the pipeline will get a unique id.

func (*BoltStore) PipelinePutRun

func (s *BoltStore) PipelinePutRun(r *gaia.PipelineRun) error

PipelinePutRun takes the given pipeline run and puts it into the store. If a pipeline run already exists in the store it will be overwritten.

func (*BoltStore) UserAuth

func (s *BoltStore) UserAuth(u *gaia.User, updateLastLogin bool) (*gaia.User, error)

UserAuth looks up a user by given username. Then it compares passwords and returns user obj if given password is valid. Returns nil if password was wrong or user not found.

func (*BoltStore) UserDelete

func (s *BoltStore) UserDelete(u string) error

UserDelete deletes the given user.

func (*BoltStore) UserGet

func (s *BoltStore) UserGet(username string) (*gaia.User, error)

UserGet looks up a user by given username. Returns nil if user was not found.

func (*BoltStore) UserGetAll

func (s *BoltStore) UserGetAll() ([]gaia.User, error)

UserGetAll returns all stored users.

func (*BoltStore) UserPut

func (s *BoltStore) UserPut(u *gaia.User, encryptPassword bool) error

UserPut takes the given user and saves it to the bolt database. User will be overwritten if it already exists. It also clears the password field afterwards.

type GaiaStore

type GaiaStore interface {
	Init() error
	CreatePipelinePut(createPipeline *gaia.CreatePipeline) error
	CreatePipelineGet() (listOfPipelines []gaia.CreatePipeline, err error)
	PipelinePut(pipeline *gaia.Pipeline) error
	PipelineGet(id int) (pipeline *gaia.Pipeline, err error)
	PipelineGetByName(name string) (pipline *gaia.Pipeline, err error)
	PipelineGetRunHighestID(pipeline *gaia.Pipeline) (id int, err error)
	PipelinePutRun(r *gaia.PipelineRun) error
	PipelineGetScheduled(limit int) ([]*gaia.PipelineRun, error)
	PipelineGetRunByPipelineIDAndID(pipelineid int, runid int) (*gaia.PipelineRun, error)
	PipelineGetAllRuns(pipelineID int) ([]gaia.PipelineRun, error)
	PipelineGetLatestRun(pipelineID int) (*gaia.PipelineRun, error)
	PipelineDelete(id int) error
	UserPut(u *gaia.User, encryptPassword bool) error
	UserAuth(u *gaia.User, updateLastLogin bool) (*gaia.User, error)
	UserGet(username string) (*gaia.User, error)
	UserGetAll() ([]gaia.User, error)
	UserDelete(u string) error
}

GaiaStore is the interface that defines methods needed to store pipeline and user related information.