k8splugins

Documentation

Index

• Constants
• func ConvertPodFailureToError(status v1.PodStatus) error
• func GetLastTransitionOccurredAt(pod *v1.Pod) metaV1.Time
• type SparkConfig
  • func GetSparkConfig() *SparkConfig
• type WaitableConfig
  • func GetWaitableConfig() *WaitableConfig

Constants

const KindSparkApplication = "SparkApplication"

Functions

func ConvertPodFailureToError

func ConvertPodFailureToError(status v1.PodStatus) error

func GetLastTransitionOccurredAt

func GetLastTransitionOccurredAt(pod *v1.Pod) metaV1.Time

Types

type SparkConfig

type SparkConfig struct {
	DefaultSparkConfig    map[string]string `json:"spark-config-default" pflag:",Key value pairs of default spark configuration that should be applied to every SparkJob"`
	SparkHistoryServerURL string            `json:"spark-history-server-url" pflag:",URL for SparkHistory Server that each job will publish the execution history to."`
}

Spark-specific configs

func GetSparkConfig

func GetSparkConfig() *SparkConfig

type WaitableConfig

type WaitableConfig struct {
	// TODO: Reconsider this once we plug Console as a Log Provider plugin.
	ConsoleURI   config.URL `json:"console-uri" pflag:",URI for console. Used to expose links in the emitted events."`
	LruCacheSize int        `json:"lru-cache-size" pflag:",Size of the AutoRefreshCache"`
}

func GetWaitableConfig

func GetWaitableConfig() *WaitableConfig