Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

client

package

Go to main page

Versions in this module

v0

v0.5.0

Apr 21, 2021

v0.4.0

Jan 27, 2021

Changes in this version

type Client

+ CertManager certmanagerpkg.Interface

+ ClusterMode bool

+ ClusterRole string

+ Reposure *reposureclient.Client

+ func (self *Client) CreateCertificate(certificate *certmanager.Certificate) (*certmanager.Certificate, error)

+ func (self *Client) CreateCertificateIssuer(issuer *certmanager.Issuer) (*certmanager.Issuer, error)

+ func (self *Client) CreateClusterRoleBinding(clusterRoleBinding *rbac.ClusterRoleBinding) (*rbac.ClusterRoleBinding, error)

+ func (self *Client) CreateCustomResourceDefinition(customResourceDefinition *apiextensions.CustomResourceDefinition) (*apiextensions.CustomResourceDefinition, error)

+ func (self *Client) CreateDeployment(deployment *apps.Deployment) (*apps.Deployment, error)

+ func (self *Client) CreateNamespace(namespace *core.Namespace) (*core.Namespace, error)

+ func (self *Client) CreatePod(pod *core.Pod) (*core.Pod, error)

+ func (self *Client) CreateRole(role *rbac.Role) (*rbac.Role, error)

+ func (self *Client) CreateRoleBinding(roleBinding *rbac.RoleBinding) (*rbac.RoleBinding, error)

+ func (self *Client) CreateServiceAccount(serviceAccount *core.ServiceAccount) (*core.ServiceAccount, error)

+ func (self *Client) CreateServiceDirect(namespace string, serviceName string, url urlpkg.URL, tlsSecretName string, ...) (*resources.Service, error)

+ func (self *Client) CreateServiceIndirect(namespace string, serviceName string, registryName string, imageName string, ...) (*resources.Service, error)

+ func (self *Client) DeleteDelegate(name string) error

+ func (self *Client) GetCertManager() error

+ func (self *Client) GetOperatorServiceAccount() (*core.ServiceAccount, error)

+ func (self *Client) GetRegistryServiceTemplateURL(registry *reposure.Registry, serviceTemplateName string) (string, error)

+ func (self *Client) GetRegistryURLForCSAR(registry *reposure.Registry, artifactName string) (string, error)

+ func (self *Client) GetSecret(namespace string, secretName string) (*core.Secret, error)

+ func (self *Client) GetSecretTLSCertPool(namespace string, secretName string, secretDataKey string) (*x509.CertPool, error)

+ func (self *Client) GetServiceClout(namespace string, serviceName string) (string, error)

+ func (self *Client) GetServiceRegistry(service *resources.Service) (*reposure.Registry, error)

+ func (self *Client) GetServiceTemplateURL(service *resources.Service) (string, error)

+ func (self *Client) GetSourceRegistryHost(registryHost string) (string, error)

+ func (self *Client) InstallOperator(site string, reposure bool, sourceRegistryHost string, wait bool) error

+ func (self *Client) Labels(appName string, component string, namespace string) map[string]string

+ func (self *Client) ListDelegates() ([]string, error)

+ func (self *Client) ListServicesForImageName(registryName string, imageName string, urlContext *urlpkg.Context) ([]string, error)

+ func (self *Client) RegistryImageNameForServiceTemplateName(serviceTemplateName string) string

+ func (self *Client) ServiceTemplateNameForRegistryImageName(artifactName string) (string, bool)

+ func (self *Client) SetDelegate(name string, kubeconfigPath string, context string, namespace string) error

+ func (self *Client) UninstallOperator(reposure bool, wait bool)

+ func (self *Client) UpdateServiceURLContext(service *resources.Service, urlContext *urlpkg.Context) error

+ func (self *Client) VolumeSource(size string) core.VolumeSource

+ func (self *Client) WaitForDeletion(name string, condition func() bool)

+ func (self *Client) WaitForDeployment(namespace string, appName string) (*apps.Deployment, error)

+ func (self *Client) WaitForPod(namespace string, appName string) (*core.Pod, error)

v0.3.0

Jun 24, 2020

Changes in this version

type Client

+ func (self *Client) CreateService(namespace string, serviceName string, url urlpkg.URL, ...) (*resources.Service, error)

+ func (self *Client) CreateServiceFromContent(namespace string, serviceName string, spooler *spoolerpkg.Client, ...) error

+ func (self *Client) CreateServiceFromTemplate(namespace string, serviceName string, serviceTemplateName string, ...) error

+ func (self *Client) CreateServiceFromURL(namespace string, serviceName string, url string, ...) error

+ func (self *Client) GetInventoryURL(imageName string, urlContext *urlpkg.Context) (*urlpkg.DockerURL, error)

+ func (self *Client) ListServicesForImage(imageName string, urlContext *urlpkg.Context) ([]string, error)

+ func (self *Client) UpdateServiceMode(service *resources.Service, mode string) (*resources.Service, error)

+ func (self *Client) UpdateServiceSpec(service *resources.Service) (*resources.Service, error)

+ func (self *Client) UpdateServiceStatus(service *resources.Service) (*resources.Service, error)

v0.2.0

May 23, 2020

v0.1.0

May 14, 2020

Changes in this version

+ func GetInventoryImageName(serviceTemplateName string) string

+ func ServiceTemplateNameFromInventoryImageName(imageName string) (string, bool)

+ type Client struct

+ APIExtensions apiextensionspkg.Interface

+ CachePath string

+ Cluster bool

+ Config *restpkg.Config

+ Context contextpkg.Context

+ InventoryImageName string

+ InventorySpoolerImageName string

+ Kubernetes kubernetespkg.Interface

+ Log *logging.Logger

+ ManagedBy string

+ NamePrefix string

+ Namespace string

+ OperatorImageName string

+ PartOf string

+ REST restpkg.Interface

+ SpoolPath string

+ Turandot turandotpkg.Interface

+ func NewClient(loggerName string, kubernetes kubernetespkg.Interface, ...) *Client

+ func (self *Client) DeleteService(serviceName string) error

+ func (self *Client) DeployServiceFromContent(serviceName string, spooler *spoolerpkg.Client, url urlpkg.URL, ...) error

+ func (self *Client) DeployServiceFromTemplate(serviceName string, serviceTemplateName string, inputs map[string]interface{}, ...) error

+ func (self *Client) DeployServiceFromURL(serviceName string, url string, inputs map[string]interface{}, ...) error

+ func (self *Client) Exec(podName string, stdin io.Reader, stdout io.Writer, command ...string) error

+ func (self *Client) GetInventoryServiceTemplateURL(serviceTemplateName string, urlContext *urlpkg.Context) (*urlpkg.DockerURL, error)

+ func (self *Client) GetService(serviceName string) (*resources.Service, error)

+ func (self *Client) Install(site string, registry string, wait bool) error

+ func (self *Client) ListServices() (*resources.ServiceList, error)

+ func (self *Client) Uninstall()

+ func (self *Client) WriteToContainer(podName string, reader io.Reader, targetPath string) error