Documentation
¶
Index ¶
- Constants
- func CollectionsNames() []string
- func DropIndexIfExists(mongo *MongoStorage, cName, indexName string) (bool, error)
- func Paginate(query *mgo.Query, info *PageInfo) *mgo.Query
- type MongoConfig
- type MongoStorage
- func (mongo *MongoStorage) ActivateDeployment(namespace, name string, version semver.Version) error
- func (mongo *MongoStorage) ActivateDeploymentWOVersion(namespace, name string) error
- func (mongo *MongoStorage) Close() (err error)
- func (mongo *MongoStorage) CountAllConfigMaps() (int, error)
- func (mongo *MongoStorage) CountAllDeployments() (int, error)
- func (mongo *MongoStorage) CountAllIngresses() (int, error)
- func (mongo *MongoStorage) CountAllReplicas() (int, error)
- func (mongo *MongoStorage) CountAllServices() (stats.Service, error)
- func (mongo *MongoStorage) CountConfigMaps(owner string) (int, error)
- func (mongo *MongoStorage) CountDeployments(owner string) (int, error)
- func (mongo *MongoStorage) CountIngresses(owner string) (int, error)
- func (mongo *MongoStorage) CountReplicas(owner string) (int, error)
- func (mongo *MongoStorage) CountServices(owner string) (stats.Service, error)
- func (mongo *MongoStorage) CountServicesInNamespace(namespaceID string) (stats.Service, error)
- func (mongo *MongoStorage) CreateConfigMap(cm configmap.ResourceConfigMap) (configmap.ResourceConfigMap, error)
- func (mongo *MongoStorage) CreateDeployment(deployment deployment.ResourceDeploy) (deployment.ResourceDeploy, error)
- func (mongo *MongoStorage) CreateDomain(domain domain.Domain) (*domain.Domain, error)
- func (mongo *MongoStorage) CreateIndex(indexName string, ...) error
- func (mongo *MongoStorage) CreateIngress(ingress ingress.ResourceIngress) (ingress.ResourceIngress, error)
- func (mongo *MongoStorage) CreateService(service service.ResourceService) (service.ResourceService, error)
- func (mongo *MongoStorage) DeactivateDeployment(namespace, name string) error
- func (mongo *MongoStorage) DeleteAllConfigMapsByOwner(owner string) error
- func (mongo *MongoStorage) DeleteAllConfigMapsInNamespace(namespaceID string) error
- func (mongo *MongoStorage) DeleteAllDeploymentsByOwner(owner string) error
- func (mongo *MongoStorage) DeleteAllDeploymentsBySolutionName(nsID, solution string) error
- func (mongo *MongoStorage) DeleteAllDeploymentsInNamespace(namespace string) error
- func (mongo *MongoStorage) DeleteAllIngressesByOwner(owner string) error
- func (mongo *MongoStorage) DeleteAllIngressesInNamespace(namespace string) error
- func (mongo *MongoStorage) DeleteAllServicesByOwner(owner string) error
- func (mongo *MongoStorage) DeleteAllServicesBySolutionName(nsID, solution string) error
- func (mongo *MongoStorage) DeleteAllServicesInNamespace(namespaceID string) error
- func (mongo *MongoStorage) DeleteConfigMap(namespaceID, name string) error
- func (mongo *MongoStorage) DeleteDeployment(namespace, name string) error
- func (mongo *MongoStorage) DeleteDeploymentVersion(namespace, name string, version semver.Version) error
- func (mongo *MongoStorage) DeleteDomain(domainName string) error
- func (mongo *MongoStorage) DeleteIngress(namespaceID, name string) error
- func (mongo *MongoStorage) DeleteService(namespaceID, name string) error
- func (mongo *MongoStorage) GetConfigMap(namespaceID, cmName string) (configmap.ResourceConfigMap, error)
- func (mongo *MongoStorage) GetConfigMapList(namespaceID string) (configmap.ListConfigMaps, error)
- func (mongo *MongoStorage) GetDeployment(namespaceID, deploymentName string) (deployment.ResourceDeploy, error)
- func (mongo *MongoStorage) GetDeploymentLatestVersion(namespaceID, deploymentName string) (deployment.ResourceDeploy, error)
- func (mongo *MongoStorage) GetDeploymentList(namespaceID string) (deployment.ListDeploy, error)
- func (mongo *MongoStorage) GetDeploymentVersion(namespaceID, deploymentName string, version semver.Version) (deployment.ResourceDeploy, error)
- func (mongo *MongoStorage) GetDeploymentVersionsList(namespaceID, deploymentName string) (deployment.ListDeploy, error)
- func (mongo *MongoStorage) GetDomain(domainName string, pages ...uint) (*domain.Domain, error)
- func (mongo *MongoStorage) GetDomainsList(pages *PageInfo) ([]domain.Domain, error)
- func (mongo *MongoStorage) GetFreePort(domain string, protocol model.Protocol) (int, error)
- func (mongo *MongoStorage) GetIngress(namespaceID, name string) (ingress.ResourceIngress, error)
- func (mongo *MongoStorage) GetIngressByService(namespaceID, serviceName string) (ingress.ResourceIngress, error)
- func (mongo *MongoStorage) GetIngressList(namespaceID string) (ingress.ListIngress, error)
- func (mongo *MongoStorage) GetNamespaceResourcesLimits(namespaceID string) (kubtypes.Resource, error)
- func (mongo *MongoStorage) GetRandomDomain() (*domain.Domain, error)
- func (mongo *MongoStorage) GetSelectedConfigMaps(namespaceID []string) (configmap.ListConfigMaps, error)
- func (mongo *MongoStorage) GetSelectedIngresses(namespaceID []string) (ingress.ListIngress, error)
- func (mongo *MongoStorage) GetService(namespaceID, serviceName string) (service.ResourceService, error)
- func (mongo *MongoStorage) GetServiceList(namespaceID string) (service.ListService, error)
- func (mongo *MongoStorage) Init(dbversion string, forceupdate bool) error
- func (mongo *MongoStorage) InitIndexes(dbversion string, forceupdate bool) error
- func (mongo *MongoStorage) IsClosed() bool
- func (mongo *MongoStorage) RestoreConfigMap(namespaceID, name string) error
- func (mongo *MongoStorage) RestoreDeployment(namespace, name string) error
- func (mongo *MongoStorage) RestoreIngress(namespaceID, name string) error
- func (mongo *MongoStorage) RestoreService(namespaceID, name string) error
- func (mongo *MongoStorage) UpdateActiveDeployment(upd deployment.ResourceDeploy) error
- func (mongo *MongoStorage) UpdateDeploymentVersion(namespace, name string, oldversion, newversion semver.Version) error
- func (mongo *MongoStorage) UpdateDomain(domain domain.Domain) (*domain.Domain, error)
- func (mongo *MongoStorage) UpdateIngress(upd ingress.ResourceIngress) (ingress.ResourceIngress, error)
- func (mongo *MongoStorage) UpdateService(upd service.ResourceService) (service.ResourceService, error)
- type PageInfo
- type PipErr
- type StorableMongoConfig
Constants ¶
View Source
const ( CollectionDeployment = "deployment" CollectionService = "service" CollectionDomain = "domain" CollectionIngress = "ingress" CollectionCM = "configmap" CollectionDB = "db" )
Variables ¶
This section is empty.
Functions ¶
func CollectionsNames ¶
func CollectionsNames() []string
func DropIndexIfExists ¶
func DropIndexIfExists(mongo *MongoStorage, cName, indexName string) (bool, error)
Types ¶
type MongoConfig ¶
type MongoConfig struct {
Logger logrus.FieldLogger
// Debug enable the delivery of debug messages to the logger. Only meaningful
// if a logger is also set.
Debug bool
mgo.DialInfo
}
func (MongoConfig) MarshalJSON ¶
func (config MongoConfig) MarshalJSON() ([]byte, error)
func (MongoConfig) Storable ¶
func (config MongoConfig) Storable() StorableMongoConfig
type MongoStorage ¶
type MongoStorage struct {
// contains filtered or unexported fields
}
func NewMongo ¶
func NewMongo(config MongoConfig) (*MongoStorage, error)
func (*MongoStorage) ActivateDeployment ¶
func (mongo *MongoStorage) ActivateDeployment(namespace, name string, version semver.Version) error
func (*MongoStorage) ActivateDeploymentWOVersion ¶ added in v1.0.3
func (mongo *MongoStorage) ActivateDeploymentWOVersion(namespace, name string) error
func (*MongoStorage) Close ¶
func (mongo *MongoStorage) Close() (err error)
func (*MongoStorage) CountAllConfigMaps ¶ added in v1.0.4
func (mongo *MongoStorage) CountAllConfigMaps() (int, error)
func (*MongoStorage) CountAllDeployments ¶ added in v1.0.3
func (mongo *MongoStorage) CountAllDeployments() (int, error)
func (*MongoStorage) CountAllIngresses ¶ added in v1.0.3
func (mongo *MongoStorage) CountAllIngresses() (int, error)
func (*MongoStorage) CountAllReplicas ¶ added in v1.0.3
func (mongo *MongoStorage) CountAllReplicas() (int, error)
func (*MongoStorage) CountAllServices ¶ added in v1.0.3
func (mongo *MongoStorage) CountAllServices() (stats.Service, error)
func (*MongoStorage) CountConfigMaps ¶ added in v1.0.4
func (mongo *MongoStorage) CountConfigMaps(owner string) (int, error)
func (*MongoStorage) CountDeployments ¶
func (mongo *MongoStorage) CountDeployments(owner string) (int, error)
func (*MongoStorage) CountIngresses ¶
func (mongo *MongoStorage) CountIngresses(owner string) (int, error)
func (*MongoStorage) CountReplicas ¶
func (mongo *MongoStorage) CountReplicas(owner string) (int, error)
func (*MongoStorage) CountServices ¶
func (mongo *MongoStorage) CountServices(owner string) (stats.Service, error)
func (*MongoStorage) CountServicesInNamespace ¶
func (mongo *MongoStorage) CountServicesInNamespace(namespaceID string) (stats.Service, error)
func (*MongoStorage) CreateConfigMap ¶ added in v1.0.4
func (mongo *MongoStorage) CreateConfigMap(cm configmap.ResourceConfigMap) (configmap.ResourceConfigMap, error)
If ID is empty, then generates UUID4 and uses it
func (*MongoStorage) CreateDeployment ¶
func (mongo *MongoStorage) CreateDeployment(deployment deployment.ResourceDeploy) (deployment.ResourceDeploy, error)
If ID is empty when use UUID4 to generate one
func (*MongoStorage) CreateDomain ¶
func (*MongoStorage) CreateIndex ¶
func (mongo *MongoStorage) CreateIndex(indexName string, options ...func(mongo *MongoStorage, cName, indexName string) (bool, error)) error
func (*MongoStorage) CreateIngress ¶
func (mongo *MongoStorage) CreateIngress(ingress ingress.ResourceIngress) (ingress.ResourceIngress, error)
func (*MongoStorage) CreateService ¶
func (mongo *MongoStorage) CreateService(service service.ResourceService) (service.ResourceService, error)
If ID is empty, then generates UUID4 and uses it
func (*MongoStorage) DeactivateDeployment ¶
func (mongo *MongoStorage) DeactivateDeployment(namespace, name string) error
func (*MongoStorage) DeleteAllConfigMapsByOwner ¶ added in v1.0.4
func (mongo *MongoStorage) DeleteAllConfigMapsByOwner(owner string) error
func (*MongoStorage) DeleteAllConfigMapsInNamespace ¶ added in v1.0.4
func (mongo *MongoStorage) DeleteAllConfigMapsInNamespace(namespaceID string) error
func (*MongoStorage) DeleteAllDeploymentsByOwner ¶
func (mongo *MongoStorage) DeleteAllDeploymentsByOwner(owner string) error
func (*MongoStorage) DeleteAllDeploymentsBySolutionName ¶
func (mongo *MongoStorage) DeleteAllDeploymentsBySolutionName(nsID, solution string) error
func (*MongoStorage) DeleteAllDeploymentsInNamespace ¶
func (mongo *MongoStorage) DeleteAllDeploymentsInNamespace(namespace string) error
func (*MongoStorage) DeleteAllIngressesByOwner ¶
func (mongo *MongoStorage) DeleteAllIngressesByOwner(owner string) error
func (*MongoStorage) DeleteAllIngressesInNamespace ¶
func (mongo *MongoStorage) DeleteAllIngressesInNamespace(namespace string) error
func (*MongoStorage) DeleteAllServicesByOwner ¶
func (mongo *MongoStorage) DeleteAllServicesByOwner(owner string) error
func (*MongoStorage) DeleteAllServicesBySolutionName ¶
func (mongo *MongoStorage) DeleteAllServicesBySolutionName(nsID, solution string) error
func (*MongoStorage) DeleteAllServicesInNamespace ¶
func (mongo *MongoStorage) DeleteAllServicesInNamespace(namespaceID string) error
func (*MongoStorage) DeleteConfigMap ¶ added in v1.0.4
func (mongo *MongoStorage) DeleteConfigMap(namespaceID, name string) error
func (*MongoStorage) DeleteDeployment ¶
func (mongo *MongoStorage) DeleteDeployment(namespace, name string) error
func (*MongoStorage) DeleteDeploymentVersion ¶
func (mongo *MongoStorage) DeleteDeploymentVersion(namespace, name string, version semver.Version) error
func (*MongoStorage) DeleteDomain ¶
func (mongo *MongoStorage) DeleteDomain(domainName string) error
func (*MongoStorage) DeleteIngress ¶
func (mongo *MongoStorage) DeleteIngress(namespaceID, name string) error
func (*MongoStorage) DeleteService ¶
func (mongo *MongoStorage) DeleteService(namespaceID, name string) error
func (*MongoStorage) GetConfigMap ¶ added in v1.0.4
func (mongo *MongoStorage) GetConfigMap(namespaceID, cmName string) (configmap.ResourceConfigMap, error)
func (*MongoStorage) GetConfigMapList ¶ added in v1.0.4
func (mongo *MongoStorage) GetConfigMapList(namespaceID string) (configmap.ListConfigMaps, error)
func (*MongoStorage) GetDeployment ¶
func (mongo *MongoStorage) GetDeployment(namespaceID, deploymentName string) (deployment.ResourceDeploy, error)
func (*MongoStorage) GetDeploymentLatestVersion ¶
func (mongo *MongoStorage) GetDeploymentLatestVersion(namespaceID, deploymentName string) (deployment.ResourceDeploy, error)
func (*MongoStorage) GetDeploymentList ¶
func (mongo *MongoStorage) GetDeploymentList(namespaceID string) (deployment.ListDeploy, error)
func (*MongoStorage) GetDeploymentVersion ¶
func (mongo *MongoStorage) GetDeploymentVersion(namespaceID, deploymentName string, version semver.Version) (deployment.ResourceDeploy, error)
func (*MongoStorage) GetDeploymentVersionsList ¶
func (mongo *MongoStorage) GetDeploymentVersionsList(namespaceID, deploymentName string) (deployment.ListDeploy, error)
func (*MongoStorage) GetDomainsList ¶
func (mongo *MongoStorage) GetDomainsList(pages *PageInfo) ([]domain.Domain, error)
GetDomainsList supports pagination
func (*MongoStorage) GetFreePort ¶
func (*MongoStorage) GetIngress ¶
func (mongo *MongoStorage) GetIngress(namespaceID, name string) (ingress.ResourceIngress, error)
func (*MongoStorage) GetIngressByService ¶
func (mongo *MongoStorage) GetIngressByService(namespaceID, serviceName string) (ingress.ResourceIngress, error)
func (*MongoStorage) GetIngressList ¶
func (mongo *MongoStorage) GetIngressList(namespaceID string) (ingress.ListIngress, error)
func (*MongoStorage) GetNamespaceResourcesLimits ¶
func (mongo *MongoStorage) GetNamespaceResourcesLimits(namespaceID string) (kubtypes.Resource, error)
func (*MongoStorage) GetRandomDomain ¶
func (mongo *MongoStorage) GetRandomDomain() (*domain.Domain, error)
func (*MongoStorage) GetSelectedConfigMaps ¶ added in v1.0.4
func (mongo *MongoStorage) GetSelectedConfigMaps(namespaceID []string) (configmap.ListConfigMaps, error)
func (*MongoStorage) GetSelectedIngresses ¶ added in v1.0.4
func (mongo *MongoStorage) GetSelectedIngresses(namespaceID []string) (ingress.ListIngress, error)
func (*MongoStorage) GetService ¶
func (mongo *MongoStorage) GetService(namespaceID, serviceName string) (service.ResourceService, error)
func (*MongoStorage) GetServiceList ¶
func (mongo *MongoStorage) GetServiceList(namespaceID string) (service.ListService, error)
func (*MongoStorage) Init ¶
func (mongo *MongoStorage) Init(dbversion string, forceupdate bool) error
func (*MongoStorage) InitIndexes ¶
func (mongo *MongoStorage) InitIndexes(dbversion string, forceupdate bool) error
func (*MongoStorage) IsClosed ¶
func (mongo *MongoStorage) IsClosed() bool
func (*MongoStorage) RestoreConfigMap ¶ added in v1.0.4
func (mongo *MongoStorage) RestoreConfigMap(namespaceID, name string) error
func (*MongoStorage) RestoreDeployment ¶
func (mongo *MongoStorage) RestoreDeployment(namespace, name string) error
func (*MongoStorage) RestoreIngress ¶
func (mongo *MongoStorage) RestoreIngress(namespaceID, name string) error
func (*MongoStorage) RestoreService ¶
func (mongo *MongoStorage) RestoreService(namespaceID, name string) error
func (*MongoStorage) UpdateActiveDeployment ¶
func (mongo *MongoStorage) UpdateActiveDeployment(upd deployment.ResourceDeploy) error
func (*MongoStorage) UpdateDeploymentVersion ¶
func (mongo *MongoStorage) UpdateDeploymentVersion(namespace, name string, oldversion, newversion semver.Version) error
func (*MongoStorage) UpdateDomain ¶
func (*MongoStorage) UpdateIngress ¶
func (mongo *MongoStorage) UpdateIngress(upd ingress.ResourceIngress) (ingress.ResourceIngress, error)
func (*MongoStorage) UpdateService ¶
func (mongo *MongoStorage) UpdateService(upd service.ResourceService) (service.ResourceService, error)
type PipErr ¶
type PipErr struct {
// contains filtered or unexported fields
}
func (PipErr) NotFoundToNil ¶
type StorableMongoConfig ¶
type StorableMongoConfig struct {
// Debug enable the delivery of debug messages to the logger. Only meaningful
// if a logger is also set.
Debug bool `json:"debug"`
// Addrs holds the addresses for the seed servers.
Addrs []string `json:"addrs"`
// Timeout is the amount of time to wait for a server to respond when
// first connecting and on follow up operations in the session. If
// timeout is zero, the call may block forever waiting for a connection
// to be established. Timeout does not affect logic in DialServer.
Timeout time.Duration `json:"timeout"`
// Database is the default database name used when the Session.DB method
// is called with an empty name, and is also used during the initial
// authentication if Source is unset.
Database string `json:"database"`
// ReplicaSetName, if specified, will prevent the obtained session from
// communicating with any server which is not part of a replica set
// with the given name. The default is to communicate with any server
// specified or discovered via the servers contacted.
ReplicaSetName string `json:"replica_set_name"`
// Source is the database used to establish credentials and privileges
// with a MongoDB server. Defaults to the value of Database, if that is
// set, or "admin" otherwise.
Source string `json:"source"`
// Service defines the service name to use when authenticating with the GSSAPI
// mechanism. Defaults to "mongodb".
Service string `json:"service"`
// ServiceHost defines which hostname to use when authenticating
// with the GSSAPI mechanism. If not specified, defaults to the MongoDB
// server's address.
ServiceHost string `json:"service_host"`
// Mechanism defines the protocol for credential negotiation.
// Defaults to "MONGODB-CR".
Mechanism string `json:"mechanism"`
// Username and Password inform the credentials for the initial authentication
// done on the database defined by the Source field. See Session.Login.
Username string `json:"username"`
Password string `json:"password"`
// PoolLimit defines the per-server socket pool limit. Defaults to 4096.
// See Session.SetPoolLimit for details.
PoolLimit int `json:"pool_limit"`
// PoolTimeout defines max time to wait for a connection to become available
// if the pool limit is reaqched. Defaults to zero, which means forever.
// See Session.SetPoolTimeout for details
PoolTimeout time.Duration `json:"pool_timeout"`
// The identifier of the client application which ran the operation.
AppName string `json:"app_name"`
// ReadPreference defines the manner in which servers are chosen. See
// Session.SetMode and Session.SelectServers.
ReadPreference *mgo.ReadPreference `json:"read_preference,omitempty"`
// FailFast will cause connection and query attempts to fail faster when
// the server is unavailable, instead of retrying until the configured
// timeout period. Note that an unavailable server may silently drop
// packets instead of rejecting them, in which case it's impossible to
// distinguish it from a slow server, so the timeout stays relevant.
FailFast bool `json:"fail_fast"`
// Direct informs whether to establish connections only with the
// specified seed servers, or to obtain information for the whole
// cluster and establish connections with further servers too.
Direct bool `json:"direct"`
// MinPoolSize defines The minimum number of connections in the connection pool.
// Defaults to 0.
MinPoolSize int `json:"min_pool_size"`
//The maximum number of milliseconds that a connection can remain idle in the pool
// before being removed and closed.
MaxIdleTimeMS int `json:"max_idle_time_ms"`
}
Click to show internal directories.
Click to hide internal directories.