store

package
v0.3.5-hr Latest Latest
Warning

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

 Go to latest Published: May 9, 2018 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ResourceCollectionName string = "ResourceCollection"
	CloudsCollection       string = "clouds"
)

Variables

This section is empty.

Functions

func FindServiceAndVersion added in v0.3.0 

func FindServiceAndVersion(versionID string) (*api.Service, *api.Version, error)

findVersionAndService finds service and version entity based on version id.

func Init 

func Init(host string, gracePeriod time.Duration, closing chan struct{}) (*mgo.Session, chan struct{}, error)

Init store mongo client session

Types

type DataStore 

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

DataStore is the type for mongo db store.

func NewStore 

func NewStore() *DataStore

NewStore copy a mongo client session

func (*DataStore) AddNewFailVersion 

func (d *DataStore) AddNewFailVersion(serviceID string, versionID string) error

AddNewFailVersion adds a new fail version (version ID) to a given service.

func (*DataStore) AddNewVersion 

func (d *DataStore) AddNewVersion(serviceID string, versionID string) error

AddNewVersion adds a new success version (version ID) to a given service.

func (*DataStore) Close 

func (d *DataStore) Close()

Close close mongo client session

func (*DataStore) CreatePipeline 

func (d *DataStore) CreatePipeline(pipeline *api.Pipeline) (*api.Pipeline, error)

CreatePipeline creates the pipeline, returns the pipeline created.

func (*DataStore) CreatePipelineRecord 

func (d *DataStore) CreatePipelineRecord(pipelineRecord *api.PipelineRecord) (*api.PipelineRecord, error)

CreatePipelineRecord creates the pipeline record, returns the pipeline record created.

func (*DataStore) CreateProject 

func (d *DataStore) CreateProject(project *api.Project) (*api.Project, error)

CreateProject creates the project, returns the project created.

func (*DataStore) CreateToken 

func (d *DataStore) CreateToken(token *api.ScmToken) (*api.ScmToken, error)

CreateToken creates creates the token, returns the token created.

func (*DataStore) DeleteCloudByName 

func (d *DataStore) DeleteCloudByName(name string) error

DeleteCloudByName delete a cloud in db by name

func (*DataStore) DeleteDeployByID 

func (d *DataStore) DeleteDeployByID(deployID string) error

DeleteDeployByID removes deploy by deploy_id.

func (*DataStore) DeletePipelineByID 

func (d *DataStore) DeletePipelineByID(pipelineID string) error

DeletePipelineByID deletes the pipeline by id.

func (*DataStore) DeletePipelineRecordByID 

func (d *DataStore) DeletePipelineRecordByID(pipelineRecordID string) error

DeletePipelineRecordByID deletes the pipeline record by id.

func (*DataStore) DeletePipelineRecordsByPipelineID 

func (d *DataStore) DeletePipelineRecordsByPipelineID(pipelineID string) error

DeletePipelineRecordsByPipelineID deletes all the pipeline records of one pipeline by pipeline id.

func (*DataStore) DeletePipelinesByProjectID 

func (d *DataStore) DeletePipelinesByProjectID(projectID string) error

DeletePipelinesByProjectID deletes all the pipelines in one project by project id.

func (*DataStore) DeleteProjectByID 

func (d *DataStore) DeleteProjectByID(projectID string) error

DeleteProjectByID deletes the project by id.

func (*DataStore) DeleteServiceByID 

func (d *DataStore) DeleteServiceByID(serviceID string) error

DeleteServiceByID removes service by service_id.

func (*DataStore) DeleteToken 

func (d *DataStore) DeleteToken(projectID, scmType string) error

DeleteToken deletes the token with the project id and scm type.

func (*DataStore) DeleteVersionByID 

func (d *DataStore) DeleteVersionByID(versionID string) error

DeleteVersionByID removes version by versionID.

func (*DataStore) FindAllClouds 

func (d *DataStore) FindAllClouds() ([]cloud.Options, error)

FindAllClouds returns all clouds

func (*DataStore) FindCloudByName 

func (d *DataStore) FindCloudByName(name string) (*cloud.Options, error)

FindCloudByName returns a cloud in db by name

func (*DataStore) FindDeployByID 

func (d *DataStore) FindDeployByID(deployID string) (*api.Deploy, error)

FindDeployByID finds a deploy entity by ID.

func (*DataStore) FindDeployByUserID 

func (d *DataStore) FindDeployByUserID(userID string) ([]api.Deploy, error)

FindDeployByUserID finds deploys entity by userID.

func (*DataStore) FindLatestVersionByServiceID 

func (d *DataStore) FindLatestVersionByServiceID(serviceID string) (*api.Version, error)

FindLatestVersionByServiceID finds the latest version entity by service ID.

func (*DataStore) FindPipelineByID 

func (d *DataStore) FindPipelineByID(pipelineID string) (*api.Pipeline, error)

FindPipelineByID finds the pipeline by id.

func (*DataStore) FindPipelineByName 

func (d *DataStore) FindPipelineByName(projectID string, name string) (*api.Pipeline, error)

FindPipelineByName finds the pipeline by name in one project. If find no pipeline or more than one pipeline, return error.

func (*DataStore) FindPipelineByServiceID added in v0.3.0 

func (d *DataStore) FindPipelineByServiceID(serviceID string) (*api.Pipeline, error)

FindPipelineByServiceID finds the pipeline by service id.

func (*DataStore) FindPipelineRecordByID 

func (d *DataStore) FindPipelineRecordByID(pipelineRecordID string) (*api.PipelineRecord, error)

FindPipelineRecordByID finds the pipeline record by id.

func (*DataStore) FindPipelineRecordsByPipelineID 

func (d *DataStore) FindPipelineRecordsByPipelineID(pipelineID string, queryParams api.QueryParams) ([]api.PipelineRecord, int, error)

FindPipelineRecordsByPipelineID finds the pipeline records by pipelineID.

func (*DataStore) FindPipelinesByProjectID 

func (d *DataStore) FindPipelinesByProjectID(projectID string, queryParams api.QueryParams) ([]api.Pipeline, int, error)

FindPipelinesByProjectID finds the pipelines by project id. Will returns all pipelines in this project.

func (*DataStore) FindProjectByID 

func (d *DataStore) FindProjectByID(projectID string) (*api.Project, error)

FindProjectByID finds the project by id.

func (*DataStore) FindProjectByName 

func (d *DataStore) FindProjectByName(name string) (*api.Project, error)

FindProjectByName finds the project by name. If find no project or more than one project, return error.

func (*DataStore) FindProjectByServiceID added in v0.3.0 

func (d *DataStore) FindProjectByServiceID(serviceID string) (*api.Project, error)

FindProjectByServiceID finds the project by service id.

func (*DataStore) FindRecentVersionsByServiceID 

func (d *DataStore) FindRecentVersionsByServiceID(serviceID string, filter map[string]interface{}, limit int) ([]api.Version, int, error)

FindRecentVersionsByServiceID finds a set of versions with conditions by service ID.

func (*DataStore) FindResourceByID 

func (d *DataStore) FindResourceByID(userID string) (*api.Resource, error)

FindResourceByID finds a resource entity by userID.

func (*DataStore) FindServiceByCondition 

func (d *DataStore) FindServiceByCondition(userID, servicename string) ([]api.Service, error)

FindServiceByCondition finds a list of services via user ID and serice name.

func (*DataStore) FindServiceByID 

func (d *DataStore) FindServiceByID(serviceID string) (*api.Service, error)

FindServiceByID finds a service entity by ID.

func (*DataStore) FindServicesByUserID 

func (d *DataStore) FindServicesByUserID(userID string) ([]api.Service, error)

FindServicesByUserID finds a list of services via user ID.

func (*DataStore) FindVersionByID 

func (d *DataStore) FindVersionByID(versionID string) (*api.Version, error)

FindVersionByID finds a version entity by ID.

func (*DataStore) FindVersionLogByID 

func (d *DataStore) FindVersionLogByID(LogID string) (*api.VersionLog, error)

FindVersionLogByID finds a version log entity by ID.

func (*DataStore) FindVersionLogByVersionID 

func (d *DataStore) FindVersionLogByVersionID(versionID string) (*api.VersionLog, error)

FindVersionLogByVersionID finds a version log entity by version ID.

func (*DataStore) FindVersionsByCondition 

func (d *DataStore) FindVersionsByCondition(serviceID, versionname string) ([]api.Version, error)

FindVersionsByCondition finds a version entity by service ID and version name.

func (*DataStore) FindVersionsByServiceID 

func (d *DataStore) FindVersionsByServiceID(serviceID string) ([]api.Version, error)

FindVersionsByServiceID finds a version entity by service ID.

func (*DataStore) FindVersionsWithPaginationByServiceID 

func (d *DataStore) FindVersionsWithPaginationByServiceID(serviceID string, filter map[string]interface{}, start, limit int) ([]api.Version, int, error)

FindVersionsWithPaginationByServiceID finds a page of versions by service ID.

func (*DataStore) Findtoken 

func (d *DataStore) Findtoken(projectID, scmType string) (*api.ScmToken, error)

Findtoken finds the token by project id and scm type.

func (*DataStore) FindtokenByUserID 

func (d *DataStore) FindtokenByUserID(userID, urlvsc string) (*api.VscToken, error)

FindtokenByUserID finds token by UserID.

func (*DataStore) GetProjects 

func (d *DataStore) GetProjects(queryParams api.QueryParams) ([]api.Project, int, error)

GetProjects gets all projects. Will returns all projects.

func (*DataStore) InsertCloud 

func (d *DataStore) InsertCloud(doc *cloud.Options) error

InsertCloud insert a new cloud document to db

func (*DataStore) NewDeployDocument 

func (d *DataStore) NewDeployDocument(deploy *api.Deploy) (string, error)

NewDeployDocument creates a new document (record) in mongodb. It returns deploy id of the newly created deploy.

func (*DataStore) NewResourceDocument 

func (d *DataStore) NewResourceDocument(resource *api.Resource) error

NewResourceDocument creates a new document (record) in mongodb.

func (*DataStore) NewServiceDocument 

func (d *DataStore) NewServiceDocument(service *api.Service) (string, error)

NewServiceDocument creates a new document (record) in mongodb. It returns service id of the newly created service.

func (*DataStore) NewTokenDocument 

func (d *DataStore) NewTokenDocument(token *api.VscToken) error

NewTokenDocument creates a new document (record) in mongodb.

func (*DataStore) NewVersionDocument 

func (d *DataStore) NewVersionDocument(version *api.Version) (string, error)

NewVersionDocument creates a new document (record) in mongodb. It returns version id of the newly created version.

func (*DataStore) NewVersionLogDocument 

func (d *DataStore) NewVersionLogDocument(versionLog *api.VersionLog) (string, error)

NewVersionLogDocument creates a new document (record) in mongodb. It returns version log id of the newly created version.

func (*DataStore) Ping 

func (d *DataStore) Ping() error

Ping ping mongo server

func (*DataStore) RemoveTokeninDB 

func (d *DataStore) RemoveTokeninDB(userID string, urlvsc string) error

RemoveTokeninDB removes token.

func (*DataStore) UpdatePipeline 

func (d *DataStore) UpdatePipeline(pipeline *api.Pipeline) error

UpdatePipeline updates the pipeline, please make sure the pipeline id is provided before call this method.

func (*DataStore) UpdatePipelineRecord 

func (d *DataStore) UpdatePipelineRecord(pipelineRecord *api.PipelineRecord) error

UpdatePipelineRecord updates the pipeline record.

func (*DataStore) UpdateProject 

func (d *DataStore) UpdateProject(project *api.Project) error

UpdateProject updates the project, please make sure the project id is provided before call this method.

func (*DataStore) UpdateRepositoryStatus 

func (d *DataStore) UpdateRepositoryStatus(serviceID string, status api.RepositoryStatus) error

UpdateRepositoryStatus updates service repository status.

func (*DataStore) UpdateResourceDocument 

func (d *DataStore) UpdateResourceDocument(resource *api.Resource) error

UpdateResourceDocument update a document (record) in mongodb.

func (*DataStore) UpdateResourceStatus 

func (d *DataStore) UpdateResourceStatus(userID string, memory float64, cpu float64) error

UpdateResourceStatus updates resource's memory and cpu.

func (*DataStore) UpdateServiceLastInfo 

func (d *DataStore) UpdateServiceLastInfo(serviceID string, lasttime time.Time, lastname string) error

UpdateServiceLastInfo updates service's lastCreateTIme and lastVersionName.

func (*DataStore) UpdateToken 

func (d *DataStore) UpdateToken(token *api.VscToken) error

UpdateToken update token via user ID.

func (*DataStore) UpdateToken2 

func (d *DataStore) UpdateToken2(token *api.ScmToken) error

UpdateToken2 updates the token, please make sure the project id and scm type is provided before call this method.

func (*DataStore) UpdateVersionDocument 

func (d *DataStore) UpdateVersionDocument(versionID string, version api.Version) error

UpdateVersionDocument updates a version entirely.

func (*DataStore) UpdateVersionLogDocument 

func (d *DataStore) UpdateVersionLogDocument(versionLog *api.VersionLog) error

UpdateVersionLogDocument updates a document (record) in mongodb.

func (*DataStore) UpsertCloud 

func (d *DataStore) UpsertCloud(doc *cloud.Options) error

UpsertCloud insert a new cloud document to db

func (*DataStore) UpsertDeployDocument 

func (d *DataStore) UpsertDeployDocument(deploy *api.Deploy) (string, error)

UpsertDeployDocument upsert a special deploy document

func (*DataStore) UpsertServiceDocument 

func (d *DataStore) UpsertServiceDocument(service *api.Service) (string, error)

UpsertServiceDocument upsert a special serivce document

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.