 Documentation
      ¶
      Documentation
      ¶
    
    
  
    
  
    Index ¶
- Constants
- func SetConfig(cfg *Config) error
- type Config
- type HTTPClient
- type Plugin
- 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
- type ResourceWrapper
Constants ¶
      View Source
      
  
const (
	ErrSystem errors.ErrorCode = "System"
)
    Variables ¶
This section is empty.
Functions ¶
Types ¶
type Config ¶
type Config struct {
	// WebAPI defines config for the base WebAPI plugin
	WebAPI webapi.PluginConfig `json:"webApi" pflag:",Defines config for the base WebAPI plugin."`
	// ResourceConstraints defines resource constraints on how many executions to be created per project/overall at any given time
	ResourceConstraints core.ResourceConstraintsSpec `` /* 141-byte string literal not displayed */
	DefaultCluster string `` /* 128-byte string literal not displayed */
	TokenKey string `json:"databricksTokenKey" pflag:",Name of the key where to find Databricks token in the secret manager."`
	DatabricksInstance string `json:"databricksInstance" pflag:",Databricks workspace instance name."`
	EntrypointFile string `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}
    Config is config for 'databricks' plugin
type HTTPClient ¶
for mocking/testing purposes, and we'll override this method
type Plugin ¶
type Plugin struct {
	// contains filtered or unexported fields
}
    func (Plugin) Create ¶
func (p Plugin) Create(ctx context.Context, taskCtx webapi.TaskExecutionContextReader) (webapi.ResourceMeta, webapi.Resource, error)
func (Plugin) GetConfig ¶
func (p Plugin) GetConfig() webapi.PluginConfig
func (Plugin) ResourceRequirements ¶
func (p Plugin) ResourceRequirements(_ context.Context, _ webapi.TaskExecutionContextReader) ( namespace core.ResourceNamespace, constraints core.ResourceConstraintsSpec, err error)
type ResourceMetaWrapper ¶
 Click to show internal directories. 
   Click to hide internal directories.