spark

Jul 30, 2019

Changes in this version

+ func App(spec *Spec) *sparkop.SparkApplication

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

type Client

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

+ func (c *Client) Create(sparkApp *sparkop.SparkApplication) (*sparkop.SparkApplication, 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)

+ type Spec struct

+ Labels map[string]string

+ Name string

+ Namespace string

+ Spec sparkop.SparkApplicationSpec

Jun 14, 2019

Changes in this version

+ var FailureCondition = "status.applicationState.state in (" + strings.Join(failureStates, ",") + ")"

+ var SuccessCondition = "status.applicationState.state in (" + strings.Join(successStates, ",") + ")"

+ func IsDone(sparkApp *sparkop.SparkApplication) bool

+ type Client struct

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

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

+ func (c *Client) List(opts *metav1.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)