sparkapplication

Documentation

Overview

Package sparkapplication manipulates the k8s api of sparkapplication object

Index

• type Option
  • func WithCompleteParams(addr string, client *httpclient.HTTPClient) Option
• type SparkApplication
  • func New(options ...Option) *SparkApplication
  • func (s *SparkApplication) Create(app *sparkv1beta2.SparkApplication) error
  • func (s *SparkApplication) CreateOrUpdate(app *sparkv1beta2.SparkApplication) error
  • func (s *SparkApplication) Delete(namespace, name string) error
  • func (s *SparkApplication) DeleteIfExists(namespace, name string) error
  • func (s *SparkApplication) DeletePod(namespace, name string) error
  • func (s *SparkApplication) Get(namespace, name string) (*sparkv1beta2.SparkApplication, error)
  • func (s *SparkApplication) List(namespace string) (sparkv1beta2.SparkApplicationList, error)
  • func (s *SparkApplication) Update(app *sparkv1beta2.SparkApplication) error

Types

type Option

type Option func(*SparkApplication)

Option configures a SparkApplication

func WithCompleteParams

func WithCompleteParams(addr string, client *httpclient.HTTPClient) Option

WithCompleteParams provides an Option

type SparkApplication

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

SparkApplication is the object to manipulate k8s api of SparkApplication

func New

func New(options ...Option) *SparkApplication

New news a SparkApplication

func (*SparkApplication) Create

func (s *SparkApplication) Create(app *sparkv1beta2.SparkApplication) error

Create creates a k8s SparkApplication object

func (*SparkApplication) CreateOrUpdate

func (s *SparkApplication) CreateOrUpdate(app *sparkv1beta2.SparkApplication) error

CreateOrUpdate create or update a k8s SparkApplication object

func (*SparkApplication) Delete

func (s *SparkApplication) Delete(namespace, name string) error

Delete deletes a k8s SparkApplication

func (*SparkApplication) DeleteIfExists

func (s *SparkApplication) DeleteIfExists(namespace, name string) error

DeleteIfExists delete if k8s SparkApplication exists

func (*SparkApplication) DeletePod

func (s *SparkApplication) DeletePod(namespace, name string) error

DeletePod deletes the spark driver & executor pods by labelSelector

func (*SparkApplication) Get

func (s *SparkApplication) Get(namespace, name string) (*sparkv1beta2.SparkApplication, error)

Get gets a k8s SparkApplication object

func (*SparkApplication) List

func (s *SparkApplication) List(namespace string) (sparkv1beta2.SparkApplicationList, error)

List lists SparkApplication under specific namespace

func (*SparkApplication) Update

func (s *SparkApplication) Update(app *sparkv1beta2.SparkApplication) error

Update updates a k8s SparkApplication