spark

Documentation

Index

• Variables
• func IsDone(sparkApp *sparkop.SparkApplication) bool
• type Client
  • 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)

Variables

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

Functions

func IsDone

func IsDone(sparkApp *sparkop.SparkApplication) bool

Types

type Client

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

func New

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

func (*Client) Delete

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

func (*Client) List

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

func (*Client) ListByLabel

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

func (*Client) ListByLabels

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