db

package
v1.0.6 Latest Latest
Warning

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

Go to latest
Published: Oct 2, 2018 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source
const (
	CollectionDeployment = "deployment"
	CollectionService    = "service"
	CollectionDomain     = "domain"
	CollectionIngress    = "ingress"
	CollectionCM         = "configmap"
)

Variables

This section is empty.

Functions

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

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) 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) (*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, minPort, maxPort int) (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() 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"`
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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