Versions in this module Expand all Collapse all v0 v0.0.1 Apr 21, 2020 Changes in this version + const AaaMode + const AgentMode + const AlarmgenIntrospectPort + const AlarmgenRedisAggregateDbOffset + const AnalyticsAlarmEnable + const AnalyticsAlarmNodes + const AnalyticsApiIntrospectPort + const AnalyticsApiPort + const AnalyticsApiVip + const AnalyticsNodes + const AnalyticsServers + const AnalyticsSnmpEnable + const AnalyticsSnmpNodes + const AnalyticsdbCqlPort + const AnalyticsdbCqlServers + const AnalyticsdbEnable + const AnalyticsdbNodes + const AnalyticsdbPort + const AuthMode + const AuthParams + const BarbicanPassword + const BarbicanUser + const BgpAsn + const BgpAutoMesh + const BgpPort + const CassandraConfigCompactionThroughputMbPerSec + const CassandraConfigConcurrectCompactors + const CassandraConfigConcurrectReads + const CassandraConfigConcurrectWrites + const CassandraConfigMemtableAllocationType + const CassandraConfigMemtableFlushWriter + const CassandraCqlPort + const CassandraJmxLocalPort + const CassandraPort + const CassandraSslAlgorithm + const CassandraSslCaCertfile + const CassandraSslCertfile + const CassandraSslCipherSuites + const CassandraSslEnable + const CassandraSslKeyfile + const CassandraSslKeystorePassword + const CassandraSslProtocol + const CassandraSslStoragePort + const CassandraSslTruststorePassword + const CassandraStoragePort + const CloudAdminRole + const CloudOrchestrator + const CollectorIntrospectPort + const CollectorIpfixPort + const CollectorPort + const CollectorProtobufPort + const CollectorServers + const CollectorSflowPort + const CollectorStructuredSyslogPort + const CollectorSyslogPort + const ConfigApiIntrospectPort + const ConfigApiPort + const ConfigApiServerCaCertfile + const ConfigApiServerCertfile + const ConfigApiServerKeyfile + const ConfigApiSslEnable + const ConfigApiVip + const ConfigNodes + const ConfigServers + const ConfigdbCqlPort + const ConfigdbCqlServers + const ConfigdbNodes + const ConfigdbPort + const ConfigdbServers + const ConfigureIptables + const ControlIntrospectPort + const ControlNodes + const ControllerNodes + const CpuCoreMask + const DMRunModeFull + const DistSnatProtoPortList + const DnsIntrospectPort + const DnsNodes + const DnsServerPort + const DpdkCommandAdditionalArgs + const DpdkMemPerSocket + const DpdkUioDriver + const EncapPriority + const ExternalRouters + const FabricSnatHashTableSize + const FlowExportRate + const FwaasEnable + const HugePages + const HugePagesDir + const IntrospectCaCertfile + const IntrospectCertfile + const IntrospectKeyfile + const IntrospectListenAll + const IntrospectSslEnable + const IntrospectSslInsecure + const IpfabricServicePort + const KafkaNodes + const KafkaPort + const KafkaServers + const KafkaSslCacertfile + const KafkaSslCertfile + const KafkaSslEnable + const KafkaSslKeyfile + const KeystoneAuthAdminPassword + const KeystoneAuthAdminPort + const KeystoneAuthAdminTenant + const KeystoneAuthAdminUser + const KeystoneAuthCaCertfile + const KeystoneAuthCertfile + const KeystoneAuthHost + const KeystoneAuthInsecure + const KeystoneAuthKeyfile + const KeystoneAuthProjectDomainName + const KeystoneAuthProto + const KeystoneAuthPublicPort + const KeystoneAuthRegionName + const KeystoneAuthUrlTokens + const KeystoneAuthUrlVersion + const KeystoneAuthUserDomainName + const KubemanagerNodes + const KubernetesApiNodes + const KubernetesApiPort + const KubernetesApiSSLPort + const KubernetesApiServer + const KubernetesClusterName + const KubernetesHostNetworkService + const KubernetesIPFabricForwarding + const KubernetesIPFabricSnat + const KubernetesIpFabricSubnets + const KubernetesPodSubnets + const KubernetesServiceAccount + const KubernetesServiceSubnets + const KubernetesUseKubeadm + const KueUiPort + const LinklocalServiceIp + const LinklocalServiceName + const LinklocalServicePort + const LogDir + const LogLevel + const LogLocal + const MetadataProxySecret + const MetadataSslCaCertfile + const MetadataSslCertType + const MetadataSslCertfile + const MetadataSslEnable + const MetadataSslKeyfile + const NicOffloadEnable + const PriorityBandwidth + const PriorityId + const PriorityScheduling + const PriorityTagging + const QosDefHwQueue + const QosLogicalQueues + const QosQueueId + const QueryengineIntrospectPort + const RabbitmqClientSslCacertfile + const RabbitmqClientSslCertfile + const RabbitmqClientSslKeyfile + const RabbitmqErlangCookie + const RabbitmqHeartbeatInterval + const RabbitmqMirroredQueueMode + const RabbitmqNodePort + const RabbitmqNodePortSSL + const RabbitmqNodes + const RabbitmqPassword + const RabbitmqServers + const RabbitmqSslCacertfile + const RabbitmqSslCertfile + const RabbitmqSslFailIfNoPeerCert + const RabbitmqSslKeyfile + const RabbitmqSslVer + const RabbitmqUseSsl + const RabbitmqUser + const RabbitmqVhost + const RedisListenAddress + const RedisNodes + const RedisProtectedMode + const RedisServerPassword + const RedisServerPort + const RedisServerPortWebui + const RedisServers + const RedisSslCertfile + const RedisSslEnable + const RedisSslKeyfile + const RndcKey + const SampleDestination + const SandeshCaCertfile + const SandeshCertfile + const SandeshKeyfile + const SandeshSslEnable + const SelfsignedCertsWithIps + const ServerCaCertfile + const ServerCaKeyfile + const ServerCertfile + const ServerKeyfile + const SloDestination + const SnmpcollectorIntrospectPort + const SslEnable + const SslInsecure + const Subcluster + const TopologyIntrospectPort + const TorAgentOvsKa + const TorOvsProtocol + const TorType + const ToragentSslCacertfile + const ToragentSslCertfile + const ToragentSslKeyfile + const TsnEvpnMode + const TsnNodes + const UseExternalTftp + const VcenterFabricManagerNodes + const VrouterComputeNodeAddress + const VrouterCryptInterface + const VrouterDecryptInterface + const VrouterDecryptKey + const VrouterModuleOptions + const WebuiHttpListenPort + const WebuiHttpsListenPort + const WebuiJobServerPort + const WebuiNodes + const WebuiSslCertFile + const WebuiSslCiphers + const WebuiSslKeyFile + const WebuiStaticAuthPassword + const WebuiStaticAuthRole + const WebuiStaticAuthUser + const XmppServerCaCertfile + const XmppServerCertfile + const XmppServerKeyfile + const XmppServerPort + const XmppSslEnable + const ZookeeperElectionPort + const ZookeeperNodes + const ZookeeperPort + const ZookeeperPorts + const ZookeeperServerPort + const ZookeeperServers + const ZookeeperServersSpaceDelim + var SchemeBuilder = &scheme.Builder + var SchemeGroupVersion = schema.GroupVersion + func AddSecretVolumesToIntendedDS(ds *appsv1.DaemonSet, volumeSecretMap map[string]string) + func AddSecretVolumesToIntendedSTS(sts *appsv1.StatefulSet, volumeSecretMap map[string]string) + func AddVolumesToIntendedDeployments(intendedDeployment *appsv1.Deployment, volumeConfigMapMap map[string]string) + func AddVolumesToIntendedSTS(sts *appsv1.StatefulSet, volumeConfigMapMap map[string]string) + func CompareIntendedWithCurrentDeployment(intendedDeployment *appsv1.Deployment, ...) error + func CreateAccount(accountName string, namespace string, client client.Client, ...) error + func CreateConfigMap(configMapName string, client client.Client, scheme *runtime.Scheme, ...) (*corev1.ConfigMap, error) + func CreateSTS(sts *appsv1.StatefulSet, commonConfiguration *CommonConfiguration, ...) error + func CreateSecret(secretName string, client client.Client, scheme *runtime.Scheme, ...) (*corev1.Secret, error) + func CurrentConfigMapExists(configMapName string, client client.Client, scheme *runtime.Scheme, ...) (corev1.ConfigMap, bool) + func ExecToPodThroughAPI(command []string, containerName, podName, namespace string, stdin io.Reader) (string, string, error) + func GetClientConfig() (*rest.Config, error) + func GetClientset() (*kubernetes.Clientset, error) + func GetClientsetFromConfig(config *rest.Config) (*kubernetes.Clientset, error) + func GetConfig() (*rest.Config, error) + func GetOpenAPIDefinitions(ref common.ReferenceCallback) map[string]common.OpenAPIDefinition + func GetRESTClient() (*rest.RESTClient, error) + func PodIPListAndIPMapFromInstance(instanceType string, commonConfiguration *CommonConfiguration, ...) (*corev1.PodList, map[string]string, error) + func PrepareIntendedDeployment(instanceDeployment *appsv1.Deployment, ...) (*appsv1.Deployment, error) + func PrepareSTS(sts *appsv1.StatefulSet, commonConfiguration *CommonConfiguration, ...) error + func RandomString(size int) string + func SetDSCommonConfiguration(ds *appsv1.DaemonSet, commonConfiguration *CommonConfiguration) + func SetDeploymentCommonConfiguration(deployment *appsv1.Deployment, commonConfiguration *CommonConfiguration) *appsv1.Deployment + func SetInstanceActive(client client.Client, activeStatus *bool, sts *appsv1.StatefulSet, ...) error + func SetPodsToReady(podList *corev1.PodList, client client.Client) error + func SetSTSCommonConfiguration(sts *appsv1.StatefulSet, commonConfiguration *CommonConfiguration) + func StatusMonitorConfig(hostname string, configNodeList []string, podIP string, nodeType string, ...) (string, error) + func UpdateSTS(sts *appsv1.StatefulSet, commonConfiguration *CommonConfiguration, ...) error + type AAAMode string + const AAAModeNoAuth + const AAAModeRBAC + type APIServer struct + APIPort string + APIServerList []string + Encryption Encryption + func (in *APIServer) DeepCopy() *APIServer + func (in *APIServer) DeepCopyInto(out *APIServer) + type ActiveStatus struct + Active *bool + func (in *ActiveStatus) DeepCopy() *ActiveStatus + func (in *ActiveStatus) DeepCopyInto(out *ActiveStatus) + type AnalyticsNode struct + Hostname string + IPAddress string + func (in *AnalyticsNode) DeepCopy() *AnalyticsNode + func (in *AnalyticsNode) DeepCopyInto(out *AnalyticsNode) + type AuthenticationMode string + const AuthenticationModeKeystone + const AuthenticationModeNoAuth + type BGPPeer struct + Number string + Up string + func (in *BGPPeer) DeepCopy() *BGPPeer + func (in *BGPPeer) DeepCopyInto(out *BGPPeer) + type Cassandra struct + Spec CassandraSpec + Status CassandraStatus + func (c *Cassandra) AddSecretVolumesToIntendedSTS(sts *appsv1.StatefulSet, volumeConfigMapMap map[string]string) + func (c *Cassandra) AddVolumesToIntendedSTS(sts *appsv1.StatefulSet, volumeConfigMapMap map[string]string) + func (c *Cassandra) ConfigurationParameters() interface{} + func (c *Cassandra) CreateConfigMap(configMapName string, client client.Client, scheme *runtime.Scheme, ...) (*corev1.ConfigMap, error) + func (c *Cassandra) CreateSTS(sts *appsv1.StatefulSet, commonConfiguration *CommonConfiguration, ...) error + func (c *Cassandra) CreateSecret(secretName string, client client.Client, scheme *runtime.Scheme, ...) (*corev1.Secret, error) + func (c *Cassandra) InstanceConfiguration(request reconcile.Request, podList *corev1.PodList, client client.Client) error + func (c *Cassandra) IsActive(name string, namespace string, client client.Client) bool + func (c *Cassandra) IsUpgrading(name string, namespace string, client client.Client) bool + func (c *Cassandra) ManageNodeStatus(podNameIPMap map[string]string, client client.Client) error + func (c *Cassandra) OwnedByManager(client client.Client, request reconcile.Request) (*Manager, error) + func (c *Cassandra) PodIPListAndIPMapFromInstance(instanceType string, request reconcile.Request, reconcileClient client.Client) (*corev1.PodList, map[string]string, error) + func (c *Cassandra) PrepareSTS(sts *appsv1.StatefulSet, commonConfiguration *CommonConfiguration, ...) error + func (c *Cassandra) SetInstanceActive(client client.Client, activeStatus *bool, sts *appsv1.StatefulSet, ...) error + func (c *Cassandra) SetPodsToReady(podIPList *corev1.PodList, client client.Client) error + func (c *Cassandra) UpdateSTS(sts *appsv1.StatefulSet, commonConfiguration *CommonConfiguration, ...) error + func (in *Cassandra) DeepCopy() *Cassandra + func (in *Cassandra) DeepCopyInto(out *Cassandra) + func (in *Cassandra) DeepCopyObject() runtime.Object + type CassandraClusterConfiguration struct + CQLPort string + JMXPort string + Port string + ServerListCQLCommaSeparated string + ServerListCQLSpaceSeparated string + ServerListCommaSeparated string + ServerListCommanSeparatedQuoted string + ServerListJMXCommaSeparated string + ServerListJMXSpaceSeparated string + ServerListSpaceSeparated string + func NewCassandraClusterConfiguration(name string, namespace string, client client.Client) (*CassandraClusterConfiguration, error) + func (in *CassandraClusterConfiguration) DeepCopy() *CassandraClusterConfiguration + func (in *CassandraClusterConfiguration) DeepCopyInto(out *CassandraClusterConfiguration) + type CassandraConfiguration struct + ClusterName string + Containers map[string]*Container + CqlPort *int + JmxLocalPort *int + ListenAddress string + MaxHeapSize string + MinHeapSize string + Port *int + SslStoragePort *int + StartRPC *bool + Storage Storage + StoragePort *int + func (in *CassandraConfiguration) DeepCopy() *CassandraConfiguration + func (in *CassandraConfiguration) DeepCopyInto(out *CassandraConfiguration) + type CassandraList struct + Items []Cassandra + func (in *CassandraList) DeepCopy() *CassandraList + func (in *CassandraList) DeepCopyInto(out *CassandraList) + func (in *CassandraList) DeepCopyObject() runtime.Object + type CassandraSpec struct + CommonConfiguration CommonConfiguration + ServiceConfiguration CassandraConfiguration + func (in *CassandraSpec) DeepCopy() *CassandraSpec + func (in *CassandraSpec) DeepCopyInto(out *CassandraSpec) + type CassandraStatus struct + Active *bool + Nodes map[string]string + Ports CassandraStatusPorts + func (in *CassandraStatus) DeepCopy() *CassandraStatus + func (in *CassandraStatus) DeepCopyInto(out *CassandraStatus) + type CassandraStatusPorts struct + CqlPort string + JmxPort string + Port string + func (in *CassandraStatusPorts) DeepCopy() *CassandraStatusPorts + func (in *CassandraStatusPorts) DeepCopyInto(out *CassandraStatusPorts) + type Command struct + Spec CommandSpec + Status CommandStatus + func (c *Command) PrepareIntendedDeployment(instanceDeployment *appsv1.Deployment, ...) (*appsv1.Deployment, error) + func (in *Command) DeepCopy() *Command + func (in *Command) DeepCopyInto(out *Command) + func (in *Command) DeepCopyObject() runtime.Object + type CommandClusterConfiguration struct + AdminPassword string + AdminUsername string + func (in *CommandClusterConfiguration) DeepCopy() *CommandClusterConfiguration + func (in *CommandClusterConfiguration) DeepCopyInto(out *CommandClusterConfiguration) + type CommandConfiguration struct + ClusterName string + ConfigAPIURL string + Containers map[string]*Container + KeystoneInstance string + KeystoneSecretName string + PostgresInstance string + SwiftInstance string + TelemetryURL string + func (in *CommandConfiguration) DeepCopy() *CommandConfiguration + func (in *CommandConfiguration) DeepCopyInto(out *CommandConfiguration) + type CommandList struct + Items []Command + func (in *CommandList) DeepCopy() *CommandList + func (in *CommandList) DeepCopyInto(out *CommandList) + func (in *CommandList) DeepCopyObject() runtime.Object + type CommandSpec struct + CommonConfiguration CommonConfiguration + ServiceConfiguration CommandConfiguration + func (in *CommandSpec) DeepCopy() *CommandSpec + func (in *CommandSpec) DeepCopyInto(out *CommandSpec) + type CommandStatus struct + Active bool + IPs []string + func (in *CommandStatus) DeepCopy() *CommandStatus + func (in *CommandStatus) DeepCopyInto(out *CommandStatus) + type CommonConfiguration struct + Activate *bool + Create *bool + HostNetwork *bool + ImagePullSecrets []string + NodeSelector map[string]string + Replicas *int32 + Tolerations []corev1.Toleration + func (in *CommonConfiguration) DeepCopy() *CommonConfiguration + func (in *CommonConfiguration) DeepCopyInto(out *CommonConfiguration) + type ConditionStatus string + const ConditionFalse + const ConditionTrue + type Config struct + Spec ConfigSpec + Status ConfigStatus + func (c *Config) AddSecretVolumesToIntendedSTS(sts *appsv1.StatefulSet, volumeConfigMapMap map[string]string) + func (c *Config) AddVolumesToIntendedSTS(sts *appsv1.StatefulSet, volumeConfigMapMap map[string]string) + func (c *Config) AuthParameters(client client.Client) (*ConfigAuthParameters, error) + func (c *Config) ConfigurationParameters() interface{} + func (c *Config) CreateConfigMap(configMapName string, client client.Client, scheme *runtime.Scheme, ...) (*corev1.ConfigMap, error) + func (c *Config) CreateSTS(sts *appsv1.StatefulSet, commonConfiguration *CommonConfiguration, ...) error + func (c *Config) CreateSecret(secretName string, client client.Client, scheme *runtime.Scheme, ...) (*corev1.Secret, error) + func (c *Config) CurrentConfigMapExists(configMapName string, client client.Client, scheme *runtime.Scheme, ...) (corev1.ConfigMap, bool) + func (c *Config) InstanceConfiguration(request reconcile.Request, podList *corev1.PodList, client client.Client) error + func (c *Config) IsActive(name string, namespace string, myclient client.Client) bool + func (c *Config) ManageNodeStatus(podNameIPMap map[string]string, client client.Client) error + func (c *Config) OwnedByManager(client client.Client, request reconcile.Request) (*Manager, error) + func (c *Config) PodIPListAndIPMapFromInstance(request reconcile.Request, reconcileClient client.Client) (*corev1.PodList, map[string]string, error) + func (c *Config) PrepareSTS(sts *appsv1.StatefulSet, commonConfiguration *CommonConfiguration, ...) error + func (c *Config) SetInstanceActive(client client.Client, activeStatus *bool, sts *appsv1.StatefulSet, ...) error + func (c *Config) SetPodsToReady(podIPList *corev1.PodList, client client.Client) error + func (c *Config) UpdateSTS(sts *appsv1.StatefulSet, commonConfiguration *CommonConfiguration, ...) error + func (c *Config) WaitForPeerPods(request reconcile.Request, reconcileClient client.Client) error + func (in *Config) DeepCopy() *Config + func (in *Config) DeepCopyInto(out *Config) + func (in *Config) DeepCopyObject() runtime.Object + type ConfigAuthParameters struct + AdminPassword string + AdminUsername string + KeystoneIP string + KeystonePort int + func (in *ConfigAuthParameters) DeepCopy() *ConfigAuthParameters + func (in *ConfigAuthParameters) DeepCopyInto(out *ConfigAuthParameters) + type ConfigClusterConfiguration struct + APIServerListCommaSeparated string + APIServerListQuotedCommaSeparated string + APIServerListSpaceSeparated string + APIServerPort string + AnalyticsServerListQuotedCommaSeparated string + AnalyticsServerListSpaceSeparated string + AnalyticsServerPort string + AuthMode AuthenticationMode + CollectorPort string + CollectorServerListSpaceSeparated string + FirstAPIServer string + RedisPort string + func NewConfigClusterConfiguration(name string, namespace string, myclient client.Client) (*ConfigClusterConfiguration, error) + func (in *ConfigClusterConfiguration) DeepCopy() *ConfigClusterConfiguration + func (in *ConfigClusterConfiguration) DeepCopyInto(out *ConfigClusterConfiguration) + type ConfigConfiguration struct + AAAMode AAAMode + APIPort *int + AnalyticsPort *int + AuthMode AuthenticationMode + CassandraInstance string + CollectorPort *int + Containers map[string]*Container + FabricMgmtIP string + KeystoneInstance string + KeystoneSecretName string + LogLevel string + NodeManager *bool + RabbitmqPassword string + RabbitmqUser string + RabbitmqVhost string + RedisPort *int + Storage Storage + ZookeeperInstance string + func (in *ConfigConfiguration) DeepCopy() *ConfigConfiguration + func (in *ConfigConfiguration) DeepCopyInto(out *ConfigConfiguration) + type ConfigList struct + Items []Config + func (in *ConfigList) DeepCopy() *ConfigList + func (in *ConfigList) DeepCopyInto(out *ConfigList) + func (in *ConfigList) DeepCopyObject() runtime.Object + type ConfigNode struct + Hostname string + IPAddress string + func (in *ConfigNode) DeepCopy() *ConfigNode + func (in *ConfigNode) DeepCopyInto(out *ConfigNode) + type ConfigSpec struct + CommonConfiguration CommonConfiguration + ServiceConfiguration ConfigConfiguration + func (in *ConfigSpec) DeepCopy() *ConfigSpec + func (in *ConfigSpec) DeepCopyInto(out *ConfigSpec) + type ConfigStatus struct + Active *bool + ConfigChanged *bool + Nodes map[string]string + Ports ConfigStatusPorts + func (in *ConfigStatus) DeepCopy() *ConfigStatus + func (in *ConfigStatus) DeepCopyInto(out *ConfigStatus) + type ConfigStatusPorts struct + APIPort string + AnalyticsPort string + CollectorPort string + RedisPort string + func (in *ConfigStatusPorts) DeepCopy() *ConfigStatusPorts + func (in *ConfigStatusPorts) DeepCopyInto(out *ConfigStatusPorts) + type Connection struct + Name string + Nodes []string + Status string + Type string + func (in *Connection) DeepCopy() *Connection + func (in *Connection) DeepCopyInto(out *Connection) + type Container struct + Command []string + Image string + func (in *Container) DeepCopy() *Container + func (in *Container) DeepCopyInto(out *Container) + type Control struct + Spec ControlSpec + Status ControlStatus + func (c *Control) AddSecretVolumesToIntendedSTS(sts *appsv1.StatefulSet, volumeConfigMapMap map[string]string) + func (c *Control) AddVolumesToIntendedSTS(sts *appsv1.StatefulSet, volumeConfigMapMap map[string]string) + func (c *Control) ConfigurationParameters() interface{} + func (c *Control) CreateConfigMap(configMapName string, client client.Client, scheme *runtime.Scheme, ...) (*corev1.ConfigMap, error) + func (c *Control) CreateSTS(sts *appsv1.StatefulSet, commonConfiguration *CommonConfiguration, ...) error + func (c *Control) CreateSecret(secretName string, client client.Client, scheme *runtime.Scheme, ...) (*corev1.Secret, error) + func (c *Control) InstanceConfiguration(request reconcile.Request, podList *corev1.PodList, client client.Client) error + func (c *Control) IsActive(name string, namespace string, client client.Client) bool + func (c *Control) ManageNodeStatus(podNameIPMap map[string]string, client client.Client) error + func (c *Control) OwnedByManager(client client.Client, request reconcile.Request) (*Manager, error) + func (c *Control) PodIPListAndIPMapFromInstance(instanceType string, request reconcile.Request, reconcileClient client.Client) (*corev1.PodList, map[string]string, error) + func (c *Control) PrepareSTS(sts *appsv1.StatefulSet, commonConfiguration *CommonConfiguration, ...) error + func (c *Control) SetInstanceActive(client client.Client, activeStatus *bool, sts *appsv1.StatefulSet, ...) error + func (c *Control) SetPodsToReady(podIPList *corev1.PodList, client client.Client) error + func (c *Control) UpdateSTS(sts *appsv1.StatefulSet, commonConfiguration *CommonConfiguration, ...) error + func (in *Control) DeepCopy() *Control + func (in *Control) DeepCopyInto(out *Control) + func (in *Control) DeepCopyObject() runtime.Object + type ControlClusterConfiguration struct + BGPPort string + DNSIntrospectPort string + DNSPort string + ServerListCommanSeparatedQuoted string + ServerListDNSCommaSeparated string + ServerListDNSSpaceSeparated string + ServerListXMPPCommaSeparated string + ServerListXMPPSpaceSeparated string + func NewControlClusterConfiguration(name string, role string, namespace string, myclient client.Client) (*ControlClusterConfiguration, error) + func (in *ControlClusterConfiguration) DeepCopy() *ControlClusterConfiguration + func (in *ControlClusterConfiguration) DeepCopyInto(out *ControlClusterConfiguration) + type ControlConfiguration struct + ASNNumber *int + BGPPort *int + CassandraInstance string + Containers map[string]*Container + DNSIntrospectPort *int + DNSPort *int + NodeManager *bool + RabbitmqPassword string + RabbitmqUser string + RabbitmqVhost string + XMPPPort *int + ZookeeperInstance string + func (in *ControlConfiguration) DeepCopy() *ControlConfiguration + func (in *ControlConfiguration) DeepCopyInto(out *ControlConfiguration) + type ControlList struct + Items []Control + func (in *ControlList) DeepCopy() *ControlList + func (in *ControlList) DeepCopyInto(out *ControlList) + func (in *ControlList) DeepCopyObject() runtime.Object + type ControlNode struct + ASN int + Hostname string + IPAddress string + func (in *ControlNode) DeepCopy() *ControlNode + func (in *ControlNode) DeepCopyInto(out *ControlNode) + type ControlServiceStatus struct + BGPPeer BGPPeer + Connections []Connection + NumberOfRoutingInstances string + NumberOfXMPPPeers string + State string + StaticRoutes StaticRoutes + func (in *ControlServiceStatus) DeepCopy() *ControlServiceStatus + func (in *ControlServiceStatus) DeepCopyInto(out *ControlServiceStatus) + type ControlSpec struct + CommonConfiguration CommonConfiguration + ServiceConfiguration ControlConfiguration + func (in *ControlSpec) DeepCopy() *ControlSpec + func (in *ControlSpec) DeepCopyInto(out *ControlSpec) + type ControlStatus struct + Active *bool + Nodes map[string]string + Ports ControlStatusPorts + ServiceStatus map[string]ControlServiceStatus + func (in *ControlStatus) DeepCopy() *ControlStatus + func (in *ControlStatus) DeepCopyInto(out *ControlStatus) + type ControlStatusPorts struct + ASNNumber string + BGPPort string + DNSIntrospectPort string + DNSPort string + XMPPPort string + func (in *ControlStatusPorts) DeepCopy() *ControlStatusPorts + func (in *ControlStatusPorts) DeepCopyInto(out *ControlStatusPorts) + type CrdStatus struct + Active *bool + Name string + func (in *CrdStatus) DeepCopy() *CrdStatus + func (in *CrdStatus) DeepCopyInto(out *CrdStatus) + type DatabaseNode struct + Hostname string + IPAddress string + func (in *DatabaseNode) DeepCopy() *DatabaseNode + func (in *DatabaseNode) DeepCopyInto(out *DatabaseNode) + type Distribution string + const CENTOS + const RHEL + const UBUNTU + type Encryption struct + CA string + Cert string + Insecure bool + Key string + func (in *Encryption) DeepCopy() *Encryption + func (in *Encryption) DeepCopyInto(out *Encryption) + type Keystone struct + Spec KeystoneSpec + Status KeystoneStatus + func (in *Keystone) DeepCopy() *Keystone + func (in *Keystone) DeepCopyInto(out *Keystone) + func (in *Keystone) DeepCopyObject() runtime.Object + type KeystoneAuthParameters struct + AdminPassword string + AdminUsername string + AuthUrl string + Encryption Encryption + TenantName string + func (in *KeystoneAuthParameters) DeepCopy() *KeystoneAuthParameters + func (in *KeystoneAuthParameters) DeepCopyInto(out *KeystoneAuthParameters) + type KeystoneConfiguration struct + Containers map[string]*Container + KeystoneSecretName string + ListenPort int + MemcachedInstance string + PostgresInstance string + Storage Storage + func (in *KeystoneConfiguration) DeepCopy() *KeystoneConfiguration + func (in *KeystoneConfiguration) DeepCopyInto(out *KeystoneConfiguration) + type KeystoneList struct + Items []Keystone + func (in *KeystoneList) DeepCopy() *KeystoneList + func (in *KeystoneList) DeepCopyInto(out *KeystoneList) + func (in *KeystoneList) DeepCopyObject() runtime.Object + type KeystoneSpec struct + CommonConfiguration CommonConfiguration + ServiceConfiguration KeystoneConfiguration + func (in *KeystoneSpec) DeepCopy() *KeystoneSpec + func (in *KeystoneSpec) DeepCopyInto(out *KeystoneSpec) + type KeystoneStatus struct + Active bool + IPs []string + Port int + func (in *KeystoneStatus) DeepCopy() *KeystoneStatus + func (in *KeystoneStatus) DeepCopyInto(out *KeystoneStatus) + type Kubemanager struct + Spec KubemanagerSpec + Status KubemanagerStatus + func (c *Kubemanager) AddSecretVolumesToIntendedSTS(sts *appsv1.StatefulSet, volumeConfigMapMap map[string]string) + func (c *Kubemanager) AddVolumesToIntendedSTS(sts *appsv1.StatefulSet, volumeConfigMapMap map[string]string) + func (c *Kubemanager) ConfigurationParameters() interface{} + func (c *Kubemanager) CreateConfigMap(configMapName string, client client.Client, scheme *runtime.Scheme, ...) (*corev1.ConfigMap, error) + func (c *Kubemanager) CreateSTS(sts *appsv1.StatefulSet, commonConfiguration *CommonConfiguration, ...) error + func (c *Kubemanager) CreateSecret(secretName string, client client.Client, scheme *runtime.Scheme, ...) (*corev1.Secret, error) + func (c *Kubemanager) CurrentConfigMapExists(configMapName string, client client.Client, scheme *runtime.Scheme, ...) (corev1.ConfigMap, bool) + func (c *Kubemanager) InstanceConfiguration(request reconcile.Request, podList *corev1.PodList, client client.Client, ...) error + func (c *Kubemanager) IsActive(name string, namespace string, client client.Client) bool + func (c *Kubemanager) ManageNodeStatus(podNameIPMap map[string]string, client client.Client) error + func (c *Kubemanager) OwnedByManager(client client.Client, request reconcile.Request) (*Manager, error) + func (c *Kubemanager) PodIPListAndIPMapFromInstance(instanceType string, request reconcile.Request, reconcileClient client.Client) (*corev1.PodList, map[string]string, error) + func (c *Kubemanager) PrepareSTS(sts *appsv1.StatefulSet, commonConfiguration *CommonConfiguration, ...) error + func (c *Kubemanager) SetInstanceActive(client client.Client, activeStatus *bool, sts *appsv1.StatefulSet, ...) error + func (c *Kubemanager) SetPodsToReady(podIPList *corev1.PodList, client client.Client) error + func (c *Kubemanager) UpdateSTS(sts *appsv1.StatefulSet, commonConfiguration *CommonConfiguration, ...) error + func (in *Kubemanager) DeepCopy() *Kubemanager + func (in *Kubemanager) DeepCopyInto(out *Kubemanager) + func (in *Kubemanager) DeepCopyObject() runtime.Object + type KubemanagerClusterInfo interface + KubernetesAPISSLPort func() (int, error) + KubernetesAPIServer func() (string, error) + KubernetesClusterName func() (string, error) + PodSubnets func() (string, error) + ServiceSubnets func() (string, error) + type KubemanagerConfiguration struct + CassandraInstance string + CloudOrchestrator string + ClusterRole string + ClusterRoleBinding string + Containers map[string]*Container + HostNetworkService *bool + IPFabricForwarding *bool + IPFabricSnat *bool + IPFabricSubnets string + KubernetesAPIPort *int + KubernetesAPISSLPort *int + KubernetesAPIServer string + KubernetesClusterName string + KubernetesTokenFile string + PodSubnets string + RabbitmqPassword string + RabbitmqUser string + RabbitmqVhost string + ServiceAccount string + ServiceSubnets string + UseKubeadmConfig *bool + ZookeeperInstance string + func (in *KubemanagerConfiguration) DeepCopy() *KubemanagerConfiguration + func (in *KubemanagerConfiguration) DeepCopyInto(out *KubemanagerConfiguration) + type KubemanagerList struct + Items []Kubemanager + func (in *KubemanagerList) DeepCopy() *KubemanagerList + func (in *KubemanagerList) DeepCopyInto(out *KubemanagerList) + func (in *KubemanagerList) DeepCopyObject() runtime.Object + type KubemanagerSpec struct + CommonConfiguration CommonConfiguration + ServiceConfiguration KubemanagerConfiguration + func (in *KubemanagerSpec) DeepCopy() *KubemanagerSpec + func (in *KubemanagerSpec) DeepCopyInto(out *KubemanagerSpec) + type KubemanagerStatus struct + Active *bool + ConfigChanged *bool + Nodes map[string]string + func (in *KubemanagerStatus) DeepCopy() *KubemanagerStatus + func (in *KubemanagerStatus) DeepCopyInto(out *KubemanagerStatus) + type Manager struct + Spec ManagerSpec + Status ManagerStatus + func (in *Manager) DeepCopy() *Manager + func (in *Manager) DeepCopyInto(out *Manager) + func (in *Manager) DeepCopyObject() runtime.Object + func (m *Manager) Cassandra() *Cassandra + func (m *Manager) Create(client client.Client) error + func (m *Manager) Delete(client client.Client) error + func (m *Manager) Get(client client.Client, request reconcile.Request) error + func (m *Manager) GetObjectFromObjectList(objectList *[]*interface{}, request reconcile.Request) interface{} + func (m *Manager) Update(client client.Client) error + func (m Manager) IsClusterReady() bool + type ManagerCondition struct + Status ConditionStatus + Type ManagerConditionType + func (in *ManagerCondition) DeepCopy() *ManagerCondition + func (in *ManagerCondition) DeepCopyInto(out *ManagerCondition) + type ManagerConditionType string + const ManagerReady + type ManagerList struct + Items []Manager + func (in *ManagerList) DeepCopy() *ManagerList + func (in *ManagerList) DeepCopyInto(out *ManagerList) + func (in *ManagerList) DeepCopyObject() runtime.Object + type ManagerSpec struct + CommonConfiguration CommonConfiguration + KeystoneSecretName string + Services Services + func (in *ManagerSpec) DeepCopy() *ManagerSpec + func (in *ManagerSpec) DeepCopyInto(out *ManagerSpec) + type ManagerStatus struct + Cassandras []*ServiceStatus + Command *ServiceStatus + Conditions []ManagerCondition + Config *ServiceStatus + Controls []*ServiceStatus + CrdStatus []CrdStatus + Keystone *ServiceStatus + Kubemanagers []*ServiceStatus + Memcached *ServiceStatus + Postgres *ServiceStatus + ProvisionManager *ServiceStatus + Rabbitmq *ServiceStatus + Swift *ServiceStatus + Vrouters []*ServiceStatus + Webui *ServiceStatus + Zookeepers []*ServiceStatus + func (in *ManagerStatus) DeepCopy() *ManagerStatus + func (in *ManagerStatus) DeepCopyInto(out *ManagerStatus) + type Memcached struct + Spec MemcachedSpec + Status MemcachedStatus + func (in *Memcached) DeepCopy() *Memcached + func (in *Memcached) DeepCopyInto(out *Memcached) + func (in *Memcached) DeepCopyObject() runtime.Object + type MemcachedConfiguration struct + ConnectionLimit int32 + Container Container + ListenPort int32 + MaxMemory int32 + func (in *MemcachedConfiguration) DeepCopy() *MemcachedConfiguration + func (in *MemcachedConfiguration) DeepCopyInto(out *MemcachedConfiguration) + func (m *MemcachedConfiguration) GetConnectionLimit() int32 + func (m *MemcachedConfiguration) GetListenPort() int32 + func (m *MemcachedConfiguration) GetMaxMemory() int32 + type MemcachedList struct + Items []Memcached + func (in *MemcachedList) DeepCopy() *MemcachedList + func (in *MemcachedList) DeepCopyInto(out *MemcachedList) + func (in *MemcachedList) DeepCopyObject() runtime.Object + type MemcachedSpec struct + ServiceConfiguration MemcachedConfiguration + func (in *MemcachedSpec) DeepCopy() *MemcachedSpec + func (in *MemcachedSpec) DeepCopyInto(out *MemcachedSpec) + type MemcachedStatus struct + Active bool + Node string + func (in *MemcachedStatus) DeepCopy() *MemcachedStatus + func (in *MemcachedStatus) DeepCopyInto(out *MemcachedStatus) + type MonitorConfig struct + APIServerList []string + Encryption MonitorEncryption + Hostname string + InCluster *bool + Interval int64 + KubeConfigPath string + Namespace string + NodeName string + NodeType string + func (in *MonitorConfig) DeepCopy() *MonitorConfig + func (in *MonitorConfig) DeepCopyInto(out *MonitorConfig) + type MonitorEncryption struct + CA *string + Cert *string + Insecure bool + Key *string + func (in *MonitorEncryption) DeepCopy() *MonitorEncryption + func (in *MonitorEncryption) DeepCopyInto(out *MonitorEncryption) + type Postgres struct + Spec PostgresSpec + Status PostgresStatus + func (in *Postgres) DeepCopy() *Postgres + func (in *Postgres) DeepCopyInto(out *Postgres) + func (in *Postgres) DeepCopyObject() runtime.Object + type PostgresList struct + Items []Postgres + func (in *PostgresList) DeepCopy() *PostgresList + func (in *PostgresList) DeepCopyInto(out *PostgresList) + func (in *PostgresList) DeepCopyObject() runtime.Object + type PostgresSpec struct + Containers map[string]*Container + HostNetwork *bool + Storage Storage + func (in *PostgresSpec) DeepCopy() *PostgresSpec + func (in *PostgresSpec) DeepCopyInto(out *PostgresSpec) + type PostgresStatus struct + Active bool + Node string + func (in *PostgresStatus) DeepCopy() *PostgresStatus + func (in *PostgresStatus) DeepCopyInto(out *PostgresStatus) + type ProvisionManager struct + Spec ProvisionManagerSpec + Status ProvisionManagerStatus + func (c *ProvisionManager) AddSecretVolumesToIntendedSTS(sts *appsv1.StatefulSet, volumeConfigMapMap map[string]string) + func (c *ProvisionManager) AddVolumesToIntendedSTS(sts *appsv1.StatefulSet, volumeConfigMapMap map[string]string) + func (c *ProvisionManager) CreateConfigMap(configMapName string, client client.Client, scheme *runtime.Scheme, ...) (*corev1.ConfigMap, error) + func (c *ProvisionManager) CreateSTS(sts *appsv1.StatefulSet, commonConfiguration *CommonConfiguration, ...) error + func (c *ProvisionManager) CreateSecret(secretName string, client client.Client, scheme *runtime.Scheme, ...) (*corev1.Secret, error) + func (c *ProvisionManager) InstanceConfiguration(request reconcile.Request, podList *corev1.PodList, client client.Client) error + func (c *ProvisionManager) OwnedByManager(client client.Client, request reconcile.Request) (*Manager, error) + func (c *ProvisionManager) PodIPListAndIPMapFromInstance(request reconcile.Request, reconcileClient client.Client) (*corev1.PodList, map[string]string, error) + func (c *ProvisionManager) PrepareSTS(sts *appsv1.StatefulSet, commonConfiguration *CommonConfiguration, ...) error + func (c *ProvisionManager) SetInstanceActive(client client.Client, activeStatus *bool, sts *appsv1.StatefulSet, ...) error + func (c *ProvisionManager) SetPodsToReady(podIPList *corev1.PodList, client client.Client) error + func (c *ProvisionManager) UpdateSTS(sts *appsv1.StatefulSet, commonConfiguration *CommonConfiguration, ...) error + func (in *ProvisionManager) DeepCopy() *ProvisionManager + func (in *ProvisionManager) DeepCopyInto(out *ProvisionManager) + func (in *ProvisionManager) DeepCopyObject() runtime.Object + type ProvisionManagerConfiguration struct + Containers map[string]*Container + KeystoneInstance string + KeystoneSecretName string + func (in *ProvisionManagerConfiguration) DeepCopy() *ProvisionManagerConfiguration + func (in *ProvisionManagerConfiguration) DeepCopyInto(out *ProvisionManagerConfiguration) + type ProvisionManagerList struct + Items []ProvisionManager + func (in *ProvisionManagerList) DeepCopy() *ProvisionManagerList + func (in *ProvisionManagerList) DeepCopyInto(out *ProvisionManagerList) + func (in *ProvisionManagerList) DeepCopyObject() runtime.Object + type ProvisionManagerSpec struct + CommonConfiguration CommonConfiguration + ServiceConfiguration ProvisionManagerConfiguration + func (in *ProvisionManagerSpec) DeepCopy() *ProvisionManagerSpec + func (in *ProvisionManagerSpec) DeepCopyInto(out *ProvisionManagerSpec) + type ProvisionManagerStatus struct + Active *bool + GlobalConfiguration map[string]string + Nodes map[string]string + func (in *ProvisionManagerStatus) DeepCopy() *ProvisionManagerStatus + func (in *ProvisionManagerStatus) DeepCopyInto(out *ProvisionManagerStatus) + type Rabbitmq struct + Spec RabbitmqSpec + Status RabbitmqStatus + func (c *Rabbitmq) AddSecretVolumesToIntendedSTS(sts *appsv1.StatefulSet, volumeConfigMapMap map[string]string) + func (c *Rabbitmq) AddVolumesToIntendedSTS(sts *appsv1.StatefulSet, volumeConfigMapMap map[string]string) + func (c *Rabbitmq) ConfigurationParameters() interface{} + func (c *Rabbitmq) CreateConfigMap(configMapName string, client client.Client, scheme *runtime.Scheme, ...) (*corev1.ConfigMap, error) + func (c *Rabbitmq) CreateSTS(sts *appsv1.StatefulSet, commonConfiguration *CommonConfiguration, ...) error + func (c *Rabbitmq) CreateSecret(secretName string, client client.Client, scheme *runtime.Scheme, ...) (*corev1.Secret, error) + func (c *Rabbitmq) InstanceConfiguration(request reconcile.Request, podList *corev1.PodList, client client.Client) error + func (c *Rabbitmq) IsActive(name string, namespace string, myclient client.Client) bool + func (c *Rabbitmq) IsUpgrading(name string, namespace string, client client.Client) bool + func (c *Rabbitmq) ManageNodeStatus(podNameIPMap map[string]string, client client.Client) error + func (c *Rabbitmq) OwnedByManager(client client.Client, request reconcile.Request) (*Manager, error) + func (c *Rabbitmq) PodIPListAndIPMapFromInstance(instanceType string, request reconcile.Request, reconcileClient client.Client) (*corev1.PodList, map[string]string, error) + func (c *Rabbitmq) PrepareSTS(sts *appsv1.StatefulSet, commonConfiguration *CommonConfiguration, ...) error + func (c *Rabbitmq) SetInstanceActive(client client.Client, activeStatus *bool, sts *appsv1.StatefulSet, ...) error + func (c *Rabbitmq) SetPodsToReady(podIPList *corev1.PodList, client client.Client) error + func (c *Rabbitmq) UpdateSTS(sts *appsv1.StatefulSet, commonConfiguration *CommonConfiguration, ...) error + func (in *Rabbitmq) DeepCopy() *Rabbitmq + func (in *Rabbitmq) DeepCopyInto(out *Rabbitmq) + func (in *Rabbitmq) DeepCopyObject() runtime.Object + type RabbitmqClusterConfiguration struct + Port string + SSLPort string + Secret string + ServerListCommaSeparated string + ServerListCommaSeparatedSSL string + ServerListCommaSeparatedWithoutPort string + ServerListSpaceSeparated string + ServerListSpaceSeparatedSSL string + func NewRabbitmqClusterConfiguration(name string, namespace string, myclient client.Client) (*RabbitmqClusterConfiguration, error) + func (in *RabbitmqClusterConfiguration) DeepCopy() *RabbitmqClusterConfiguration + func (in *RabbitmqClusterConfiguration) DeepCopyInto(out *RabbitmqClusterConfiguration) + type RabbitmqConfiguration struct + Containers map[string]*Container + ErlangCookie string + Password string + Port *int + SSLPort *int + Secret string + User string + Vhost string + func (in *RabbitmqConfiguration) DeepCopy() *RabbitmqConfiguration + func (in *RabbitmqConfiguration) DeepCopyInto(out *RabbitmqConfiguration) + type RabbitmqList struct + Items []Rabbitmq + func (in *RabbitmqList) DeepCopy() *RabbitmqList + func (in *RabbitmqList) DeepCopyInto(out *RabbitmqList) + func (in *RabbitmqList) DeepCopyObject() runtime.Object + type RabbitmqSpec struct + CommonConfiguration CommonConfiguration + ServiceConfiguration RabbitmqConfiguration + func (in *RabbitmqSpec) DeepCopy() *RabbitmqSpec + func (in *RabbitmqSpec) DeepCopyInto(out *RabbitmqSpec) + type RabbitmqStatus struct + Active *bool + Nodes map[string]string + Ports RabbitmqStatusPorts + Secret string + func (in *RabbitmqStatus) DeepCopy() *RabbitmqStatus + func (in *RabbitmqStatus) DeepCopyInto(out *RabbitmqStatus) + type RabbitmqStatusPorts struct + Port string + SSLPort string + func (in *RabbitmqStatusPorts) DeepCopy() *RabbitmqStatusPorts + func (in *RabbitmqStatusPorts) DeepCopyInto(out *RabbitmqStatusPorts) + type ServiceInstance interface + Create func(client.Client) error + Delete func(client.Client) error + Get func(client.Client, reconcile.Request) error + Update func(client.Client) error + type ServiceStatus struct + Active *bool + Created *bool + Name *string + func (in *ServiceStatus) DeepCopy() *ServiceStatus + func (in *ServiceStatus) DeepCopyInto(out *ServiceStatus) + type Services struct + Cassandras []*Cassandra + Command *Command + Config *Config + Controls []*Control + Keystone *Keystone + Kubemanagers []*Kubemanager + Memcached *Memcached + Postgres *Postgres + ProvisionManager *ProvisionManager + Rabbitmq *Rabbitmq + Swift *Swift + Vrouters []*Vrouter + Webui *Webui + Zookeepers []*Zookeeper + func (in *Services) DeepCopy() *Services + func (in *Services) DeepCopyInto(out *Services) + type StaticRoutes struct + Down string + Number string + func (in *StaticRoutes) DeepCopy() *StaticRoutes + func (in *StaticRoutes) DeepCopyInto(out *StaticRoutes) + type Status struct + Active *bool + Nodes map[string]string + Ports map[string]string + func (in *Status) DeepCopy() *Status + func (in *Status) DeepCopyInto(out *Status) + type Storage struct + Path string + Size string + func (in *Storage) DeepCopy() *Storage + func (in *Storage) DeepCopyInto(out *Storage) + func (s Storage) SizeAsQuantity() (resource.Quantity, error) + type Swift struct + Spec SwiftSpec + Status SwiftStatus + func (in *Swift) DeepCopy() *Swift + func (in *Swift) DeepCopyInto(out *Swift) + func (in *Swift) DeepCopyObject() runtime.Object + type SwiftConfiguration struct + Containers map[string]*Container + CredentialsSecretName string + RingsStorage Storage + SwiftProxyConfiguration SwiftProxyConfiguration + SwiftStorageConfiguration SwiftStorageConfiguration + func (in *SwiftConfiguration) DeepCopy() *SwiftConfiguration + func (in *SwiftConfiguration) DeepCopyInto(out *SwiftConfiguration) + type SwiftList struct + Items []Swift + func (in *SwiftList) DeepCopy() *SwiftList + func (in *SwiftList) DeepCopyInto(out *SwiftList) + func (in *SwiftList) DeepCopyObject() runtime.Object + type SwiftProxy struct + Spec SwiftProxySpec + Status SwiftProxyStatus + func (in *SwiftProxy) DeepCopy() *SwiftProxy + func (in *SwiftProxy) DeepCopyInto(out *SwiftProxy) + func (in *SwiftProxy) DeepCopyObject() runtime.Object + type SwiftProxyConfiguration struct + Containers map[string]*Container + CredentialsSecretName string + Endpoint string + KeystoneInstance string + KeystoneSecretName string + ListenPort int + MemcachedInstance string + RingPersistentVolumeClaim string + SwiftConfSecretName string + func (in *SwiftProxyConfiguration) DeepCopy() *SwiftProxyConfiguration + func (in *SwiftProxyConfiguration) DeepCopyInto(out *SwiftProxyConfiguration) + type SwiftProxyList struct + Items []SwiftProxy + func (in *SwiftProxyList) DeepCopy() *SwiftProxyList + func (in *SwiftProxyList) DeepCopyInto(out *SwiftProxyList) + func (in *SwiftProxyList) DeepCopyObject() runtime.Object + type SwiftProxySpec struct + ServiceConfiguration SwiftProxyConfiguration + func (in *SwiftProxySpec) DeepCopy() *SwiftProxySpec + func (in *SwiftProxySpec) DeepCopyInto(out *SwiftProxySpec) + type SwiftProxyStatus struct + Active bool + func (in *SwiftProxyStatus) DeepCopy() *SwiftProxyStatus + func (in *SwiftProxyStatus) DeepCopyInto(out *SwiftProxyStatus) + type SwiftSpec struct + ServiceConfiguration SwiftConfiguration + func (in *SwiftSpec) DeepCopy() *SwiftSpec + func (in *SwiftSpec) DeepCopyInto(out *SwiftSpec) + type SwiftStatus struct + Active bool + CredentialsSecretName string + SwiftProxyPort int + func (in *SwiftStatus) DeepCopy() *SwiftStatus + func (in *SwiftStatus) DeepCopyInto(out *SwiftStatus) + type SwiftStorage struct + Spec SwiftStorageSpec + Status SwiftStorageStatus + func (in *SwiftStorage) DeepCopy() *SwiftStorage + func (in *SwiftStorage) DeepCopyInto(out *SwiftStorage) + func (in *SwiftStorage) DeepCopyObject() runtime.Object + type SwiftStorageConfiguration struct + AccountBindPort int + ContainerBindPort int + Containers map[string]*Container + Device string + ObjectBindPort int + RingPersistentVolumeClaim string + Storage Storage + SwiftConfSecretName string + func (in *SwiftStorageConfiguration) DeepCopy() *SwiftStorageConfiguration + func (in *SwiftStorageConfiguration) DeepCopyInto(out *SwiftStorageConfiguration) + type SwiftStorageList struct + Items []SwiftStorage + func (in *SwiftStorageList) DeepCopy() *SwiftStorageList + func (in *SwiftStorageList) DeepCopyInto(out *SwiftStorageList) + func (in *SwiftStorageList) DeepCopyObject() runtime.Object + type SwiftStorageSpec struct + ServiceConfiguration SwiftStorageConfiguration + func (in *SwiftStorageSpec) DeepCopy() *SwiftStorageSpec + func (in *SwiftStorageSpec) DeepCopyInto(out *SwiftStorageSpec) + type SwiftStorageStatus struct + Active bool + IPs []string + func (in *SwiftStorageStatus) DeepCopy() *SwiftStorageStatus + func (in *SwiftStorageStatus) DeepCopyInto(out *SwiftStorageStatus) + type Vrouter struct + Spec VrouterSpec + Status VrouterStatus + func (c *Vrouter) AddSecretVolumesToIntendedDS(ds *appsv1.DaemonSet, volumeConfigMapMap map[string]string) + func (c *Vrouter) AddVolumesToIntendedDS(ds *appsv1.DaemonSet, volumeConfigMapMap map[string]string) + func (c *Vrouter) ConfigurationParameters() interface{} + func (c *Vrouter) CreateConfigMap(configMapName string, client client.Client, scheme *runtime.Scheme, ...) (*corev1.ConfigMap, error) + func (c *Vrouter) CreateDS(ds *appsv1.DaemonSet, commonConfiguration *CommonConfiguration, ...) error + func (c *Vrouter) CreateSecret(secretName string, client client.Client, scheme *runtime.Scheme, ...) (*corev1.Secret, error) + func (c *Vrouter) InstanceConfiguration(request reconcile.Request, podList *corev1.PodList, client client.Client) error + func (c *Vrouter) ManageNodeStatus(podNameIPMap map[string]string, client client.Client) error + func (c *Vrouter) OwnedByManager(client client.Client, request reconcile.Request) (*Manager, error) + func (c *Vrouter) PodIPListAndIPMapFromInstance(instanceType string, request reconcile.Request, reconcileClient client.Client, ...) (*corev1.PodList, map[string]string, error) + func (c *Vrouter) PrepareDaemonSet(ds *appsv1.DaemonSet, commonConfiguration *CommonConfiguration, ...) error + func (c *Vrouter) SetInstanceActive(client client.Client, activeStatus *bool, ds *appsv1.DaemonSet, ...) error + func (c *Vrouter) SetPodsToReady(podIPList *corev1.PodList, client client.Client) error + func (c *Vrouter) UpdateDS(ds *appsv1.DaemonSet, commonConfiguration *CommonConfiguration, ...) error + func (in *Vrouter) DeepCopy() *Vrouter + func (in *Vrouter) DeepCopyInto(out *Vrouter) + func (in *Vrouter) DeepCopyObject() runtime.Object + type VrouterCNIDirectories struct + BinariesDirectory string + ConfigFilesDirectory string + func (in *VrouterCNIDirectories) DeepCopy() *VrouterCNIDirectories + func (in *VrouterCNIDirectories) DeepCopyInto(out *VrouterCNIDirectories) + type VrouterClusterConfiguration struct + Gateway string + MetaDataSecret string + PhysicalInterface string + func NewVrouterConfiguration(name string, namespace string, myclient client.Client) (*VrouterClusterConfiguration, error) + func (in *VrouterClusterConfiguration) DeepCopy() *VrouterClusterConfiguration + func (in *VrouterClusterConfiguration) DeepCopyInto(out *VrouterClusterConfiguration) + type VrouterConfiguration struct + CassandraInstance string + ClusterRole string + ClusterRoleBinding string + Containers map[string]*Container + ControlInstance string + Distribution *Distribution + Gateway string + MetaDataSecret string + NodeManager *bool + PhysicalInterface string + ServiceAccount string + func (in *VrouterConfiguration) DeepCopy() *VrouterConfiguration + func (in *VrouterConfiguration) DeepCopyInto(out *VrouterConfiguration) + type VrouterList struct + Items []Vrouter + func (in *VrouterList) DeepCopy() *VrouterList + func (in *VrouterList) DeepCopyInto(out *VrouterList) + func (in *VrouterList) DeepCopyObject() runtime.Object + type VrouterNode struct + Hostname string + IPAddress string + func (in *VrouterNode) DeepCopy() *VrouterNode + func (in *VrouterNode) DeepCopyInto(out *VrouterNode) + type VrouterSpec struct + CommonConfiguration CommonConfiguration + ServiceConfiguration VrouterConfiguration + func (in *VrouterSpec) DeepCopy() *VrouterSpec + func (in *VrouterSpec) DeepCopyInto(out *VrouterSpec) + type VrouterStatus struct + Active *bool + Nodes map[string]string + Ports ConfigStatusPorts + func (in *VrouterStatus) DeepCopy() *VrouterStatus + func (in *VrouterStatus) DeepCopyInto(out *VrouterStatus) + type WebUIClusterConfiguration struct + AdminPassword string + AdminUsername string + func (in *WebUIClusterConfiguration) DeepCopy() *WebUIClusterConfiguration + func (in *WebUIClusterConfiguration) DeepCopyInto(out *WebUIClusterConfiguration) + type Webui struct + Spec WebuiSpec + Status WebuiStatus + func (c *Webui) AddSecretVolumesToIntendedSTS(sts *appsv1.StatefulSet, volumeConfigMapMap map[string]string) + func (c *Webui) AddVolumesToIntendedSTS(sts *appsv1.StatefulSet, volumeConfigMapMap map[string]string) + func (c *Webui) ConfigurationParameters(client client.Client) (*WebUIClusterConfiguration, error) + func (c *Webui) CreateConfigMap(configMapName string, client client.Client, scheme *runtime.Scheme, ...) (*corev1.ConfigMap, error) + func (c *Webui) CreateSTS(sts *appsv1.StatefulSet, commonConfiguration *CommonConfiguration, ...) error + func (c *Webui) CreateSecret(secretName string, client client.Client, scheme *runtime.Scheme, ...) (*corev1.Secret, error) + func (c *Webui) InstanceConfiguration(request reconcile.Request, podList *corev1.PodList, client client.Client) error + func (c *Webui) IsActive(name string, namespace string, client client.Client) bool + func (c *Webui) ManageNodeStatus(podNameIPMap map[string]string, client client.Client) error + func (c *Webui) OwnedByManager(client client.Client, request reconcile.Request) (*Manager, error) + func (c *Webui) PodIPListAndIPMapFromInstance(instanceType string, request reconcile.Request, reconcileClient client.Client) (*corev1.PodList, map[string]string, error) + func (c *Webui) PrepareSTS(sts *appsv1.StatefulSet, commonConfiguration *CommonConfiguration, ...) error + func (c *Webui) SetInstanceActive(client client.Client, activeStatus *bool, sts *appsv1.StatefulSet, ...) error + func (c *Webui) SetPodsToReady(podIPList *corev1.PodList, client client.Client) error + func (c *Webui) UpdateSTS(sts *appsv1.StatefulSet, commonConfiguration *CommonConfiguration, ...) error + func (in *Webui) DeepCopy() *Webui + func (in *Webui) DeepCopyInto(out *Webui) + func (in *Webui) DeepCopyObject() runtime.Object + type WebuiConfiguration struct + CassandraInstance string + ClusterRole string + ClusterRoleBinding string + Containers map[string]*Container + KeystoneInstance string + KeystoneSecretName string + ServiceAccount string + func (in *WebuiConfiguration) DeepCopy() *WebuiConfiguration + func (in *WebuiConfiguration) DeepCopyInto(out *WebuiConfiguration) + type WebuiList struct + Items []Webui + func (in *WebuiList) DeepCopy() *WebuiList + func (in *WebuiList) DeepCopyInto(out *WebuiList) + func (in *WebuiList) DeepCopyObject() runtime.Object + type WebuiSpec struct + CommonConfiguration CommonConfiguration + ServiceConfiguration WebuiConfiguration + func (in *WebuiSpec) DeepCopy() *WebuiSpec + func (in *WebuiSpec) DeepCopyInto(out *WebuiSpec) + type WebuiStatus struct + Active *bool + Nodes map[string]string + func (in *WebuiStatus) DeepCopy() *WebuiStatus + func (in *WebuiStatus) DeepCopyInto(out *WebuiStatus) + type Zookeeper struct + Spec ZookeeperSpec + Status ZookeeperStatus + func (c *Zookeeper) AddSecretVolumesToIntendedSTS(sts *appsv1.StatefulSet, volumeConfigMapMap map[string]string) + func (c *Zookeeper) AddVolumesToIntendedSTS(sts *appsv1.StatefulSet, volumeConfigMapMap map[string]string) + func (c *Zookeeper) ConfigurationParameters() interface{} + func (c *Zookeeper) CreateConfigMap(configMapName string, client client.Client, scheme *runtime.Scheme, ...) (*corev1.ConfigMap, error) + func (c *Zookeeper) CreateSTS(sts *appsv1.StatefulSet, commonConfiguration *CommonConfiguration, ...) error + func (c *Zookeeper) InstanceConfiguration(request reconcile.Request, podList *corev1.PodList, client client.Client) error + func (c *Zookeeper) IsActive(name string, namespace string, client client.Client) bool + func (c *Zookeeper) IsUpgrading(name string, namespace string, client client.Client) bool + func (c *Zookeeper) ManageNodeStatus(podNameIPMap map[string]string, client client.Client) error + func (c *Zookeeper) OwnedByManager(client client.Client, request reconcile.Request) (*Manager, error) + func (c *Zookeeper) PodIPListAndIPMapFromInstance(instanceType string, request reconcile.Request, reconcileClient client.Client) (*corev1.PodList, map[string]string, error) + func (c *Zookeeper) PrepareSTS(sts *appsv1.StatefulSet, commonConfiguration *CommonConfiguration, ...) error + func (c *Zookeeper) SetInstanceActive(client client.Client, activeStatus *bool, sts *appsv1.StatefulSet, ...) error + func (c *Zookeeper) SetPodsToReady(podIPList *corev1.PodList, client client.Client) error + func (c *Zookeeper) UpdateSTS(sts *appsv1.StatefulSet, commonConfiguration *CommonConfiguration, ...) error + func (in *Zookeeper) DeepCopy() *Zookeeper + func (in *Zookeeper) DeepCopyInto(out *Zookeeper) + func (in *Zookeeper) DeepCopyObject() runtime.Object + type ZookeeperClusterConfiguration struct + ClientPort string + ElectionPort string + ServerListCommaSeparated string + ServerListSpaceSeparated string + ServerPort string + func NewZookeeperClusterConfiguration(name string, namespace string, client client.Client) (*ZookeeperClusterConfiguration, error) + func (in *ZookeeperClusterConfiguration) DeepCopy() *ZookeeperClusterConfiguration + func (in *ZookeeperClusterConfiguration) DeepCopyInto(out *ZookeeperClusterConfiguration) + type ZookeeperConfiguration struct + ClientPort *int + Containers map[string]*Container + ElectionPort *int + ServerPort *int + func (in *ZookeeperConfiguration) DeepCopy() *ZookeeperConfiguration + func (in *ZookeeperConfiguration) DeepCopyInto(out *ZookeeperConfiguration) + type ZookeeperList struct + Items []Zookeeper + func (in *ZookeeperList) DeepCopy() *ZookeeperList + func (in *ZookeeperList) DeepCopyInto(out *ZookeeperList) + func (in *ZookeeperList) DeepCopyObject() runtime.Object + type ZookeeperSpec struct + CommonConfiguration CommonConfiguration + ServiceConfiguration ZookeeperConfiguration + func (in *ZookeeperSpec) DeepCopy() *ZookeeperSpec + func (in *ZookeeperSpec) DeepCopyInto(out *ZookeeperSpec) + type ZookeeperStatus struct + Active *bool + Nodes map[string]string + Ports ZookeeperStatusPorts + func (in *ZookeeperStatus) DeepCopy() *ZookeeperStatus + func (in *ZookeeperStatus) DeepCopyInto(out *ZookeeperStatus) + type ZookeeperStatusPorts struct + ClientPort string + func (in *ZookeeperStatusPorts) DeepCopy() *ZookeeperStatusPorts + func (in *ZookeeperStatusPorts) DeepCopyInto(out *ZookeeperStatusPorts)