spark

package

v0.7.1 Latest Latest Go to latest Published: Aug 9, 2019 License: Apache-2.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

func App(spec *Spec) *sparkop.SparkApplication

func Map(services []sparkop.SparkApplication) map[string]sparkop.SparkApplication

type Client struct {
	// contains filtered or unexported fields
}

func New(restConfig *kclientrest.Config, namespace string) (*Client, error)

func (c *Client) Apply(sparkApp *sparkop.SparkApplication) (*sparkop.SparkApplication, error)

func (c *Client) Create(sparkApp *sparkop.SparkApplication) (*sparkop.SparkApplication, error)

func (c *Client) Delete(appName string) (bool, error)

func (c *Client) Exists(name string) (bool, error)

func (c *Client) Get(name string) (*sparkop.SparkApplication, error)

func (c *Client) IsRunning(name string) (bool, error)

func (c *Client) List(opts *kmeta.ListOptions) ([]sparkop.SparkApplication, error)

func (c *Client) ListByLabel(labelKey string, labelValue string) ([]sparkop.SparkApplication, error)

func (c *Client) ListByLabels(labels map[string]string) ([]sparkop.SparkApplication, error)

type Spec struct {
	Name      string
	Namespace string
	Spec      sparkop.SparkApplicationSpec
	Labels    map[string]string
}