spark

Aug 20, 2019 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Aug 14, 2019 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Aug 9, 2019 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jul 30, 2019 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

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

Jul 8, 2019 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jun 27, 2019 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jun 17, 2019 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

Jun 14, 2019 GO-2024-3036

  GO-2024-3036: cortex establishes TLS connections with `InsecureSkipVerify` set to `true` in github.com/cortexproject/cortex

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)