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) 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

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) DeleteService

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

func (*Client) DeployServiceFromContent

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

func (*Client) DeployServiceFromTemplate

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

func (*Client) DeployServiceFromURL

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

func (*Client) Exec

func (self *Client) Exec(podName 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) GetService

func (self *Client) GetService(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) Uninstall

func (self *Client) Uninstall()

func (*Client) WriteToContainer

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