db

package
v1.0.4 Latest Latest
Warning

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

 Go to latest Published: Aug 17, 2018 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

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)

func Paginate 

func Paginate(query *mgo.Query, info *PageInfo) *mgo.Query

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 (mongo *MongoStorage) CreateDomain(domain domain.Domain) (*domain.Domain, error)

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

func (mongo *MongoStorage) GetDomain(domainName string, pages ...uint) (*domain.Domain, error)

func (*MongoStorage) GetDomainsList 

func (mongo *MongoStorage) GetDomainsList(pages *PageInfo) ([]domain.Domain, error)

GetDomainsList supports pagination

func (*MongoStorage) GetFreePort 

func (mongo *MongoStorage) GetFreePort(domain string, protocol model.Protocol) (int, error)

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 (mongo *MongoStorage) UpdateDomain(domain domain.Domain) (*domain.Domain, error)

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 PageInfo 

type PageInfo struct {
	PerPage        int
	Page           int
	DefaultPerPage int
}

func (PageInfo) Init 

func (pages PageInfo) Init() (limit, offset int)

type PipErr 

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

func (PipErr) Apply 

func (piperr PipErr) Apply(op func(error) error) PipErr

func (PipErr) Extract 

func (piperr PipErr) Extract() error

func (PipErr) NotFoundToNil 

func (piperr PipErr) NotFoundToNil() PipErr

func (PipErr) ToMongerr 

func (piperr PipErr) ToMongerr() PipErr

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"`
}

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.