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(_ context.Context, taskCtx webapi.StatusContext) (phase core.PhaseInfo, err error)
 
- type QueryInfo
 - 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 */
	DefaultWarehouse string `` /* 127-byte string literal not displayed */
	TokenKey string `json:"snowflakeTokenKey" pflag:",Name of the key where to find Snowflake token in the secret manager."`
	// contains filtered or unexported fields
}
    Config is config for 'snowflake' 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 ¶
type ResourceWrapper ¶
 Click to show internal directories. 
   Click to hide internal directories.