Help us shape the future of Go! Take the 2026 Go Developer Survey

storage

package
v0.7.31 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 6, 2018 License: GPL-3.0 Imports: 27 Imported by: 0

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

View Source 
const TimeFormat = "2006-01-02 15:04:05"

Variables

View Source 
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 

func CreateTestPgDatabase(t *testing.T, port int) (cleanup func(t *testing.T), password string)

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.

func PostgresTeardown 

func PostgresTeardown(t *testing.T, db *sql.DB)

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)
}

func CreateTestFileSystemStorage 

func CreateTestFileSystemStorage(t *testing.T) BuildSum

type Cabinet 

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

func NewCabinet 

func NewCabinet(name string) *Cabinet

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
}

type Dest 

type Dest int
const (
	FileSystem Dest = iota
	Postgres
)

type Drawer 

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

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

func (*FileBuildStorage) UpdateSum 

func (f *FileBuildStorage) UpdateSum(failed bool, duration float64, id int64) error

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

func (*MockBuildSum) UpdateSum 

func (m *MockBuildSum) UpdateSum(failed bool, duration float64, id int64) error

UpdateSum 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) 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) 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) Close 

func (m *MockOcelotStorage) Close()

Close 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() ([]*models.PollRequest, error)

GetAllPolls mocks base method

func (*MockOcelotStorage) GetLastData 

func (m *MockOcelotStorage) GetLastData(accountRepo string) (time.Time, map[string]string, error)

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) 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) 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

func (*MockOcelotStorage) UpdateSum 

func (m *MockOcelotStorage) UpdateSum(failed bool, duration float64, id int64) error

UpdateSum 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) 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 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() ([]*models.PollRequest, error)

GetAllPolls mocks base method

func (*MockPollTable) GetLastData 

func (m *MockPollTable) GetLastData(accountRepo string) (time.Time, map[string]string, error)

GetLastData mocks base method

func (*MockPollTable) InsertPoll 

func (m *MockPollTable) InsertPoll(account, repo, cronString, branches string) 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 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) 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() ([]*models.PollRequest, error)
	DeletePoll(account string, repo string) error
}

type PostgresStorage 

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

func NewPostgresStorage 

func NewPostgresStorage(user string, pw string, loc string, port int, dbLoc string) *PostgresStorage

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() ([]*models.PollRequest, error)

func (*PostgresStorage) GetLastData 

func (p *PostgresStorage) GetLastData(accountRepo string) (timestamp time.Time, hashes map[string]string, err error)

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) 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 (p *PostgresStorage) InsertPoll(account string, repo string, cronString string, branches string) (err error)

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 (p *PostgresStorage) SetLastData(account string, repo string, lasthashes map[string]string) (err error)

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

func (*PostgresStorage) UpdatePoll 

func (p *PostgresStorage) UpdatePoll(account string, repo string, cronString string, branches string) (err error)

func (*PostgresStorage) UpdateSum 

func (p *PostgresStorage) UpdateSum(failed bool, duration float64, id int64) error

UpdateSum updates the remaining fields in the build_summary table

type Stringy 

type Stringy interface {
	StorageType() string
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.