Documentation ¶
Overview ¶
This implementation of the OcelotStorage system creates a directory structure and stores the data via json files. The build id is a generated random number that is unique to the storage system. The directory tree ends up being as follows: save-direc/ ├── 1238ejs7 <---------------- hash │ └── 5577006791947779410 <- build id │ ├── out.json <-------- build output │ └── sum.json <-------- build summary │ └── fail.json <------ build failure reasons (if any) *NOT IMPLEMENTED YET* ├── 123cc34 │ └── 6129484611666145821 │ ├── out.json │ └── sum.json └── alsdkurnv
└── 8674665223082153551 ├── out.json └── sum.json
Package storage is a generated GoMock package.
Index ¶
- Constants
- Variables
- func CreateTestPgDatabase(t *testing.T, port int) (cleanup func(t *testing.T), password string)
- func PostgresTeardown(t *testing.T, db *sql.DB)
- type BuildOut
- type BuildStage
- type BuildSum
- type Cabinet
- type CredTable
- type Dest
- type Drawer
- type ErrMultipleVCSTypes
- type ErrNotFound
- type FileBuildStorage
- func (f *FileBuildStorage) AddOut(output *models.BuildOutput) error
- func (f *FileBuildStorage) AddStageDetail(stageResult *models.StageResult) error
- func (f *FileBuildStorage) AddSumStart(hash string, account string, repo string, branch string) (int64, error)
- func (f *FileBuildStorage) Clean()
- func (f *FileBuildStorage) Healthy() bool
- func (f *FileBuildStorage) Retrieve(gitHash string) (data []byte, err error)
- func (f *FileBuildStorage) RetrieveAcctRepo(partialRepo string) ([]*pb.BuildSummary, error)
- func (f *FileBuildStorage) RetrieveHashStartsWith(partialGitHash string) ([]*pb.BuildSummary, error)
- func (f *FileBuildStorage) RetrieveLastFewSums(repo string, account string, limit int32) ([]*pb.BuildSummary, error)
- func (f *FileBuildStorage) RetrieveLastOutByHash(gitHash string) (models.BuildOutput, error)
- func (f *FileBuildStorage) RetrieveLatestSum(gitHash string) (*pb.BuildSummary, error)
- func (f *FileBuildStorage) RetrieveOut(buildId int64) (models.BuildOutput, error)
- func (f *FileBuildStorage) RetrieveStageDetail(buildId int64) ([]models.StageResult, error)
- func (f *FileBuildStorage) RetrieveSum(gitHash string) ([]*pb.BuildSummary, error)
- func (f *FileBuildStorage) RetrieveSumByBuildId(buildId int64) (*pb.BuildSummary, error)
- func (f *FileBuildStorage) StorageType() string
- func (f *FileBuildStorage) UpdateSum(failed bool, duration float64, id int64) error
- type HealthyChkr
- type HealthyStorage
- type MockBuildOut
- type MockBuildOutMockRecorder
- type MockBuildStage
- type MockBuildStageMockRecorder
- type MockBuildSum
- func (m *MockBuildSum) AddSumStart(hash, account, repo, branch string) (int64, error)
- func (m *MockBuildSum) EXPECT() *MockBuildSumMockRecorder
- func (m *MockBuildSum) GetLastSuccessfulBuildHash(account, repo, branch string) (string, error)
- func (m *MockBuildSum) GetTrackedRepos() (*pb.AcctRepos, error)
- func (m *MockBuildSum) RetrieveAcctRepo(partialRepo string) ([]*pb.BuildSummary, error)
- func (m *MockBuildSum) RetrieveHashStartsWith(partialGitHash string) ([]*pb.BuildSummary, error)
- func (m *MockBuildSum) RetrieveLastFewSums(repo, account string, limit int32) ([]*pb.BuildSummary, error)
- func (m *MockBuildSum) RetrieveLatestSum(gitHash string) (*pb.BuildSummary, error)
- func (m *MockBuildSum) RetrieveSum(gitHash string) ([]*pb.BuildSummary, error)
- func (m *MockBuildSum) RetrieveSumByBuildId(buildId int64) (*pb.BuildSummary, error)
- func (m *MockBuildSum) SetQueueTime(id int64) error
- func (m *MockBuildSum) StartBuild(id int64) error
- func (m *MockBuildSum) StoreFailedValidation(id int64) error
- func (m *MockBuildSum) UpdateSum(failed bool, duration float64, id int64) error
- type MockBuildSumMockRecorder
- func (mr *MockBuildSumMockRecorder) AddSumStart(hash, account, repo, branch interface{}) *gomock.Call
- func (mr *MockBuildSumMockRecorder) GetLastSuccessfulBuildHash(account, repo, branch interface{}) *gomock.Call
- func (mr *MockBuildSumMockRecorder) GetTrackedRepos() *gomock.Call
- func (mr *MockBuildSumMockRecorder) RetrieveAcctRepo(partialRepo interface{}) *gomock.Call
- func (mr *MockBuildSumMockRecorder) RetrieveHashStartsWith(partialGitHash interface{}) *gomock.Call
- func (mr *MockBuildSumMockRecorder) RetrieveLastFewSums(repo, account, limit interface{}) *gomock.Call
- func (mr *MockBuildSumMockRecorder) RetrieveLatestSum(gitHash interface{}) *gomock.Call
- func (mr *MockBuildSumMockRecorder) RetrieveSum(gitHash interface{}) *gomock.Call
- func (mr *MockBuildSumMockRecorder) RetrieveSumByBuildId(buildId interface{}) *gomock.Call
- func (mr *MockBuildSumMockRecorder) SetQueueTime(id interface{}) *gomock.Call
- func (mr *MockBuildSumMockRecorder) StartBuild(id interface{}) *gomock.Call
- func (mr *MockBuildSumMockRecorder) StoreFailedValidation(id interface{}) *gomock.Call
- func (mr *MockBuildSumMockRecorder) UpdateSum(failed, duration, id interface{}) *gomock.Call
- type MockCredTable
- func (m *MockCredTable) CredExists(credder pb.OcyCredder) (bool, error)
- func (m *MockCredTable) DeleteCred(credder pb.OcyCredder) error
- func (m *MockCredTable) EXPECT() *MockCredTableMockRecorder
- func (m *MockCredTable) GetVCSTypeFromAccount(account string) (pb.SubCredType, error)
- func (m *MockCredTable) InsertCred(credder pb.OcyCredder, overWriteOk bool) error
- func (m *MockCredTable) RetrieveAllCreds() ([]pb.OcyCredder, error)
- func (m *MockCredTable) RetrieveCred(subCredType pb.SubCredType, identifier, accountName string) (pb.OcyCredder, error)
- func (m *MockCredTable) RetrieveCredBySubTypeAndAcct(scredType pb.SubCredType, acctName string) ([]pb.OcyCredder, error)
- func (m *MockCredTable) RetrieveCreds(credType pb.CredType) ([]pb.OcyCredder, error)
- func (m *MockCredTable) UpdateCred(credder pb.OcyCredder) error
- type MockCredTableMockRecorder
- func (mr *MockCredTableMockRecorder) CredExists(credder interface{}) *gomock.Call
- func (mr *MockCredTableMockRecorder) DeleteCred(credder interface{}) *gomock.Call
- func (mr *MockCredTableMockRecorder) GetVCSTypeFromAccount(account interface{}) *gomock.Call
- func (mr *MockCredTableMockRecorder) InsertCred(credder, overWriteOk interface{}) *gomock.Call
- func (mr *MockCredTableMockRecorder) RetrieveAllCreds() *gomock.Call
- func (mr *MockCredTableMockRecorder) RetrieveCred(subCredType, identifier, accountName interface{}) *gomock.Call
- func (mr *MockCredTableMockRecorder) RetrieveCredBySubTypeAndAcct(scredType, acctName interface{}) *gomock.Call
- func (mr *MockCredTableMockRecorder) RetrieveCreds(credType interface{}) *gomock.Call
- func (mr *MockCredTableMockRecorder) UpdateCred(credder interface{}) *gomock.Call
- type MockHealthyChkr
- type MockHealthyChkrMockRecorder
- type MockOcelotStorage
- func (m *MockOcelotStorage) AddOut(output *models.BuildOutput) error
- func (m *MockOcelotStorage) AddStageDetail(stageResult *models.StageResult) error
- func (m *MockOcelotStorage) AddSumStart(hash, account, repo, branch string) (int64, error)
- func (m *MockOcelotStorage) Close()
- func (m *MockOcelotStorage) CredExists(credder pb.OcyCredder) (bool, error)
- func (m *MockOcelotStorage) DeleteCred(credder pb.OcyCredder) error
- func (m *MockOcelotStorage) DeletePoll(account, repo string) error
- func (m *MockOcelotStorage) EXPECT() *MockOcelotStorageMockRecorder
- func (m *MockOcelotStorage) GetAllPolls() ([]*pb.PollRequest, error)
- func (m *MockOcelotStorage) GetLastData(accountRepo string) (time.Time, map[string]string, error)
- func (m *MockOcelotStorage) GetLastSuccessfulBuildHash(account, repo, branch string) (string, error)
- func (m *MockOcelotStorage) GetTrackedRepos() (*pb.AcctRepos, error)
- func (m *MockOcelotStorage) GetVCSTypeFromAccount(account string) (pb.SubCredType, error)
- func (m *MockOcelotStorage) Healthy() bool
- func (m *MockOcelotStorage) InsertCred(credder pb.OcyCredder, overWriteOk bool) error
- func (m *MockOcelotStorage) InsertPoll(account, repo, cronString, branches string, credsId int64) error
- func (m *MockOcelotStorage) PollExists(account, repo string) (bool, error)
- func (m *MockOcelotStorage) RetrieveAcctRepo(partialRepo string) ([]*pb.BuildSummary, error)
- func (m *MockOcelotStorage) RetrieveAllCreds() ([]pb.OcyCredder, error)
- func (m *MockOcelotStorage) RetrieveCred(subCredType pb.SubCredType, identifier, accountName string) (pb.OcyCredder, error)
- func (m *MockOcelotStorage) RetrieveCredBySubTypeAndAcct(scredType pb.SubCredType, acctName string) ([]pb.OcyCredder, error)
- func (m *MockOcelotStorage) RetrieveCreds(credType pb.CredType) ([]pb.OcyCredder, error)
- func (m *MockOcelotStorage) RetrieveHashStartsWith(partialGitHash string) ([]*pb.BuildSummary, error)
- func (m *MockOcelotStorage) RetrieveLastFewSums(repo, account string, limit int32) ([]*pb.BuildSummary, error)
- func (m *MockOcelotStorage) RetrieveLastOutByHash(gitHash string) (models.BuildOutput, error)
- func (m *MockOcelotStorage) RetrieveLatestSum(gitHash string) (*pb.BuildSummary, error)
- func (m *MockOcelotStorage) RetrieveOut(buildId int64) (models.BuildOutput, error)
- func (m *MockOcelotStorage) RetrieveStageDetail(buildId int64) ([]models.StageResult, error)
- func (m *MockOcelotStorage) RetrieveSum(gitHash string) ([]*pb.BuildSummary, error)
- func (m *MockOcelotStorage) RetrieveSumByBuildId(buildId int64) (*pb.BuildSummary, error)
- func (m *MockOcelotStorage) SetLastData(account, repo string, lasthashes map[string]string) error
- func (m *MockOcelotStorage) SetQueueTime(id int64) error
- func (m *MockOcelotStorage) StartBuild(id int64) error
- func (m *MockOcelotStorage) StorageType() string
- func (m *MockOcelotStorage) StoreFailedValidation(id int64) error
- func (m *MockOcelotStorage) UpdateCred(credder pb.OcyCredder) error
- func (m *MockOcelotStorage) UpdatePoll(account, repo, cronString, branches string) error
- func (m *MockOcelotStorage) UpdateSum(failed bool, duration float64, id int64) error
- type MockOcelotStorageMockRecorder
- func (mr *MockOcelotStorageMockRecorder) AddOut(output interface{}) *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) AddStageDetail(stageResult interface{}) *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) AddSumStart(hash, account, repo, branch interface{}) *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) Close() *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) CredExists(credder interface{}) *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) DeleteCred(credder interface{}) *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) DeletePoll(account, repo interface{}) *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) GetAllPolls() *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) GetLastData(accountRepo interface{}) *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) GetLastSuccessfulBuildHash(account, repo, branch interface{}) *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) GetTrackedRepos() *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) GetVCSTypeFromAccount(account interface{}) *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) Healthy() *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) InsertCred(credder, overWriteOk interface{}) *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) InsertPoll(account, repo, cronString, branches, credsId interface{}) *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) PollExists(account, repo interface{}) *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) RetrieveAcctRepo(partialRepo interface{}) *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) RetrieveAllCreds() *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) RetrieveCred(subCredType, identifier, accountName interface{}) *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) RetrieveCredBySubTypeAndAcct(scredType, acctName interface{}) *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) RetrieveCreds(credType interface{}) *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) RetrieveHashStartsWith(partialGitHash interface{}) *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) RetrieveLastFewSums(repo, account, limit interface{}) *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) RetrieveLastOutByHash(gitHash interface{}) *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) RetrieveLatestSum(gitHash interface{}) *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) RetrieveOut(buildId interface{}) *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) RetrieveStageDetail(buildId interface{}) *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) RetrieveSum(gitHash interface{}) *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) RetrieveSumByBuildId(buildId interface{}) *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) SetLastData(account, repo, lasthashes interface{}) *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) SetQueueTime(id interface{}) *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) StartBuild(id interface{}) *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) StorageType() *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) StoreFailedValidation(id interface{}) *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) UpdateCred(credder interface{}) *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) UpdatePoll(account, repo, cronString, branches interface{}) *gomock.Call
- func (mr *MockOcelotStorageMockRecorder) UpdateSum(failed, duration, id interface{}) *gomock.Call
- type MockPollTable
- func (m *MockPollTable) DeletePoll(account, repo string) error
- func (m *MockPollTable) EXPECT() *MockPollTableMockRecorder
- func (m *MockPollTable) GetAllPolls() ([]*pb.PollRequest, error)
- func (m *MockPollTable) GetLastData(accountRepo string) (time.Time, map[string]string, error)
- func (m *MockPollTable) InsertPoll(account, repo, cronString, branches string, credsId int64) error
- func (m *MockPollTable) PollExists(account, repo string) (bool, error)
- func (m *MockPollTable) SetLastData(account, repo string, lasthashes map[string]string) error
- func (m *MockPollTable) UpdatePoll(account, repo, cronString, branches string) error
- type MockPollTableMockRecorder
- func (mr *MockPollTableMockRecorder) DeletePoll(account, repo interface{}) *gomock.Call
- func (mr *MockPollTableMockRecorder) GetAllPolls() *gomock.Call
- func (mr *MockPollTableMockRecorder) GetLastData(accountRepo interface{}) *gomock.Call
- func (mr *MockPollTableMockRecorder) InsertPoll(account, repo, cronString, branches, credsId interface{}) *gomock.Call
- func (mr *MockPollTableMockRecorder) PollExists(account, repo interface{}) *gomock.Call
- func (mr *MockPollTableMockRecorder) SetLastData(account, repo, lasthashes interface{}) *gomock.Call
- func (mr *MockPollTableMockRecorder) UpdatePoll(account, repo, cronString, branches interface{}) *gomock.Call
- type MockStringy
- type MockStringyMockRecorder
- type OcelotStorage
- type PollTable
- type PostgresStorage
- func (p *PostgresStorage) AddOut(output *models.BuildOutput) error
- func (p *PostgresStorage) AddStageDetail(stageResult *models.StageResult) error
- func (p *PostgresStorage) AddSumStart(hash string, account string, repo string, branch string) (int64, error)
- func (p *PostgresStorage) Close()
- func (p *PostgresStorage) Connect() error
- func (p *PostgresStorage) CredExists(credder pb.OcyCredder) (bool, error)
- func (p *PostgresStorage) DeleteCred(credder pb.OcyCredder) error
- func (p *PostgresStorage) DeletePoll(account string, repo string) error
- func (p *PostgresStorage) GetAllPolls() ([]*pb.PollRequest, error)
- func (p *PostgresStorage) GetLastData(accountRepo string) (timestamp time.Time, hashes map[string]string, err error)
- func (p *PostgresStorage) GetLastSuccessfulBuildHash(account, repo, branch string) (string, error)
- func (p *PostgresStorage) GetTrackedRepos() (*pb.AcctRepos, error)
- func (p *PostgresStorage) GetVCSTypeFromAccount(account string) (pb.SubCredType, error)
- func (p *PostgresStorage) Healthy() bool
- func (p *PostgresStorage) InsertCred(credder pb.OcyCredder, overwriteOk bool) error
- func (p *PostgresStorage) InsertPoll(account string, repo string, cronString string, branches string, credsId int64) (err error)
- func (p *PostgresStorage) PollExists(account string, repo string) (bool, error)
- func (p *PostgresStorage) RetrieveAcctRepo(partialRepo string) ([]*pb.BuildSummary, error)
- func (p *PostgresStorage) RetrieveAllCreds() ([]pb.OcyCredder, error)
- func (p *PostgresStorage) RetrieveCred(subCredType pb.SubCredType, identifier, accountName string) (pb.OcyCredder, error)
- func (p *PostgresStorage) RetrieveCredBySubTypeAndAcct(scredType pb.SubCredType, acctName string) ([]pb.OcyCredder, error)
- func (p *PostgresStorage) RetrieveCreds(credType pb.CredType) ([]pb.OcyCredder, error)
- func (p *PostgresStorage) RetrieveHashStartsWith(partialGitHash string) (hashes []*pb.BuildSummary, err error)
- func (p *PostgresStorage) RetrieveLastFewSums(repo string, account string, limit int32) (sums []*pb.BuildSummary, err error)
- func (p *PostgresStorage) RetrieveLastOutByHash(gitHash string) (models.BuildOutput, error)
- func (p *PostgresStorage) RetrieveLatestSum(partialGitHash string) (*pb.BuildSummary, error)
- func (p *PostgresStorage) RetrieveOut(buildId int64) (models.BuildOutput, error)
- func (p *PostgresStorage) RetrieveStageDetail(buildId int64) ([]models.StageResult, error)
- func (p *PostgresStorage) RetrieveSum(gitHash string) (sums []*pb.BuildSummary, err error)
- func (p *PostgresStorage) RetrieveSumByBuildId(buildId int64) (*pb.BuildSummary, error)
- func (p *PostgresStorage) SetLastData(account string, repo string, lasthashes map[string]string) (err error)
- func (p *PostgresStorage) SetQueueTime(id int64) error
- func (p *PostgresStorage) StartBuild(id int64) error
- func (p *PostgresStorage) StorageType() string
- func (p *PostgresStorage) StoreFailedValidation(id int64) error
- func (p *PostgresStorage) UpdateCred(credder pb.OcyCredder) error
- func (p *PostgresStorage) UpdatePoll(account string, repo string, cronString string, branches string) (err error)
- func (p *PostgresStorage) UpdateSum(failed bool, duration float64, id int64) error
- type Stringy
Constants ¶
const TimeFormat = "2006-01-02 15:04:05"
Variables ¶
var ( BUILD_SUM_404 = "no build summary found for %s" STAGE_REASON_404 = "no stages found for %s" BUILD_OUT_404 = "no build output found for %s" CRED_404 = "no credential found for %s %s" )
Functions ¶
func CreateTestPgDatabase ¶
todo: add some auditing to this, have a file that says what test started it up and what test called cleanup, i know something's missing create the postgres database using docker image, create tables using sql file in test-fixtures returns a cleanup function for closing database, the password, and the port it runs on.
Types ¶
type BuildOut ¶
type BuildOut interface { AddOut(output *models.BuildOutput) error RetrieveOut(buildId int64) (models.BuildOutput, error) RetrieveLastOutByHash(gitHash string) (models.BuildOutput, error) }
type BuildStage ¶
type BuildStage interface { AddStageDetail(stageResult *models.StageResult) error RetrieveStageDetail(buildId int64) ([]models.StageResult, error) }
type BuildSum ¶
type BuildSum interface { // AddSumStart will AddSumStart(hash string, account string, repo string, branch string) (int64, error) UpdateSum(failed bool, duration float64, id int64) error RetrieveSumByBuildId(buildId int64) (*pb.BuildSummary, error) RetrieveSum(gitHash string) ([]*pb.BuildSummary, error) RetrieveLatestSum(gitHash string) (*pb.BuildSummary, error) RetrieveHashStartsWith(partialGitHash string) ([]*pb.BuildSummary, error) RetrieveLastFewSums(repo string, account string, limit int32) ([]*pb.BuildSummary, error) RetrieveAcctRepo(partialRepo string) ([]*pb.BuildSummary, error) StartBuild(id int64) error StoreFailedValidation(id int64) error SetQueueTime(id int64) error GetTrackedRepos() (*pb.AcctRepos, error) GetLastSuccessfulBuildHash(account, repo, branch string) (string, error) }
type CredTable ¶
type CredTable interface { InsertCred(credder pb.OcyCredder, overWriteOk bool) error // retrieve ordered by cred type RetrieveAllCreds() ([]pb.OcyCredder, error) // todo: take out all this pb.CredType stuff, can just call Parent() on subcredType. realized too late :"( RetrieveCreds(credType pb.CredType) ([]pb.OcyCredder, error) RetrieveCred(subCredType pb.SubCredType, identifier, accountName string) (pb.OcyCredder, error) RetrieveCredBySubTypeAndAcct(scredType pb.SubCredType, acctName string) ([]pb.OcyCredder, error) CredExists(credder pb.OcyCredder) (bool, error) UpdateCred(credder pb.OcyCredder) error DeleteCred(credder pb.OcyCredder) error GetVCSTypeFromAccount(account string) (pb.SubCredType, error) }
type ErrMultipleVCSTypes ¶ added in v0.8.0
type ErrMultipleVCSTypes struct {
// contains filtered or unexported fields
}
func MultipleVCSTypes ¶ added in v0.8.0
func MultipleVCSTypes(account string, types []pb.SubCredType) *ErrMultipleVCSTypes
func (*ErrMultipleVCSTypes) Error ¶ added in v0.8.0
func (e *ErrMultipleVCSTypes) Error() string
type ErrNotFound ¶
type ErrNotFound struct {
// contains filtered or unexported fields
}
func BuildOutNotFound ¶
func BuildOutNotFound(id string) *ErrNotFound
func BuildSumNotFound ¶
func BuildSumNotFound(id string) *ErrNotFound
func CredNotFound ¶
func CredNotFound(account string, repoType string) *ErrNotFound
func StagesNotFound ¶
func StagesNotFound(id string) *ErrNotFound
func (*ErrNotFound) Error ¶
func (e *ErrNotFound) Error() string
type FileBuildStorage ¶
type FileBuildStorage struct { *PostgresStorage // contains filtered or unexported fields }
FileBuildStorage is an implementation of BuildOutput that is for filesystem.
func NewFileBuildStorage ¶
func NewFileBuildStorage(saveDir string) (f *FileBuildStorage)
NewFileBuildStorage will return an initialized FileBuildStorage with the saveDirec added to the filesystem if it isn't already. will fatally exit if cannot create directory. if saveDir == "", will create path at `~/.ocelot/build-output`
func (*FileBuildStorage) AddOut ¶
func (f *FileBuildStorage) AddOut(output *models.BuildOutput) error
func (*FileBuildStorage) AddStageDetail ¶
func (f *FileBuildStorage) AddStageDetail(stageResult *models.StageResult) error
todo; implement stages
func (*FileBuildStorage) AddSumStart ¶
func (f *FileBuildStorage) AddSumStart(hash string, account string, repo string, branch string) (int64, error)
AddSumStart will create an entry in the filesystem storage by generating a random number that has not been used yet. that will be the buildId. Then it will dump the *pb.BuildSummary struct to JSON.
func (*FileBuildStorage) Clean ¶
func (f *FileBuildStorage) Clean()
func (*FileBuildStorage) Healthy ¶
func (f *FileBuildStorage) Healthy() bool
func (*FileBuildStorage) Retrieve ¶
func (f *FileBuildStorage) Retrieve(gitHash string) (data []byte, err error)
retrieve build data from filesystem
func (*FileBuildStorage) RetrieveAcctRepo ¶
func (f *FileBuildStorage) RetrieveAcctRepo(partialRepo string) ([]*pb.BuildSummary, error)
TODO: implement
func (*FileBuildStorage) RetrieveHashStartsWith ¶
func (f *FileBuildStorage) RetrieveHashStartsWith(partialGitHash string) ([]*pb.BuildSummary, error)
todo: implement sometime in the future?
func (*FileBuildStorage) RetrieveLastFewSums ¶
func (f *FileBuildStorage) RetrieveLastFewSums(repo string, account string, limit int32) ([]*pb.BuildSummary, error)
stub
func (*FileBuildStorage) RetrieveLastOutByHash ¶
func (f *FileBuildStorage) RetrieveLastOutByHash(gitHash string) (models.BuildOutput, error)
func (*FileBuildStorage) RetrieveLatestSum ¶
func (f *FileBuildStorage) RetrieveLatestSum(gitHash string) (*pb.BuildSummary, error)
func (*FileBuildStorage) RetrieveOut ¶
func (f *FileBuildStorage) RetrieveOut(buildId int64) (models.BuildOutput, error)
func (*FileBuildStorage) RetrieveStageDetail ¶
func (f *FileBuildStorage) RetrieveStageDetail(buildId int64) ([]models.StageResult, error)
func (*FileBuildStorage) RetrieveSum ¶
func (f *FileBuildStorage) RetrieveSum(gitHash string) ([]*pb.BuildSummary, error)
func (*FileBuildStorage) RetrieveSumByBuildId ¶
func (f *FileBuildStorage) RetrieveSumByBuildId(buildId int64) (*pb.BuildSummary, error)
TODO: implement
func (*FileBuildStorage) StorageType ¶
func (f *FileBuildStorage) StorageType() string
type HealthyChkr ¶
type HealthyChkr interface {
Healthy() bool
}
GetCredAt(path string, hideSecret bool, rcc RemoteConfigCred) (map[string]RemoteConfigCred, error)
type HealthyStorage ¶
type HealthyStorage struct {
IsHealthy bool
}
func NewHealthyStorage ¶
func NewHealthyStorage() *HealthyStorage
func (*HealthyStorage) Healthy ¶
func (h *HealthyStorage) Healthy() bool
type MockBuildOut ¶
type MockBuildOut struct {
// contains filtered or unexported fields
}
MockBuildOut is a mock of BuildOut interface
func NewMockBuildOut ¶
func NewMockBuildOut(ctrl *gomock.Controller) *MockBuildOut
NewMockBuildOut creates a new mock instance
func (*MockBuildOut) AddOut ¶
func (m *MockBuildOut) AddOut(output *models.BuildOutput) error
AddOut mocks base method
func (*MockBuildOut) EXPECT ¶
func (m *MockBuildOut) EXPECT() *MockBuildOutMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockBuildOut) RetrieveLastOutByHash ¶
func (m *MockBuildOut) RetrieveLastOutByHash(gitHash string) (models.BuildOutput, error)
RetrieveLastOutByHash mocks base method
func (*MockBuildOut) RetrieveOut ¶
func (m *MockBuildOut) RetrieveOut(buildId int64) (models.BuildOutput, error)
RetrieveOut mocks base method
type MockBuildOutMockRecorder ¶
type MockBuildOutMockRecorder struct {
// contains filtered or unexported fields
}
MockBuildOutMockRecorder is the mock recorder for MockBuildOut
func (*MockBuildOutMockRecorder) AddOut ¶
func (mr *MockBuildOutMockRecorder) AddOut(output interface{}) *gomock.Call
AddOut indicates an expected call of AddOut
func (*MockBuildOutMockRecorder) RetrieveLastOutByHash ¶
func (mr *MockBuildOutMockRecorder) RetrieveLastOutByHash(gitHash interface{}) *gomock.Call
RetrieveLastOutByHash indicates an expected call of RetrieveLastOutByHash
func (*MockBuildOutMockRecorder) RetrieveOut ¶
func (mr *MockBuildOutMockRecorder) RetrieveOut(buildId interface{}) *gomock.Call
RetrieveOut indicates an expected call of RetrieveOut
type MockBuildStage ¶
type MockBuildStage struct {
// contains filtered or unexported fields
}
MockBuildStage is a mock of BuildStage interface
func NewMockBuildStage ¶
func NewMockBuildStage(ctrl *gomock.Controller) *MockBuildStage
NewMockBuildStage creates a new mock instance
func (*MockBuildStage) AddStageDetail ¶
func (m *MockBuildStage) AddStageDetail(stageResult *models.StageResult) error
AddStageDetail mocks base method
func (*MockBuildStage) EXPECT ¶
func (m *MockBuildStage) EXPECT() *MockBuildStageMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockBuildStage) RetrieveStageDetail ¶
func (m *MockBuildStage) RetrieveStageDetail(buildId int64) ([]models.StageResult, error)
RetrieveStageDetail mocks base method
type MockBuildStageMockRecorder ¶
type MockBuildStageMockRecorder struct {
// contains filtered or unexported fields
}
MockBuildStageMockRecorder is the mock recorder for MockBuildStage
func (*MockBuildStageMockRecorder) AddStageDetail ¶
func (mr *MockBuildStageMockRecorder) AddStageDetail(stageResult interface{}) *gomock.Call
AddStageDetail indicates an expected call of AddStageDetail
func (*MockBuildStageMockRecorder) RetrieveStageDetail ¶
func (mr *MockBuildStageMockRecorder) RetrieveStageDetail(buildId interface{}) *gomock.Call
RetrieveStageDetail indicates an expected call of RetrieveStageDetail
type MockBuildSum ¶
type MockBuildSum struct {
// contains filtered or unexported fields
}
MockBuildSum is a mock of BuildSum interface
func NewMockBuildSum ¶
func NewMockBuildSum(ctrl *gomock.Controller) *MockBuildSum
NewMockBuildSum creates a new mock instance
func (*MockBuildSum) AddSumStart ¶
func (m *MockBuildSum) AddSumStart(hash, account, repo, branch string) (int64, error)
AddSumStart mocks base method
func (*MockBuildSum) EXPECT ¶
func (m *MockBuildSum) EXPECT() *MockBuildSumMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockBuildSum) GetLastSuccessfulBuildHash ¶ added in v0.7.3
func (m *MockBuildSum) GetLastSuccessfulBuildHash(account, repo, branch string) (string, error)
GetLastSuccessfulBuildHash mocks base method
func (*MockBuildSum) GetTrackedRepos ¶
func (m *MockBuildSum) GetTrackedRepos() (*pb.AcctRepos, error)
GetTrackedRepos mocks base method
func (*MockBuildSum) RetrieveAcctRepo ¶
func (m *MockBuildSum) RetrieveAcctRepo(partialRepo string) ([]*pb.BuildSummary, error)
RetrieveAcctRepo mocks base method
func (*MockBuildSum) RetrieveHashStartsWith ¶
func (m *MockBuildSum) RetrieveHashStartsWith(partialGitHash string) ([]*pb.BuildSummary, error)
RetrieveHashStartsWith mocks base method
func (*MockBuildSum) RetrieveLastFewSums ¶
func (m *MockBuildSum) RetrieveLastFewSums(repo, account string, limit int32) ([]*pb.BuildSummary, error)
RetrieveLastFewSums mocks base method
func (*MockBuildSum) RetrieveLatestSum ¶
func (m *MockBuildSum) RetrieveLatestSum(gitHash string) (*pb.BuildSummary, error)
RetrieveLatestSum mocks base method
func (*MockBuildSum) RetrieveSum ¶
func (m *MockBuildSum) RetrieveSum(gitHash string) ([]*pb.BuildSummary, error)
RetrieveSum mocks base method
func (*MockBuildSum) RetrieveSumByBuildId ¶
func (m *MockBuildSum) RetrieveSumByBuildId(buildId int64) (*pb.BuildSummary, error)
RetrieveSumByBuildId mocks base method
func (*MockBuildSum) SetQueueTime ¶
func (m *MockBuildSum) SetQueueTime(id int64) error
SetQueueTime mocks base method
func (*MockBuildSum) StartBuild ¶
func (m *MockBuildSum) StartBuild(id int64) error
StartBuild mocks base method
func (*MockBuildSum) StoreFailedValidation ¶
func (m *MockBuildSum) StoreFailedValidation(id int64) error
StoreFailedValidation mocks base method
type MockBuildSumMockRecorder ¶
type MockBuildSumMockRecorder struct {
// contains filtered or unexported fields
}
MockBuildSumMockRecorder is the mock recorder for MockBuildSum
func (*MockBuildSumMockRecorder) AddSumStart ¶
func (mr *MockBuildSumMockRecorder) AddSumStart(hash, account, repo, branch interface{}) *gomock.Call
AddSumStart indicates an expected call of AddSumStart
func (*MockBuildSumMockRecorder) GetLastSuccessfulBuildHash ¶ added in v0.7.3
func (mr *MockBuildSumMockRecorder) GetLastSuccessfulBuildHash(account, repo, branch interface{}) *gomock.Call
GetLastSuccessfulBuildHash indicates an expected call of GetLastSuccessfulBuildHash
func (*MockBuildSumMockRecorder) GetTrackedRepos ¶
func (mr *MockBuildSumMockRecorder) GetTrackedRepos() *gomock.Call
GetTrackedRepos indicates an expected call of GetTrackedRepos
func (*MockBuildSumMockRecorder) RetrieveAcctRepo ¶
func (mr *MockBuildSumMockRecorder) RetrieveAcctRepo(partialRepo interface{}) *gomock.Call
RetrieveAcctRepo indicates an expected call of RetrieveAcctRepo
func (*MockBuildSumMockRecorder) RetrieveHashStartsWith ¶
func (mr *MockBuildSumMockRecorder) RetrieveHashStartsWith(partialGitHash interface{}) *gomock.Call
RetrieveHashStartsWith indicates an expected call of RetrieveHashStartsWith
func (*MockBuildSumMockRecorder) RetrieveLastFewSums ¶
func (mr *MockBuildSumMockRecorder) RetrieveLastFewSums(repo, account, limit interface{}) *gomock.Call
RetrieveLastFewSums indicates an expected call of RetrieveLastFewSums
func (*MockBuildSumMockRecorder) RetrieveLatestSum ¶
func (mr *MockBuildSumMockRecorder) RetrieveLatestSum(gitHash interface{}) *gomock.Call
RetrieveLatestSum indicates an expected call of RetrieveLatestSum
func (*MockBuildSumMockRecorder) RetrieveSum ¶
func (mr *MockBuildSumMockRecorder) RetrieveSum(gitHash interface{}) *gomock.Call
RetrieveSum indicates an expected call of RetrieveSum
func (*MockBuildSumMockRecorder) RetrieveSumByBuildId ¶
func (mr *MockBuildSumMockRecorder) RetrieveSumByBuildId(buildId interface{}) *gomock.Call
RetrieveSumByBuildId indicates an expected call of RetrieveSumByBuildId
func (*MockBuildSumMockRecorder) SetQueueTime ¶
func (mr *MockBuildSumMockRecorder) SetQueueTime(id interface{}) *gomock.Call
SetQueueTime indicates an expected call of SetQueueTime
func (*MockBuildSumMockRecorder) StartBuild ¶
func (mr *MockBuildSumMockRecorder) StartBuild(id interface{}) *gomock.Call
StartBuild indicates an expected call of StartBuild
func (*MockBuildSumMockRecorder) StoreFailedValidation ¶
func (mr *MockBuildSumMockRecorder) StoreFailedValidation(id interface{}) *gomock.Call
StoreFailedValidation indicates an expected call of StoreFailedValidation
func (*MockBuildSumMockRecorder) UpdateSum ¶
func (mr *MockBuildSumMockRecorder) UpdateSum(failed, duration, id interface{}) *gomock.Call
UpdateSum indicates an expected call of UpdateSum
type MockCredTable ¶
type MockCredTable struct {
// contains filtered or unexported fields
}
MockCredTable is a mock of CredTable interface
func NewMockCredTable ¶
func NewMockCredTable(ctrl *gomock.Controller) *MockCredTable
NewMockCredTable creates a new mock instance
func (*MockCredTable) CredExists ¶
func (m *MockCredTable) CredExists(credder pb.OcyCredder) (bool, error)
CredExists mocks base method
func (*MockCredTable) DeleteCred ¶
func (m *MockCredTable) DeleteCred(credder pb.OcyCredder) error
DeleteCred mocks base method
func (*MockCredTable) EXPECT ¶
func (m *MockCredTable) EXPECT() *MockCredTableMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockCredTable) GetVCSTypeFromAccount ¶ added in v0.8.0
func (m *MockCredTable) GetVCSTypeFromAccount(account string) (pb.SubCredType, error)
GetVCSTypeFromAccount mocks base method
func (*MockCredTable) InsertCred ¶
func (m *MockCredTable) InsertCred(credder pb.OcyCredder, overWriteOk bool) error
InsertCred mocks base method
func (*MockCredTable) RetrieveAllCreds ¶
func (m *MockCredTable) RetrieveAllCreds() ([]pb.OcyCredder, error)
RetrieveAllCreds mocks base method
func (*MockCredTable) RetrieveCred ¶
func (m *MockCredTable) RetrieveCred(subCredType pb.SubCredType, identifier, accountName string) (pb.OcyCredder, error)
RetrieveCred mocks base method
func (*MockCredTable) RetrieveCredBySubTypeAndAcct ¶
func (m *MockCredTable) RetrieveCredBySubTypeAndAcct(scredType pb.SubCredType, acctName string) ([]pb.OcyCredder, error)
RetrieveCredBySubTypeAndAcct mocks base method
func (*MockCredTable) RetrieveCreds ¶
func (m *MockCredTable) RetrieveCreds(credType pb.CredType) ([]pb.OcyCredder, error)
RetrieveCreds mocks base method
func (*MockCredTable) UpdateCred ¶
func (m *MockCredTable) UpdateCred(credder pb.OcyCredder) error
UpdateCred mocks base method
type MockCredTableMockRecorder ¶
type MockCredTableMockRecorder struct {
// contains filtered or unexported fields
}
MockCredTableMockRecorder is the mock recorder for MockCredTable
func (*MockCredTableMockRecorder) CredExists ¶
func (mr *MockCredTableMockRecorder) CredExists(credder interface{}) *gomock.Call
CredExists indicates an expected call of CredExists
func (*MockCredTableMockRecorder) DeleteCred ¶
func (mr *MockCredTableMockRecorder) DeleteCred(credder interface{}) *gomock.Call
DeleteCred indicates an expected call of DeleteCred
func (*MockCredTableMockRecorder) GetVCSTypeFromAccount ¶ added in v0.8.0
func (mr *MockCredTableMockRecorder) GetVCSTypeFromAccount(account interface{}) *gomock.Call
GetVCSTypeFromAccount indicates an expected call of GetVCSTypeFromAccount
func (*MockCredTableMockRecorder) InsertCred ¶
func (mr *MockCredTableMockRecorder) InsertCred(credder, overWriteOk interface{}) *gomock.Call
InsertCred indicates an expected call of InsertCred
func (*MockCredTableMockRecorder) RetrieveAllCreds ¶
func (mr *MockCredTableMockRecorder) RetrieveAllCreds() *gomock.Call
RetrieveAllCreds indicates an expected call of RetrieveAllCreds
func (*MockCredTableMockRecorder) RetrieveCred ¶
func (mr *MockCredTableMockRecorder) RetrieveCred(subCredType, identifier, accountName interface{}) *gomock.Call
RetrieveCred indicates an expected call of RetrieveCred
func (*MockCredTableMockRecorder) RetrieveCredBySubTypeAndAcct ¶
func (mr *MockCredTableMockRecorder) RetrieveCredBySubTypeAndAcct(scredType, acctName interface{}) *gomock.Call
RetrieveCredBySubTypeAndAcct indicates an expected call of RetrieveCredBySubTypeAndAcct
func (*MockCredTableMockRecorder) RetrieveCreds ¶
func (mr *MockCredTableMockRecorder) RetrieveCreds(credType interface{}) *gomock.Call
RetrieveCreds indicates an expected call of RetrieveCreds
func (*MockCredTableMockRecorder) UpdateCred ¶
func (mr *MockCredTableMockRecorder) UpdateCred(credder interface{}) *gomock.Call
UpdateCred indicates an expected call of UpdateCred
type MockHealthyChkr ¶
type MockHealthyChkr struct {
// contains filtered or unexported fields
}
MockHealthyChkr is a mock of HealthyChkr interface
func NewMockHealthyChkr ¶
func NewMockHealthyChkr(ctrl *gomock.Controller) *MockHealthyChkr
NewMockHealthyChkr creates a new mock instance
func (*MockHealthyChkr) EXPECT ¶
func (m *MockHealthyChkr) EXPECT() *MockHealthyChkrMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockHealthyChkr) Healthy ¶
func (m *MockHealthyChkr) Healthy() bool
Healthy mocks base method
type MockHealthyChkrMockRecorder ¶
type MockHealthyChkrMockRecorder struct {
// contains filtered or unexported fields
}
MockHealthyChkrMockRecorder is the mock recorder for MockHealthyChkr
func (*MockHealthyChkrMockRecorder) Healthy ¶
func (mr *MockHealthyChkrMockRecorder) Healthy() *gomock.Call
Healthy indicates an expected call of Healthy
type MockOcelotStorage ¶
type MockOcelotStorage struct {
// contains filtered or unexported fields
}
MockOcelotStorage is a mock of OcelotStorage interface
func NewMockOcelotStorage ¶
func NewMockOcelotStorage(ctrl *gomock.Controller) *MockOcelotStorage
NewMockOcelotStorage creates a new mock instance
func (*MockOcelotStorage) AddOut ¶
func (m *MockOcelotStorage) AddOut(output *models.BuildOutput) error
AddOut mocks base method
func (*MockOcelotStorage) AddStageDetail ¶
func (m *MockOcelotStorage) AddStageDetail(stageResult *models.StageResult) error
AddStageDetail mocks base method
func (*MockOcelotStorage) AddSumStart ¶
func (m *MockOcelotStorage) AddSumStart(hash, account, repo, branch string) (int64, error)
AddSumStart mocks base method
func (*MockOcelotStorage) CredExists ¶
func (m *MockOcelotStorage) CredExists(credder pb.OcyCredder) (bool, error)
CredExists mocks base method
func (*MockOcelotStorage) DeleteCred ¶
func (m *MockOcelotStorage) DeleteCred(credder pb.OcyCredder) error
DeleteCred mocks base method
func (*MockOcelotStorage) DeletePoll ¶
func (m *MockOcelotStorage) DeletePoll(account, repo string) error
DeletePoll mocks base method
func (*MockOcelotStorage) EXPECT ¶
func (m *MockOcelotStorage) EXPECT() *MockOcelotStorageMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockOcelotStorage) GetAllPolls ¶
func (m *MockOcelotStorage) GetAllPolls() ([]*pb.PollRequest, error)
GetAllPolls mocks base method
func (*MockOcelotStorage) GetLastData ¶
GetLastData mocks base method
func (*MockOcelotStorage) GetLastSuccessfulBuildHash ¶ added in v0.7.3
func (m *MockOcelotStorage) GetLastSuccessfulBuildHash(account, repo, branch string) (string, error)
GetLastSuccessfulBuildHash mocks base method
func (*MockOcelotStorage) GetTrackedRepos ¶
func (m *MockOcelotStorage) GetTrackedRepos() (*pb.AcctRepos, error)
GetTrackedRepos mocks base method
func (*MockOcelotStorage) GetVCSTypeFromAccount ¶ added in v0.8.0
func (m *MockOcelotStorage) GetVCSTypeFromAccount(account string) (pb.SubCredType, error)
GetVCSTypeFromAccount mocks base method
func (*MockOcelotStorage) Healthy ¶
func (m *MockOcelotStorage) Healthy() bool
Healthy mocks base method
func (*MockOcelotStorage) InsertCred ¶
func (m *MockOcelotStorage) InsertCred(credder pb.OcyCredder, overWriteOk bool) error
InsertCred mocks base method
func (*MockOcelotStorage) InsertPoll ¶
func (m *MockOcelotStorage) InsertPoll(account, repo, cronString, branches string, credsId int64) error
InsertPoll mocks base method
func (*MockOcelotStorage) PollExists ¶
func (m *MockOcelotStorage) PollExists(account, repo string) (bool, error)
PollExists mocks base method
func (*MockOcelotStorage) RetrieveAcctRepo ¶
func (m *MockOcelotStorage) RetrieveAcctRepo(partialRepo string) ([]*pb.BuildSummary, error)
RetrieveAcctRepo mocks base method
func (*MockOcelotStorage) RetrieveAllCreds ¶
func (m *MockOcelotStorage) RetrieveAllCreds() ([]pb.OcyCredder, error)
RetrieveAllCreds mocks base method
func (*MockOcelotStorage) RetrieveCred ¶
func (m *MockOcelotStorage) RetrieveCred(subCredType pb.SubCredType, identifier, accountName string) (pb.OcyCredder, error)
RetrieveCred mocks base method
func (*MockOcelotStorage) RetrieveCredBySubTypeAndAcct ¶
func (m *MockOcelotStorage) RetrieveCredBySubTypeAndAcct(scredType pb.SubCredType, acctName string) ([]pb.OcyCredder, error)
RetrieveCredBySubTypeAndAcct mocks base method
func (*MockOcelotStorage) RetrieveCreds ¶
func (m *MockOcelotStorage) RetrieveCreds(credType pb.CredType) ([]pb.OcyCredder, error)
RetrieveCreds mocks base method
func (*MockOcelotStorage) RetrieveHashStartsWith ¶
func (m *MockOcelotStorage) RetrieveHashStartsWith(partialGitHash string) ([]*pb.BuildSummary, error)
RetrieveHashStartsWith mocks base method
func (*MockOcelotStorage) RetrieveLastFewSums ¶
func (m *MockOcelotStorage) RetrieveLastFewSums(repo, account string, limit int32) ([]*pb.BuildSummary, error)
RetrieveLastFewSums mocks base method
func (*MockOcelotStorage) RetrieveLastOutByHash ¶
func (m *MockOcelotStorage) RetrieveLastOutByHash(gitHash string) (models.BuildOutput, error)
RetrieveLastOutByHash mocks base method
func (*MockOcelotStorage) RetrieveLatestSum ¶
func (m *MockOcelotStorage) RetrieveLatestSum(gitHash string) (*pb.BuildSummary, error)
RetrieveLatestSum mocks base method
func (*MockOcelotStorage) RetrieveOut ¶
func (m *MockOcelotStorage) RetrieveOut(buildId int64) (models.BuildOutput, error)
RetrieveOut mocks base method
func (*MockOcelotStorage) RetrieveStageDetail ¶
func (m *MockOcelotStorage) RetrieveStageDetail(buildId int64) ([]models.StageResult, error)
RetrieveStageDetail mocks base method
func (*MockOcelotStorage) RetrieveSum ¶
func (m *MockOcelotStorage) RetrieveSum(gitHash string) ([]*pb.BuildSummary, error)
RetrieveSum mocks base method
func (*MockOcelotStorage) RetrieveSumByBuildId ¶
func (m *MockOcelotStorage) RetrieveSumByBuildId(buildId int64) (*pb.BuildSummary, error)
RetrieveSumByBuildId mocks base method
func (*MockOcelotStorage) SetLastData ¶
func (m *MockOcelotStorage) SetLastData(account, repo string, lasthashes map[string]string) error
SetLastData mocks base method
func (*MockOcelotStorage) SetQueueTime ¶
func (m *MockOcelotStorage) SetQueueTime(id int64) error
SetQueueTime mocks base method
func (*MockOcelotStorage) StartBuild ¶
func (m *MockOcelotStorage) StartBuild(id int64) error
StartBuild mocks base method
func (*MockOcelotStorage) StorageType ¶
func (m *MockOcelotStorage) StorageType() string
StorageType mocks base method
func (*MockOcelotStorage) StoreFailedValidation ¶
func (m *MockOcelotStorage) StoreFailedValidation(id int64) error
StoreFailedValidation mocks base method
func (*MockOcelotStorage) UpdateCred ¶
func (m *MockOcelotStorage) UpdateCred(credder pb.OcyCredder) error
UpdateCred mocks base method
func (*MockOcelotStorage) UpdatePoll ¶
func (m *MockOcelotStorage) UpdatePoll(account, repo, cronString, branches string) error
UpdatePoll mocks base method
type MockOcelotStorageMockRecorder ¶
type MockOcelotStorageMockRecorder struct {
// contains filtered or unexported fields
}
MockOcelotStorageMockRecorder is the mock recorder for MockOcelotStorage
func (*MockOcelotStorageMockRecorder) AddOut ¶
func (mr *MockOcelotStorageMockRecorder) AddOut(output interface{}) *gomock.Call
AddOut indicates an expected call of AddOut
func (*MockOcelotStorageMockRecorder) AddStageDetail ¶
func (mr *MockOcelotStorageMockRecorder) AddStageDetail(stageResult interface{}) *gomock.Call
AddStageDetail indicates an expected call of AddStageDetail
func (*MockOcelotStorageMockRecorder) AddSumStart ¶
func (mr *MockOcelotStorageMockRecorder) AddSumStart(hash, account, repo, branch interface{}) *gomock.Call
AddSumStart indicates an expected call of AddSumStart
func (*MockOcelotStorageMockRecorder) Close ¶
func (mr *MockOcelotStorageMockRecorder) Close() *gomock.Call
Close indicates an expected call of Close
func (*MockOcelotStorageMockRecorder) CredExists ¶
func (mr *MockOcelotStorageMockRecorder) CredExists(credder interface{}) *gomock.Call
CredExists indicates an expected call of CredExists
func (*MockOcelotStorageMockRecorder) DeleteCred ¶
func (mr *MockOcelotStorageMockRecorder) DeleteCred(credder interface{}) *gomock.Call
DeleteCred indicates an expected call of DeleteCred
func (*MockOcelotStorageMockRecorder) DeletePoll ¶
func (mr *MockOcelotStorageMockRecorder) DeletePoll(account, repo interface{}) *gomock.Call
DeletePoll indicates an expected call of DeletePoll
func (*MockOcelotStorageMockRecorder) GetAllPolls ¶
func (mr *MockOcelotStorageMockRecorder) GetAllPolls() *gomock.Call
GetAllPolls indicates an expected call of GetAllPolls
func (*MockOcelotStorageMockRecorder) GetLastData ¶
func (mr *MockOcelotStorageMockRecorder) GetLastData(accountRepo interface{}) *gomock.Call
GetLastData indicates an expected call of GetLastData
func (*MockOcelotStorageMockRecorder) GetLastSuccessfulBuildHash ¶ added in v0.7.3
func (mr *MockOcelotStorageMockRecorder) GetLastSuccessfulBuildHash(account, repo, branch interface{}) *gomock.Call
GetLastSuccessfulBuildHash indicates an expected call of GetLastSuccessfulBuildHash
func (*MockOcelotStorageMockRecorder) GetTrackedRepos ¶
func (mr *MockOcelotStorageMockRecorder) GetTrackedRepos() *gomock.Call
GetTrackedRepos indicates an expected call of GetTrackedRepos
func (*MockOcelotStorageMockRecorder) GetVCSTypeFromAccount ¶ added in v0.8.0
func (mr *MockOcelotStorageMockRecorder) GetVCSTypeFromAccount(account interface{}) *gomock.Call
GetVCSTypeFromAccount indicates an expected call of GetVCSTypeFromAccount
func (*MockOcelotStorageMockRecorder) Healthy ¶
func (mr *MockOcelotStorageMockRecorder) Healthy() *gomock.Call
Healthy indicates an expected call of Healthy
func (*MockOcelotStorageMockRecorder) InsertCred ¶
func (mr *MockOcelotStorageMockRecorder) InsertCred(credder, overWriteOk interface{}) *gomock.Call
InsertCred indicates an expected call of InsertCred
func (*MockOcelotStorageMockRecorder) InsertPoll ¶
func (mr *MockOcelotStorageMockRecorder) InsertPoll(account, repo, cronString, branches, credsId interface{}) *gomock.Call
InsertPoll indicates an expected call of InsertPoll
func (*MockOcelotStorageMockRecorder) PollExists ¶
func (mr *MockOcelotStorageMockRecorder) PollExists(account, repo interface{}) *gomock.Call
PollExists indicates an expected call of PollExists
func (*MockOcelotStorageMockRecorder) RetrieveAcctRepo ¶
func (mr *MockOcelotStorageMockRecorder) RetrieveAcctRepo(partialRepo interface{}) *gomock.Call
RetrieveAcctRepo indicates an expected call of RetrieveAcctRepo
func (*MockOcelotStorageMockRecorder) RetrieveAllCreds ¶
func (mr *MockOcelotStorageMockRecorder) RetrieveAllCreds() *gomock.Call
RetrieveAllCreds indicates an expected call of RetrieveAllCreds
func (*MockOcelotStorageMockRecorder) RetrieveCred ¶
func (mr *MockOcelotStorageMockRecorder) RetrieveCred(subCredType, identifier, accountName interface{}) *gomock.Call
RetrieveCred indicates an expected call of RetrieveCred
func (*MockOcelotStorageMockRecorder) RetrieveCredBySubTypeAndAcct ¶
func (mr *MockOcelotStorageMockRecorder) RetrieveCredBySubTypeAndAcct(scredType, acctName interface{}) *gomock.Call
RetrieveCredBySubTypeAndAcct indicates an expected call of RetrieveCredBySubTypeAndAcct
func (*MockOcelotStorageMockRecorder) RetrieveCreds ¶
func (mr *MockOcelotStorageMockRecorder) RetrieveCreds(credType interface{}) *gomock.Call
RetrieveCreds indicates an expected call of RetrieveCreds
func (*MockOcelotStorageMockRecorder) RetrieveHashStartsWith ¶
func (mr *MockOcelotStorageMockRecorder) RetrieveHashStartsWith(partialGitHash interface{}) *gomock.Call
RetrieveHashStartsWith indicates an expected call of RetrieveHashStartsWith
func (*MockOcelotStorageMockRecorder) RetrieveLastFewSums ¶
func (mr *MockOcelotStorageMockRecorder) RetrieveLastFewSums(repo, account, limit interface{}) *gomock.Call
RetrieveLastFewSums indicates an expected call of RetrieveLastFewSums
func (*MockOcelotStorageMockRecorder) RetrieveLastOutByHash ¶
func (mr *MockOcelotStorageMockRecorder) RetrieveLastOutByHash(gitHash interface{}) *gomock.Call
RetrieveLastOutByHash indicates an expected call of RetrieveLastOutByHash
func (*MockOcelotStorageMockRecorder) RetrieveLatestSum ¶
func (mr *MockOcelotStorageMockRecorder) RetrieveLatestSum(gitHash interface{}) *gomock.Call
RetrieveLatestSum indicates an expected call of RetrieveLatestSum
func (*MockOcelotStorageMockRecorder) RetrieveOut ¶
func (mr *MockOcelotStorageMockRecorder) RetrieveOut(buildId interface{}) *gomock.Call
RetrieveOut indicates an expected call of RetrieveOut
func (*MockOcelotStorageMockRecorder) RetrieveStageDetail ¶
func (mr *MockOcelotStorageMockRecorder) RetrieveStageDetail(buildId interface{}) *gomock.Call
RetrieveStageDetail indicates an expected call of RetrieveStageDetail
func (*MockOcelotStorageMockRecorder) RetrieveSum ¶
func (mr *MockOcelotStorageMockRecorder) RetrieveSum(gitHash interface{}) *gomock.Call
RetrieveSum indicates an expected call of RetrieveSum
func (*MockOcelotStorageMockRecorder) RetrieveSumByBuildId ¶
func (mr *MockOcelotStorageMockRecorder) RetrieveSumByBuildId(buildId interface{}) *gomock.Call
RetrieveSumByBuildId indicates an expected call of RetrieveSumByBuildId
func (*MockOcelotStorageMockRecorder) SetLastData ¶
func (mr *MockOcelotStorageMockRecorder) SetLastData(account, repo, lasthashes interface{}) *gomock.Call
SetLastData indicates an expected call of SetLastData
func (*MockOcelotStorageMockRecorder) SetQueueTime ¶
func (mr *MockOcelotStorageMockRecorder) SetQueueTime(id interface{}) *gomock.Call
SetQueueTime indicates an expected call of SetQueueTime
func (*MockOcelotStorageMockRecorder) StartBuild ¶
func (mr *MockOcelotStorageMockRecorder) StartBuild(id interface{}) *gomock.Call
StartBuild indicates an expected call of StartBuild
func (*MockOcelotStorageMockRecorder) StorageType ¶
func (mr *MockOcelotStorageMockRecorder) StorageType() *gomock.Call
StorageType indicates an expected call of StorageType
func (*MockOcelotStorageMockRecorder) StoreFailedValidation ¶
func (mr *MockOcelotStorageMockRecorder) StoreFailedValidation(id interface{}) *gomock.Call
StoreFailedValidation indicates an expected call of StoreFailedValidation
func (*MockOcelotStorageMockRecorder) UpdateCred ¶
func (mr *MockOcelotStorageMockRecorder) UpdateCred(credder interface{}) *gomock.Call
UpdateCred indicates an expected call of UpdateCred
func (*MockOcelotStorageMockRecorder) UpdatePoll ¶
func (mr *MockOcelotStorageMockRecorder) UpdatePoll(account, repo, cronString, branches interface{}) *gomock.Call
UpdatePoll indicates an expected call of UpdatePoll
func (*MockOcelotStorageMockRecorder) UpdateSum ¶
func (mr *MockOcelotStorageMockRecorder) UpdateSum(failed, duration, id interface{}) *gomock.Call
UpdateSum indicates an expected call of UpdateSum
type MockPollTable ¶
type MockPollTable struct {
// contains filtered or unexported fields
}
MockPollTable is a mock of PollTable interface
func NewMockPollTable ¶
func NewMockPollTable(ctrl *gomock.Controller) *MockPollTable
NewMockPollTable creates a new mock instance
func (*MockPollTable) DeletePoll ¶
func (m *MockPollTable) DeletePoll(account, repo string) error
DeletePoll mocks base method
func (*MockPollTable) EXPECT ¶
func (m *MockPollTable) EXPECT() *MockPollTableMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockPollTable) GetAllPolls ¶
func (m *MockPollTable) GetAllPolls() ([]*pb.PollRequest, error)
GetAllPolls mocks base method
func (*MockPollTable) GetLastData ¶
GetLastData mocks base method
func (*MockPollTable) InsertPoll ¶
func (m *MockPollTable) InsertPoll(account, repo, cronString, branches string, credsId int64) error
InsertPoll mocks base method
func (*MockPollTable) PollExists ¶
func (m *MockPollTable) PollExists(account, repo string) (bool, error)
PollExists mocks base method
func (*MockPollTable) SetLastData ¶
func (m *MockPollTable) SetLastData(account, repo string, lasthashes map[string]string) error
SetLastData mocks base method
func (*MockPollTable) UpdatePoll ¶
func (m *MockPollTable) UpdatePoll(account, repo, cronString, branches string) error
UpdatePoll mocks base method
type MockPollTableMockRecorder ¶
type MockPollTableMockRecorder struct {
// contains filtered or unexported fields
}
MockPollTableMockRecorder is the mock recorder for MockPollTable
func (*MockPollTableMockRecorder) DeletePoll ¶
func (mr *MockPollTableMockRecorder) DeletePoll(account, repo interface{}) *gomock.Call
DeletePoll indicates an expected call of DeletePoll
func (*MockPollTableMockRecorder) GetAllPolls ¶
func (mr *MockPollTableMockRecorder) GetAllPolls() *gomock.Call
GetAllPolls indicates an expected call of GetAllPolls
func (*MockPollTableMockRecorder) GetLastData ¶
func (mr *MockPollTableMockRecorder) GetLastData(accountRepo interface{}) *gomock.Call
GetLastData indicates an expected call of GetLastData
func (*MockPollTableMockRecorder) InsertPoll ¶
func (mr *MockPollTableMockRecorder) InsertPoll(account, repo, cronString, branches, credsId interface{}) *gomock.Call
InsertPoll indicates an expected call of InsertPoll
func (*MockPollTableMockRecorder) PollExists ¶
func (mr *MockPollTableMockRecorder) PollExists(account, repo interface{}) *gomock.Call
PollExists indicates an expected call of PollExists
func (*MockPollTableMockRecorder) SetLastData ¶
func (mr *MockPollTableMockRecorder) SetLastData(account, repo, lasthashes interface{}) *gomock.Call
SetLastData indicates an expected call of SetLastData
func (*MockPollTableMockRecorder) UpdatePoll ¶
func (mr *MockPollTableMockRecorder) UpdatePoll(account, repo, cronString, branches interface{}) *gomock.Call
UpdatePoll indicates an expected call of UpdatePoll
type MockStringy ¶
type MockStringy struct {
// contains filtered or unexported fields
}
MockStringy is a mock of Stringy interface
func NewMockStringy ¶
func NewMockStringy(ctrl *gomock.Controller) *MockStringy
NewMockStringy creates a new mock instance
func (*MockStringy) EXPECT ¶
func (m *MockStringy) EXPECT() *MockStringyMockRecorder
EXPECT returns an object that allows the caller to indicate expected use
func (*MockStringy) StorageType ¶
func (m *MockStringy) StorageType() string
StorageType mocks base method
type MockStringyMockRecorder ¶
type MockStringyMockRecorder struct {
// contains filtered or unexported fields
}
MockStringyMockRecorder is the mock recorder for MockStringy
func (*MockStringyMockRecorder) StorageType ¶
func (mr *MockStringyMockRecorder) StorageType() *gomock.Call
StorageType indicates an expected call of StorageType
type OcelotStorage ¶
type OcelotStorage interface { BuildOut BuildSum BuildStage Stringy PollTable CredTable HealthyChkr Close() }
type PollTable ¶
type PollTable interface { InsertPoll(account string, repo string, cronString string, branches string, credsId int64) error UpdatePoll(account string, repo string, cronString string, branches string) error SetLastData(account string, repo string, lasthashes map[string]string) error GetLastData(accountRepo string) (timestamp time.Time, hashes map[string]string, err error) PollExists(account string, repo string) (bool, error) GetAllPolls() ([]*pb.PollRequest, error) DeletePoll(account string, repo string) error }
type PostgresStorage ¶
type PostgresStorage struct {
// contains filtered or unexported fields
}
func NewPostgresStorage ¶
func (*PostgresStorage) AddOut ¶
func (p *PostgresStorage) AddOut(output *models.BuildOutput) error
AddOut adds build output text to build_output table
func (*PostgresStorage) AddStageDetail ¶
func (p *PostgresStorage) AddStageDetail(stageResult *models.StageResult) error
AddStageDetail will store the stage data along with a starttime and duration to db
The fields required on stageResult to insert into stage detail table are: stageResult.BuildId, stageResult.Stage, stageResult.Error, stageResult.StartTime, stageResult.StageDuration, stageResult.Status, stageResult.Messages
func (*PostgresStorage) AddSumStart ¶
func (p *PostgresStorage) AddSumStart(hash string, account string, repo string, branch string) (int64, error)
AddSumStart updates the build_summary table with the initial information that you get from a webhook returning the build id that postgres generates
func (*PostgresStorage) Close ¶
func (p *PostgresStorage) Close()
func (*PostgresStorage) Connect ¶
func (p *PostgresStorage) Connect() error
func (*PostgresStorage) CredExists ¶
func (p *PostgresStorage) CredExists(credder pb.OcyCredder) (bool, error)
func (*PostgresStorage) DeleteCred ¶
func (p *PostgresStorage) DeleteCred(credder pb.OcyCredder) error
func (*PostgresStorage) DeletePoll ¶
func (p *PostgresStorage) DeletePoll(account string, repo string) error
func (*PostgresStorage) GetAllPolls ¶
func (p *PostgresStorage) GetAllPolls() ([]*pb.PollRequest, error)
func (*PostgresStorage) GetLastData ¶
func (*PostgresStorage) GetLastSuccessfulBuildHash ¶ added in v0.7.2
func (p *PostgresStorage) GetLastSuccessfulBuildHash(account, repo, branch string) (string, error)
GetLastSuccessfulBuildHash will retrieve the last hash of a successful build on the given branch. If there are no builds for that branch, a BuildSumNotFound error will be returned. If there are no successful builds, a BuildSumNotFound will also be returned.
func (*PostgresStorage) GetTrackedRepos ¶
func (p *PostgresStorage) GetTrackedRepos() (*pb.AcctRepos, error)
func (*PostgresStorage) GetVCSTypeFromAccount ¶ added in v0.8.0
func (p *PostgresStorage) GetVCSTypeFromAccount(account string) (pb.SubCredType, error)
func (*PostgresStorage) Healthy ¶
func (p *PostgresStorage) Healthy() bool
todo: need to write a test for this
func (*PostgresStorage) InsertCred ¶
func (p *PostgresStorage) InsertCred(credder pb.OcyCredder, overwriteOk bool) error
InsertCred will insert an ocyCredder object into the credentials table after calling its ValidateForInsert method. if the OcyCredder fails validation, it will return a *models.ValidationErr
func (*PostgresStorage) InsertPoll ¶
func (*PostgresStorage) PollExists ¶
func (p *PostgresStorage) PollExists(account string, repo string) (bool, error)
func (*PostgresStorage) RetrieveAcctRepo ¶
func (p *PostgresStorage) RetrieveAcctRepo(partialRepo string) ([]*pb.BuildSummary, error)
RetrieveAcctRepo will return to you a list of accountname + repositories that matches starting with partialRepo
func (*PostgresStorage) RetrieveAllCreds ¶
func (p *PostgresStorage) RetrieveAllCreds() ([]pb.OcyCredder, error)
func (*PostgresStorage) RetrieveCred ¶
func (p *PostgresStorage) RetrieveCred(subCredType pb.SubCredType, identifier, accountName string) (pb.OcyCredder, error)
func (*PostgresStorage) RetrieveCredBySubTypeAndAcct ¶
func (p *PostgresStorage) RetrieveCredBySubTypeAndAcct(scredType pb.SubCredType, acctName string) ([]pb.OcyCredder, error)
func (*PostgresStorage) RetrieveCreds ¶
func (p *PostgresStorage) RetrieveCreds(credType pb.CredType) ([]pb.OcyCredder, error)
func (*PostgresStorage) RetrieveHashStartsWith ¶
func (p *PostgresStorage) RetrieveHashStartsWith(partialGitHash string) (hashes []*pb.BuildSummary, err error)
RetrieveHashStartsWith will return a list of all hashes starting with the partial string in db ** THIS WILL ONLY RETURN HASH, ACCOUNT, AND REPO **
func (*PostgresStorage) RetrieveLastFewSums ¶
func (p *PostgresStorage) RetrieveLastFewSums(repo string, account string, limit int32) (sums []*pb.BuildSummary, err error)
RetrieveLastFewSums will return < limit> number of summaries that correlate with a repo and account.
func (*PostgresStorage) RetrieveLastOutByHash ¶
func (p *PostgresStorage) RetrieveLastOutByHash(gitHash string) (models.BuildOutput, error)
RetrieveLastOutByHash will return the last output text that correlates with the gitHash
func (*PostgresStorage) RetrieveLatestSum ¶
func (p *PostgresStorage) RetrieveLatestSum(partialGitHash string) (*pb.BuildSummary, error)
RetrieveLatestSum will return the latest entry of build_summary where hash starts with `gitHash`
func (*PostgresStorage) RetrieveOut ¶
func (p *PostgresStorage) RetrieveOut(buildId int64) (models.BuildOutput, error)
func (*PostgresStorage) RetrieveStageDetail ¶
func (p *PostgresStorage) RetrieveStageDetail(buildId int64) ([]models.StageResult, error)
Retrieve StageDetail will return all stages matching build id
func (*PostgresStorage) RetrieveSum ¶
func (p *PostgresStorage) RetrieveSum(gitHash string) (sums []*pb.BuildSummary, err error)
func (*PostgresStorage) RetrieveSumByBuildId ¶
func (p *PostgresStorage) RetrieveSumByBuildId(buildId int64) (*pb.BuildSummary, error)
RetrieveSumByBuildId will return a build summary based on build id
func (*PostgresStorage) SetLastData ¶
func (*PostgresStorage) SetQueueTime ¶
func (p *PostgresStorage) SetQueueTime(id int64) error
SetQueueTime will update the QueueTime in the database to the current time
func (*PostgresStorage) StartBuild ¶
func (p *PostgresStorage) StartBuild(id int64) error
func (*PostgresStorage) StorageType ¶
func (p *PostgresStorage) StorageType() string
func (*PostgresStorage) StoreFailedValidation ¶
func (p *PostgresStorage) StoreFailedValidation(id int64) error
StoreFailedValidation will update the rest of the summary fields (failed:true, duration:0)
func (*PostgresStorage) UpdateCred ¶
func (p *PostgresStorage) UpdateCred(credder pb.OcyCredder) error