jupyt

Mar 11, 2024

Changes in this version

+ func NewClusterInitializer(l log.Logger, ytc yt.Client, root ypath.Path) strawberry.ClusterInitializer

+ type ClusterInitializer struct

+ func (initializer *ClusterInitializer) ACONamespace() string

+ func (initializer *ClusterInitializer) InitializeCluster() error

Feb 6, 2024

Changes in this version

+ const JupytPort

+ var AllCommands = []api.CmdDescriptor

+ var GetEndpointCmdDescriptor = api.CmdDescriptor

+ func HandleGetEndpoint(a api.HTTPAPI, w http.ResponseWriter, r *http.Request, params map[string]any)

+ type GetEndpointResult struct

+ Address string

+ JobID yt.JobID

+ OperationID yt.OperationID

+ func GetEndpoint(a *api.API, ctx context.Context, alias string) (result GetEndpointResult, err error)

type Speclet

+ JupyterDockerImage string

Aug 10, 2023

Changes in this version

+ const DefaultCPU

+ const DefaultMemory

+ const DefaultTrampolinePath

+ const TrampolineBinaryDirectory

+ const VenvDirectory

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

+ 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, 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 struct

+ CPU *uint64

+ Memory *uint64

+ PythonVersion string

+ TrampolinePath *string

+ VenvPath *string

+ func (speclet *Speclet) CPUOrDefault() uint64

+ func (speclet *Speclet) MemoryOrDefault() uint64

+ func (speclet *Speclet) TrampolinePathOrDefault() string