store

package

v0.0.0-...-1806480 Latest Latest Go to latest Published: Feb 28, 2017 License: Apache-2.0 Imports: 5 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/gaocegege/cyclone

Links

Open Source Insights

Documentation ¶

Constants ¶

View Source

const (
	ResourceCollectionName string = "ResourceCollection"
)

Variables ¶

This section is empty.

Functions ¶

func Init ¶

func Init(s *mgo.Session)

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

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

DeleteDeployByID removes deploy by deploy_id.

func (*DataStore) DeleteServiceByID ¶

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

DeleteServiceByID removes service by service_id.

func (*DataStore) DeleteVersionByID ¶

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

DeleteVersionByID removes version by versionID.

func (*DataStore) DeleteWorkerNodeByID ¶

func (d *DataStore) DeleteWorkerNodeByID(nodeID string) error

DeleteWorkerNodeByID removes worker node by node_id.

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

func (d *DataStore) FindSystemWorkerNode() ([]api.WorkerNode, error)

FindSystemWorkerNode finds a list of system worker node.

func (*DataStore) FindSystemWorkerNodeByResource ¶

func (d *DataStore) FindSystemWorkerNodeByResource(resource *api.BuildResource) ([]api.WorkerNode, error)

FindSystemWorkerNodeByResource finds a list of system worker node by resouce.

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

func (d *DataStore) FindWorkerNodeByID(nodeID string) (*api.WorkerNode, error)

FindWorkerNodeByID finds a worker node entity by ID.

func (*DataStore) FindWorkerNodesByDockerHost ¶

func (d *DataStore) FindWorkerNodesByDockerHost(dockerHost string) ([]api.WorkerNode, error)

FindWorkerNodesByDockerHost finds a list of WorkerNodes via docker host.

func (*DataStore) FindtokenByUserID ¶

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

FindtokenByUserID finds token by UserID.

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

func (d *DataStore) NewSystemWorkerNodeDocument(workerNode *api.WorkerNode) (string, error)

NewSystemWorkerNodeDocument creates a new document (record) in mongodb. It returns worker node id of the newly created worker node.

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

func (*DataStore) UpsertWorkerNodeDocument ¶

func (d *DataStore) UpsertWorkerNodeDocument(node *api.WorkerNode) (string, error)

UpsertWorkerNodeDocument upsert a special woker node document

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL