types

Documentation

Index

• Variables
• type CustomLogger
  • func (log CustomLogger) Debugf(format string, a ...interface{})
  • func (log *CustomLogger) Errorf(err error, format string, a ...interface{})
  • func (log CustomLogger) Infof(format string, a ...interface{})
  • func (log *CustomLogger) WithValues(keysAndValues ...interface{}) CustomLogger
• type DaskContext
  • func SetConfig(dask analyticsv1.Dask) DaskContext
  • func (context *DaskContext) ForNotebook() DaskContext
  • func (context *DaskContext) ForScheduler() DaskContext
  • func (context *DaskContext) ForWorker() DaskContext
  • func (context *DaskContext) SetJobConfig(daskjob *analyticsv1.DaskJob)

Variables

var Image string

Image Default Container Image

var PullPolicy string

PullPolicy Default image pull policy

Types

type CustomLogger

type CustomLogger struct {
	logr.Logger
}

CustomLogger - add Errorf, Infof, and Debugf

func (CustomLogger) Debugf

func (log CustomLogger) Debugf(format string, a ...interface{})

Debugf helper

func (*CustomLogger) Errorf

func (log *CustomLogger) Errorf(err error, format string, a ...interface{})

Errorf helper

func (CustomLogger) Infof

func (log CustomLogger) Infof(format string, a ...interface{})

Infof helper

func (*CustomLogger) WithValues

func (log *CustomLogger) WithValues(keysAndValues ...interface{}) CustomLogger

WithValues helper

type DaskContext

type DaskContext struct {
	JupyterIngress     string
	SchedulerIngress   string
	MonitorIngress     string
	Daemon             bool
	Jupyter            bool
	DisablePolicies    bool
	Namespace          string
	Name               string
	ServiceType        string
	Port               int
	BokehPort          int
	Replicas           int32
	Cluster            string
	Script             string
	ScriptType         string
	ScriptContents     string
	Report             bool
	ReportStorageClass string
	MountedFile        bool
	Image              string
	Repository         string
	Tag                string
	PullSecrets        interface{}
	PullPolicy         string
	NodeSelector       interface{}
	Affinity           interface{}
	Tolerations        interface{}
	Resources          interface{}
	VolumeMounts       interface{}
	Volumes            interface{}
	Env                interface{}
	JupyterImage       string
	JupyterPassword    string
	Scheduler          interface{}
	Worker             interface{}
	Notebook           interface{}
}

DaskContext is the set of parameters to configures this instance

func SetConfig

func SetConfig(dask analyticsv1.Dask) DaskContext

SetConfig setup the configuration

func (*DaskContext) ForNotebook

func (context *DaskContext) ForNotebook() DaskContext

ForNotebook - copy and arrange config values for Notebook

func (*DaskContext) ForScheduler

func (context *DaskContext) ForScheduler() DaskContext

ForScheduler - copy and arrange config values for Scheduler

func (*DaskContext) ForWorker

func (context *DaskContext) ForWorker() DaskContext

ForWorker - copy and arrange config values for Worker

func (*DaskContext) SetJobConfig

func (context *DaskContext) SetJobConfig(daskjob *analyticsv1.DaskJob)

SetJobConfig - add in DaskJob specific config elements