jupyt

Documentation

Index

• Constants
• Variables
• func HandleGetEndpoint(a api.HTTPAPI, w http.ResponseWriter, r *http.Request, params map[string]any)
• 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
• type ClusterInitializer
  • func (initializer *ClusterInitializer) ACONamespace() string
  • func (initializer *ClusterInitializer) InitializeCluster() error
• 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
  • 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 GetEndpointResult
  • func GetEndpoint(a *api.API, ctx context.Context, alias string) (result GetEndpointResult, err error)
• type Speclet
  • func (speclet *Speclet) CPUOrDefault() uint64
  • func (speclet *Speclet) MemoryOrDefault() uint64

Constants

const (
	DefaultCPU    = 2
	DefaultMemory = 8 * 1024 * 1024 * 1024
)

const (
	JupytPort = 27042
)

Variables

var AllCommands = []api.CmdDescriptor{
	GetEndpointCmdDescriptor,
}

var GetEndpointCmdDescriptor = api.CmdDescriptor{
	Name:        "get_endpoint",
	Parameters:  []api.CmdParameter{api.AliasParameter.AsExplicit()},
	Description: "get endpoint of JupYT strawberry operation",
	Handler:     HandleGetEndpoint,
}

Functions

func HandleGetEndpoint

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

func NewClusterInitializer

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

func NewController

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

Types

type ClusterInitializer

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

func (*ClusterInitializer) ACONamespace

func (initializer *ClusterInitializer) ACONamespace() string

func (*ClusterInitializer) InitializeCluster

func (initializer *ClusterInitializer) InitializeCluster() error

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

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 GetEndpointResult

type GetEndpointResult struct {
	Address     string         `yson:"address"`
	OperationID yt.OperationID `yson:"operation_id"`
	JobID       yt.JobID       `yson:"job_id"`
}

func GetEndpoint

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

type Speclet

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

	JupyterDockerImage string `yson:"jupyter_docker_image"`
}

func (*Speclet) CPUOrDefault

func (speclet *Speclet) CPUOrDefault() uint64

func (*Speclet) MemoryOrDefault

func (speclet *Speclet) MemoryOrDefault() uint64