databricks

Dec 19, 2022

Changes in this version

+ const ErrSystem

+ func SetConfig(cfg *Config) error

+ type Config struct

+ DatabricksInstance string

+ DefaultCluster string

+ EntrypointFile string

+ ResourceConstraints core.ResourceConstraintsSpec

+ TokenKey string

+ WebAPI webapi.PluginConfig

+ func GetConfig() *Config

+ type HTTPClient interface

+ Do func(req *http.Request) (*http.Response, error)

+ type Plugin struct

+ func (p Plugin) Create(ctx context.Context, taskCtx webapi.TaskExecutionContextReader) (webapi.ResourceMeta, webapi.Resource, error)

+ func (p Plugin) Delete(ctx context.Context, taskCtx webapi.DeleteContext) error

+ func (p Plugin) Get(ctx context.Context, taskCtx webapi.GetContext) (latest webapi.Resource, err error)

+ func (p Plugin) GetConfig() webapi.PluginConfig

+ func (p Plugin) ResourceRequirements(_ context.Context, _ webapi.TaskExecutionContextReader) (namespace core.ResourceNamespace, constraints core.ResourceConstraintsSpec, ...)

+ func (p Plugin) Status(ctx context.Context, taskCtx webapi.StatusContext) (phase core.PhaseInfo, err error)

+ type ResourceMetaWrapper struct

+ DatabricksInstance string

+ RunID string

+ Token string

+ type ResourceWrapper struct

+ JobID string

+ LifeCycleState string

+ Message string

+ ResultState string

+ StatusCode int