Versions in this module Expand all Collapse all v0 v0.0.12 Jun 21, 2024 Changes in this version + const DefaultDriverCPU + const DefaultDriverMemory + const DefaultMaxSessions + const DefaultSparkVersion + const LivyPort + func NewClusterInitializer(l log.Logger, ytc yt.Client, root ypath.Path) strawberry.ClusterInitializer + func NewController(l log.Logger, ytc yt.Client, root ypath.Path, cluster string, ...) strawberry.Controller + func VersionType(version string) string + type ClusterInitializer struct + func (initializer *ClusterInitializer) ACONamespace() string + func (initializer *ClusterInitializer) InitializeCluster() error + type Config struct + type Controller struct + func (c *Controller) DescribeOptions(parsedSpeclet any) []strawberry.OptionGroupDescriptor + func (c *Controller) Family() string + func (c *Controller) GetOpBriefAttributes(parsedSpeclet any) map[string]any + func (c *Controller) GetSparkDistrib(ctx context.Context, speclet *Speclet) (name string, path string, err error) + func (c *Controller) ParseGlobalConf(ctx context.Context) (conf SparkGlobalConf, err error) + func (c *Controller) ParseSpeclet(specletYson yson.RawValue) (any, error) + func (c *Controller) ParseVersionConf(ctx context.Context, speclet *Speclet) (conf SparkLaunchConf, err error) + func (c *Controller) Prepare(ctx context.Context, oplet *strawberry.Oplet) (spec map[string]any, description map[string]any, annotations map[string]any, ...) + func (c *Controller) Root() ypath.Path + func (c *Controller) UpdateState() (changed bool, err error) + type SparkGlobalConf struct + Environment map[string]string + type SparkLaunchConf struct + FilePaths []string + LayerPaths []string + SparkConf map[string]string + type Speclet struct + DriverCPU *uint64 + DriverMemory *uint64 + MasterGroupID *string + MaxSessions *uint64 + SparkMasterAddress *string + SparkVersion *string + Version *string + func (speclet *Speclet) DriverCPUOrDefault() uint64 + func (speclet *Speclet) DriverMemoryOrDefault() uint64 + func (speclet *Speclet) MaxSessionsOrDefault() uint64 + func (speclet *Speclet) SparkVersionOrDefault() string
Go to main page