Versions in this module Expand all Collapse all v0 v0.10.0 May 7, 2021 Changes in this version + var DefaultModuleLoader = func(thread *starlark.Thread, module string) (dict starlark.StringDict, err error) + var ErrNotDefined = fmt.Errorf("not defined") + var ErrNtwkDisabled = fmt.Errorf("network use is disabled. http can only be used during download step") + var Version = version.Version + func AddDatasetLoader(loader dsref.Loader) func(o *ExecOpts) + func AddEventsChannel(eventsCh chan event.Event) func(o *ExecOpts) + func AddMutateFieldCheck(check func(path ...string) error) func(o *ExecOpts) + func AddQriRepo(repo repo.Repo) func(o *ExecOpts) + func DefaultExecOpts(o *ExecOpts) + func Error(thread *starlark.Thread, _ *starlark.Builtin, args starlark.Tuple, ...) (starlark.Value, error) + func ExecScript(ctx context.Context, next, prev *dataset.Dataset, opts ...func(o *ExecOpts)) error + func MutatedComponentsFunc(dsp *dataset.Dataset) func(path ...string) error + func SetErrWriter(w io.Writer) func(o *ExecOpts) + func SetSecrets(secrets map[string]string) func(o *ExecOpts) + type EntryReader struct + func NewEntryReader(st *dataset.Structure, iter starlark.Iterable) *EntryReader + func (r *EntryReader) Close() error + func (r *EntryReader) ReadEntry() (e dsio.Entry, err error) + func (r *EntryReader) Structure() *dataset.Structure + type ExecOpts struct + AllowFloat bool + AllowLambda bool + AllowNestedDef bool + AllowSet bool + DatasetLoader dsref.Loader + ErrWriter io.Writer + EventsCh chan event.Event + Globals starlark.StringDict + ModuleLoader ModuleLoader + MutateFieldCheck func(path ...string) error + Repo repo.Repo + Secrets map[string]interface{} + type HTTPGuard struct + NetworkEnabled bool + func (h *HTTPGuard) Allowed(req *http.Request) error + func (h *HTTPGuard) DisableNtwk() + func (h *HTTPGuard) EnableNtwk() + type ModuleLoader func(thread *starlark.Thread, module string) (starlark.StringDict, error) + type StepRunner struct + func NewStepRunner(prev *dataset.Dataset, opts ...func(o *ExecOpts)) *StepRunner + func (r *StepRunner) LoadDatasetFunc(ctx context.Context, target *dataset.Dataset) ... + func (r *StepRunner) RunStep(ctx context.Context, ds *dataset.Dataset, st *dataset.TransformStep) error
Go to main page