jupyt

Documentation

Index

• Constants
• func NewController(l log.Logger, ytc yt.Client, root ypath.Path, cluster string, ...) strawberry.Controller
• type Config
• type Controller
  • func (c *Controller) DescribeOptions(parsedSpeclet any) []strawberry.OptionGroupDescriptor
  • func (c *Controller) Family() string
  • func (c *Controller) GetOpBriefAttributes(parsedSpeclet any) (map[string]any, error)
  • func (c *Controller) ParseSpeclet(specletYson yson.RawValue) (any, 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 Speclet
  • func (speclet *Speclet) CPUOrDefault() uint64
  • func (speclet *Speclet) MemoryOrDefault() uint64
  • func (speclet *Speclet) TrampolinePathOrDefault() string

Constants

const (
	VenvDirectory             = ypath.Path("//sys/bin/jupyter-venv")
	TrampolineBinaryDirectory = ypath.Path("//sys/bin/jupyter-trampoline")
)

const (
	DefaultCPU            = 2
	DefaultMemory         = 8 * 1024 * 1024 * 1024
	DefaultTrampolinePath = "jupyter-trampoline.sh"
)

Functions

func NewController

func NewController(l log.Logger, ytc yt.Client, root ypath.Path, cluster string, rawConfig yson.RawValue) strawberry.Controller

Types

type Config

type Config struct {
}

type Controller

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

func (*Controller) DescribeOptions

func (c *Controller) DescribeOptions(parsedSpeclet any) []strawberry.OptionGroupDescriptor

func (*Controller) Family

func (c *Controller) Family() string

func (*Controller) GetOpBriefAttributes

func (c *Controller) GetOpBriefAttributes(parsedSpeclet any) (map[string]any, error)

func (*Controller) ParseSpeclet

func (c *Controller) ParseSpeclet(specletYson yson.RawValue) (any, error)

func (*Controller) Prepare

func (c *Controller) Prepare(ctx context.Context, oplet *strawberry.Oplet) (
	spec map[string]any, description map[string]any, annotations map[string]any, err error)

func (*Controller) Root

func (c *Controller) Root() ypath.Path

func (*Controller) UpdateState

func (c *Controller) UpdateState() (changed bool, err error)

type Speclet

type Speclet struct {
	CPU    *uint64 `yson:"cpu"`
	Memory *uint64 `yson:"memory"`

	PythonVersion  string  `yson:"python_version"`
	TrampolinePath *string `yson:"trampoline_path"`
	VenvPath       *string `yson:"venv_path"`
}

func (*Speclet) CPUOrDefault

func (speclet *Speclet) CPUOrDefault() uint64

func (*Speclet) MemoryOrDefault

func (speclet *Speclet) MemoryOrDefault() uint64

func (*Speclet) TrampolinePathOrDefault

func (speclet *Speclet) TrampolinePathOrDefault() string