delegate

Documentation

Index

• func GetInventoryImageName(serviceTemplateName string) string
• func ServiceTemplateNameFromInventoryImageName(imageName string) (string, bool)
• type Client
  • func NewClient(loggerName string, kubernetes kubernetespkg.Interface, ...) *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) DeleteService(namespace string, serviceName string) error
  • func (self *Client) Exec(namespace string, podName string, containerName string, stdin io.Reader, ...) error
  • func (self *Client) GetInventoryServiceTemplateURL(serviceTemplateName string, urlContext *urlpkg.Context) (*urlpkg.DockerURL, error)
  • func (self *Client) GetInventoryURL(imageName string, urlContext *urlpkg.Context) (*urlpkg.DockerURL, error)
  • func (self *Client) GetService(namespace string, 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) ListServicesForImage(imageName string, urlContext *urlpkg.Context) ([]string, error)
  • func (self *Client) Uninstall(wait bool)
  • 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)
  • func (self *Client) WriteToContainer(namespace string, podName string, containerName string, reader io.Reader, ...) error

Functions

func GetInventoryImageName

func GetInventoryImageName(serviceTemplateName string) string

func ServiceTemplateNameFromInventoryImageName

func ServiceTemplateNameFromInventoryImageName(imageName string) (string, bool)

Types

type Client

type Client struct {
	Kubernetes    kubernetespkg.Interface
	APIExtensions apiextensionspkg.Interface
	Turandot      turandotpkg.Interface
	REST          restpkg.Interface
	Config        *restpkg.Config

	Cluster                   bool
	Namespace                 string
	NamePrefix                string
	PartOf                    string
	ManagedBy                 string
	OperatorImageName         string
	InventoryImageName        string
	InventorySpoolerImageName string
	CachePath                 string
	SpoolPath                 string

	Context contextpkg.Context
	Log     *logging.Logger
}

func NewClient

func NewClient(loggerName string, kubernetes kubernetespkg.Interface, apiExtensions apiextensionspkg.Interface, turandot turandotpkg.Interface, rest restpkg.Interface, config *restpkg.Config, cluster bool, namespace string, namePrefix string, partOf string, managedBy string, operatorImageName string, inventoryImageName string, inventorySpoolerImageName string, cachePath string, spoolPath string) *Client

func (*Client) CreateService

func (self *Client) CreateService(namespace string, serviceName string, url urlpkg.URL, inputs map[string]interface{}, mode string) (*resources.Service, error)

func (*Client) CreateServiceFromContent

func (self *Client) CreateServiceFromContent(namespace string, serviceName string, spooler *spoolerpkg.Client, url urlpkg.URL, inputs map[string]interface{}, mode string, urlContext *urlpkg.Context) error

func (*Client) CreateServiceFromTemplate

func (self *Client) CreateServiceFromTemplate(namespace string, serviceName string, serviceTemplateName string, inputs map[string]interface{}, mode string, urlContext *urlpkg.Context) error

func (*Client) CreateServiceFromURL

func (self *Client) CreateServiceFromURL(namespace string, serviceName string, url string, inputs map[string]interface{}, mode string, urlContext *urlpkg.Context) error

func (*Client) DeleteService

func (self *Client) DeleteService(namespace string, serviceName string) error

func (*Client) Exec

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

func (*Client) GetInventoryServiceTemplateURL

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

func (*Client) GetInventoryURL

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

func (*Client) GetService

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

func (*Client) Install

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

func (*Client) ListServices

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

func (*Client) ListServicesForImage

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

func (*Client) Uninstall

func (self *Client) Uninstall(wait bool)

func (*Client) UpdateServiceMode

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

func (*Client) UpdateServiceSpec

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

func (*Client) UpdateServiceStatus

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

func (*Client) WriteToContainer

func (self *Client) WriteToContainer(namespace string, podName string, containerName string, reader io.Reader, targetPath string, permissions *int64) error