k8s

package

Go to main page

Versions in this module

v0

v0.7.4

Aug 18, 2016

v0.7.3

Aug 18, 2016

v0.7.2

Aug 18, 2016

v0.7.1

Jun 15, 2016

Changes in this version

type K8Fabricator

+ func (k *K8Fabricator) DeleteAllPersistentVolumeClaims(creds K8sClusterCredential) error

+ func (k *K8Fabricator) GetAllPersistentVolumes(creds K8sClusterCredential) ([]api.PersistentVolume, error)

type KubernetesApi

+ DeleteAllPersistentVolumeClaims func(creds K8sClusterCredential) error

+ GetAllPersistentVolumes func(creds K8sClusterCredential) ([]api.PersistentVolume, error)

v0.7.0

Jun 7, 2016

Changes in this version

+ func GetConsulServiceName(port api.ServicePort, service api.Service) string

+ func GetServiceExternalAddress(domain string, port api.ServicePort) string

+ func GetServiceInternalHost(port api.ServicePort, service api.Service) string

+ func GetServiceInternalHostByFirstTCPPort(service api.Service) string

+ type ContainerSimple struct

+ Envs map[string]string

+ Name string

+ type FabricateResult struct

+ Env map[string]string

+ Url string

+ type K8Fabricator struct

+ ConsulApi consul.ConsulService

+ Domain string

+ KubernetesClient KubernetesClientCreator

+ func NewK8Fabricator(domain string) *K8Fabricator

+ func (k *K8Fabricator) CheckKubernetesServiceHealthByServiceInstanceId(creds K8sClusterCredential, space, instance_id string) (bool, error)

+ func (k *K8Fabricator) CreateSecret(creds K8sClusterCredential, secret api.Secret) error

+ func (k *K8Fabricator) DeleteAllByServiceId(creds K8sClusterCredential, space, service_id string) error

+ func (k *K8Fabricator) DeleteAllPersistentVolumes(creds K8sClusterCredential) error

+ func (k *K8Fabricator) DeleteSecret(creds K8sClusterCredential, key string) error

+ func (k *K8Fabricator) FabricateService(creds K8sClusterCredential, space, cf_service_id, parameters string, ...) (FabricateResult, error)

+ func (k *K8Fabricator) GetAllPodsEnvsByServiceId(creds K8sClusterCredential, space, service_id string) ([]PodEnvs, error)

+ func (k *K8Fabricator) GetClusterWorkers(creds K8sClusterCredential) ([]string, error)

+ func (k *K8Fabricator) GetPodsStateByServiceId(creds K8sClusterCredential, service_id string) ([]PodStatus, error)

+ func (k *K8Fabricator) GetPodsStateForAllServices(creds K8sClusterCredential) (map[string][]PodStatus, error)

+ func (k *K8Fabricator) GetQuota(creds K8sClusterCredential, space string) (*api.ResourceQuotaList, error)

+ func (k *K8Fabricator) GetSecret(creds K8sClusterCredential, key string) (*api.Secret, error)

+ func (k *K8Fabricator) GetServiceCredentials(creds K8sClusterCredential, space, service_id string) ([]ServiceCredential, error)

+ func (k *K8Fabricator) GetServiceVisibility(creds K8sClusterCredential, org, space, service_id string) ([]K8sServiceInfo, error)

+ func (k *K8Fabricator) GetServices(creds K8sClusterCredential, org string) ([]api.Service, error)

+ func (k *K8Fabricator) GetServicesVisibility(creds K8sClusterCredential, org, space string) ([]K8sServiceInfo, error)

+ func (k *K8Fabricator) ListReplicationControllers(creds K8sClusterCredential, space string) (*api.ReplicationControllerList, error)

+ func (k *K8Fabricator) SetServicePublicVisibilityByServiceId(creds K8sClusterCredential, org, space, service_id string, shouldBePublic bool) ([]K8sServiceInfo, error)

+ func (k *K8Fabricator) UpdateSecret(creds K8sClusterCredential, secret api.Secret) error

+ type K8sClusterCredential struct

+ CLusterName string

+ ConsulEndpoint string

+ Password string

+ Server string

+ Username string

+ type K8sCreatorConnector struct

+ ApiVersion string

+ Client *http.Client

+ KubernetesClient KubernetesClientCreator

+ OrgQuota int

+ Password string

+ Server string

+ Username string

+ func NewK8sCreatorConnector(server, user, pass string, maxOrgQuota int) *K8sCreatorConnector

+ func (k *K8sCreatorConnector) CreateSecretForPrivateTapRepo(creds K8sClusterCredential) error

+ func (k *K8sCreatorConnector) DeleteCluster(org string) error

+ func (k *K8sCreatorConnector) GetCluster(org string) (int, K8sClusterCredential, error)

+ func (k *K8sCreatorConnector) GetClusters() ([]K8sClusterCredential, error)

+ func (k *K8sCreatorConnector) GetOrCreateCluster(org string) (K8sClusterCredential, error)

+ func (k *K8sCreatorConnector) IsApiWorking(credential K8sClusterCredential) bool

+ func (k *K8sCreatorConnector) PostCluster(org string) (int, error)

+ type K8sCreatorRest interface

+ DeleteCluster func(org string) error

+ GetCluster func(org string) (int, K8sClusterCredential, error)

+ GetClusters func() ([]K8sClusterCredential, error)

+ GetOrCreateCluster func(org string) (K8sClusterCredential, error)

+ PostCluster func(org string) (int, error)

+ type K8sServiceInfo struct

+ Name string

+ Org string

+ ServiceId string

+ Space string

+ TapPublic bool

+ Uri []string

+ type KubernetesApi interface

+ CheckKubernetesServiceHealthByServiceInstanceId func(creds K8sClusterCredential, space, instance_id string) (bool, error)

+ CreateSecret func(creds K8sClusterCredential, secret api.Secret) error

+ DeleteAllByServiceId func(creds K8sClusterCredential, space, service_id string) error

+ DeleteAllPersistentVolumes func(creds K8sClusterCredential) error

+ DeleteSecret func(creds K8sClusterCredential, key string) error

+ FabricateService func(creds K8sClusterCredential, space, cf_service_id, parameters string, ...) (FabricateResult, error)

+ GetAllPodsEnvsByServiceId func(creds K8sClusterCredential, space, service_id string) ([]PodEnvs, error)

+ GetClusterWorkers func(creds K8sClusterCredential) ([]string, error)

+ GetPodsStateByServiceId func(creds K8sClusterCredential, service_id string) ([]PodStatus, error)

+ GetPodsStateForAllServices func(creds K8sClusterCredential) (map[string][]PodStatus, error)

+ GetQuota func(creds K8sClusterCredential, space string) (*api.ResourceQuotaList, error)

+ GetSecret func(creds K8sClusterCredential, key string) (*api.Secret, error)

+ GetServiceCredentials func(creds K8sClusterCredential, space, service_id string) ([]ServiceCredential, error)

+ GetServiceVisibility func(creds K8sClusterCredential, org, space, service_id string) ([]K8sServiceInfo, error)

+ GetServices func(creds K8sClusterCredential, org string) ([]api.Service, error)

+ GetServicesVisibility func(creds K8sClusterCredential, org, space string) ([]K8sServiceInfo, error)

+ ListReplicationControllers func(creds K8sClusterCredential, space string) (*api.ReplicationControllerList, error)

+ SetServicePublicVisibilityByServiceId func(creds K8sClusterCredential, org, space, service_id string, shouldBePublic bool) ([]K8sServiceInfo, error)

+ UpdateSecret func(creds K8sClusterCredential, secret api.Secret) error

+ type KubernetesClient interface

+ ComponentStatuses func() k8sClient.ComponentStatusInterface

+ ConfigMaps func(namespace string) k8sClient.ConfigMapsInterface

+ Endpoints func(namespace string) k8sClient.EndpointsInterface

+ Events func(namespace string) k8sClient.EventInterface

+ LimitRanges func(namespace string) k8sClient.LimitRangeInterface

+ Namespaces func() k8sClient.NamespaceInterface

+ Nodes func() k8sClient.NodeInterface

+ PersistentVolumeClaims func(namespace string) k8sClient.PersistentVolumeClaimInterface

+ PersistentVolumes func() k8sClient.PersistentVolumeInterface

+ PodTemplates func(namespace string) k8sClient.PodTemplateInterface

+ Pods func(namespace string) k8sClient.PodInterface

+ ReplicationControllers func(namespace string) k8sClient.ReplicationControllerInterface

+ ResourceQuotas func(namespace string) k8sClient.ResourceQuotaInterface

+ Secrets func(namespace string) k8sClient.SecretsInterface

+ ServiceAccounts func(namespace string) k8sClient.ServiceAccountsInterface

+ Services func(namespace string) k8sClient.ServiceInterface

+ type KubernetesClientCreator interface

+ GetNewClient func(creds K8sClusterCredential) (KubernetesClient, error)

+ type KubernetesRestCreator struct

+ func (k *KubernetesRestCreator) GetNewClient(creds K8sClusterCredential) (KubernetesClient, error)

+ type KubernetesTestAdvancedParams struct

+ Resource string

+ ResponceObjects []runtime.Object

+ Verb string

+ type KubernetesTestCreator struct

+ func (k *KubernetesTestCreator) GetNewClient(creds K8sClusterCredential) (KubernetesClient, error)

+ func (k *KubernetesTestCreator) LoadAdvancedResponses(params []KubernetesTestAdvancedParams)

+ func (k *KubernetesTestCreator) LoadSimpleResponsesWithSameAction(responeObjects ...runtime.Object)

+ type PodEnvs struct

+ Containers []ContainerSimple

+ RcName string

+ type PodStatus struct

+ PodName string

+ ServiceId string

+ Status api.PodPhase

+ StatusMessage string

+ type RcConnector struct

+ func NewReplicationControllerManager(client KubernetesClient) *RcConnector

+ func (r *RcConnector) Create(replicationController *api.ReplicationController) (*api.ReplicationController, error)

+ func (r *RcConnector) DeleteAll(selector labels.Selector) error

+ func (r *RcConnector) List(selector labels.Selector) (*api.ReplicationControllerList, error)

+ func (r *RcConnector) UpdateReplicasNumber(name string, count int) error

+ type ReplicationControllerManager interface

+ Create func(replicationController *api.ReplicationController) (*api.ReplicationController, error)

+ DeleteAll func(selector labels.Selector) error

+ List func(selector labels.Selector) (*api.ReplicationControllerList, error)

+ UpdateReplicasNumber func(name string, count int) error

+ type ServiceCredential struct

+ Host string

+ Name string

+ Ports []api.ServicePort

v0.7.0-rc1

Jun 7, 2016

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