admin

Documentation

Index

• type Client
  • func NewClient(kubernetes kubernetespkg.Interface, apiExtensions apiextensionspkg.Interface, ...) *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) CreateRegistryDirect(namespace string, registryName string, host string, ...) (*resources.Registry, error)
  • func (self *Client) CreateRegistryIndirect(namespace string, registryName string, serviceNamespace string, ...) (*resources.Registry, error)
  • func (self *Client) CreateRegistrySurrogate(registry *resources.Registry) (*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) CreateService(service *core.Service) (*core.Service, error)
  • func (self *Client) CreateServiceAccount(serviceAccount *core.ServiceAccount) (*core.ServiceAccount, error)
  • func (self *Client) DeleteRegistry(namespace string, registryName string) error
  • func (self *Client) DirectClient(registry *resources.Registry) (*directclient.Client, error)
  • func (self *Client) GetCertManager() error
  • func (self *Client) GetOperatorServiceAccount() (*core.ServiceAccount, error)
  • func (self *Client) GetRegistry(namespace string, registryName string) (*resources.Registry, error)
  • func (self *Client) GetRegistrySurrogateAppName(registryName string) string
  • func (self *Client) GetSourceRegistryHost(registryHost string) (string, error)
  • func (self *Client) InstallOperator(sourceRegistryHost string, wait bool) error
  • func (self *Client) InstallSimple(sourceRegistryHost string, authentication bool, authorization bool, wait bool) error
  • func (self *Client) Labels(appName string, component string, namespace string) map[string]string
  • func (self *Client) ListRegistries() (*resources.RegistryList, error)
  • func (self *Client) RegistryClient() *registryclient.Client
  • func (self *Client) SimpleHost() (string, error)
  • func (self *Client) SimpleService() (*core.Service, error)
  • func (self *Client) SurrogateCommandClient(registry *resources.Registry) (*commandclient.Client, error)
  • func (self *Client) SurrogateSpoolerClient(registry *resources.Registry) *spoolerclient.Client
  • func (self *Client) UninstallOperator(wait bool)
  • func (self *Client) UninstallSimple(wait bool)
  • func (self *Client) UpdateRegistryStatus(registry *resources.Registry) (*resources.Registry, error)
  • func (self *Client) VolumeSource(size string) core.VolumeSource
  • func (self *Client) WaitForRegistrySurrogate(namespace string, registryName string) (*core.Pod, error)

Types

type Client

type Client struct {
	Kubernetes    kubernetespkg.Interface
	APIExtensions apiextensionspkg.Interface
	Reposure      reposurepkg.Interface
	REST          restpkg.Interface
	CertManager   certmanagerpkg.Interface
	Config        *restpkg.Config
	Context       contextpkg.Context

	ClusterMode             bool
	ClusterRole             string
	Namespace               string
	NamePrefix              string
	PartOf                  string
	ManagedBy               string
	OperatorImageReference  string
	SurrogateImageReference string
	SimpleImageReference    string

	LogName string
	Log     commonlog.Logger
}

func NewClient

func NewClient(kubernetes kubernetespkg.Interface, apiExtensions apiextensionspkg.Interface, reposure reposurepkg.Interface, rest restpkg.Interface, config *restpkg.Config, context contextpkg.Context, clusterMode bool, clusterRole string, namespace string, namePrefix string, partOf string, managedBy string, operatorImageReference string, surrogateImageReference string, simpleImageReference string, logName string) *Client

func (*Client) CreateCertificate

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

func (*Client) CreateCertificateIssuer

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

func (*Client) CreateClusterRoleBinding

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

func (*Client) CreateCustomResourceDefinition

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

func (*Client) CreateDeployment

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

func (*Client) CreateNamespace

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

func (*Client) CreatePod

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

func (*Client) CreateRegistryDirect

func (self *Client) CreateRegistryDirect(namespace string, registryName string, host string, authenticationSecretName string, authenticationSecretDataKey string, authorizationSecretName string) (*resources.Registry, error)

func (*Client) CreateRegistryIndirect

func (self *Client) CreateRegistryIndirect(namespace string, registryName string, serviceNamespace string, serviceName string, port uint64, authenticationSecretName string, authenticationSecretDataKey string, authorizationSecretName string) (*resources.Registry, error)

func (*Client) CreateRegistrySurrogate

func (self *Client) CreateRegistrySurrogate(registry *resources.Registry) (*core.Pod, error)

func (*Client) CreateRole

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

func (*Client) CreateRoleBinding

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

func (*Client) CreateService

func (self *Client) CreateService(service *core.Service) (*core.Service, error)

func (*Client) CreateServiceAccount

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

func (*Client) DeleteRegistry

func (self *Client) DeleteRegistry(namespace string, registryName string) error

func (*Client) DirectClient

func (self *Client) DirectClient(registry *resources.Registry) (*directclient.Client, error)

func (*Client) GetCertManager

func (self *Client) GetCertManager() error

func (*Client) GetOperatorServiceAccount

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

func (*Client) GetRegistry

func (self *Client) GetRegistry(namespace string, registryName string) (*resources.Registry, error)

func (*Client) GetRegistrySurrogateAppName

func (self *Client) GetRegistrySurrogateAppName(registryName string) string

func (*Client) GetSourceRegistryHost

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

func (*Client) InstallOperator

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

func (*Client) InstallSimple

func (self *Client) InstallSimple(sourceRegistryHost string, authentication bool, authorization bool, wait bool) error

func (*Client) Labels

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

func (*Client) ListRegistries

func (self *Client) ListRegistries() (*resources.RegistryList, error)

func (*Client) RegistryClient

func (self *Client) RegistryClient() *registryclient.Client

func (*Client) SimpleHost

func (self *Client) SimpleHost() (string, error)

func (*Client) SimpleService

func (self *Client) SimpleService() (*core.Service, error)

func (*Client) SurrogateCommandClient

func (self *Client) SurrogateCommandClient(registry *resources.Registry) (*commandclient.Client, error)

func (*Client) SurrogateSpoolerClient

func (self *Client) SurrogateSpoolerClient(registry *resources.Registry) *spoolerclient.Client

func (*Client) UninstallOperator

func (self *Client) UninstallOperator(wait bool)

func (*Client) UninstallSimple

func (self *Client) UninstallSimple(wait bool)

func (*Client) UpdateRegistryStatus

func (self *Client) UpdateRegistryStatus(registry *resources.Registry) (*resources.Registry, error)

func (*Client) VolumeSource

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

func (*Client) WaitForRegistrySurrogate

func (self *Client) WaitForRegistrySurrogate(namespace string, registryName string) (*core.Pod, error)