exec

Documentation

Index

• Constants
• Variables
• func MergeSources(parent config.SourcePath, child config.SourcePath) config.SourcePath
• func ReadDredgeFile(source config.SourcePath) (config.SourcePath, *config.DredgeFile, error)
• type DredgeExec
  • func EmptyExec(source config.SourcePath, rd []api.ResourceDefinition, ...) *DredgeExec
  • func NewExec(source config.SourcePath, rd []api.ResourceDefinition, ...) (*DredgeExec, error)
  • func (e *DredgeExec) AddBucketToDredgefile(b config.Bucket) error
  • func (e *DredgeExec) AddProviderToDredgefile(resource, provider string, providerConfig map[string]string) error
  • func (e *DredgeExec) AddVariablesToDredgefile(variables map[string]string) error
  • func (e *DredgeExec) AddWorkflowToDredgefile(w config.Workflow) error
  • func (e *DredgeExec) Confirm(msg string, args ...interface{}) (bool, error)
  • func (e *DredgeExec) ExecuteResourceCommand(resourceName string, commandName string) (*api.CommandOutput, error)
  • func (exec *DredgeExec) GetBucket(bucketName string) (*workflow.Bucket, error)
  • func (exec *DredgeExec) GetBuckets() ([]*workflow.Bucket, error)
  • func (e *DredgeExec) GetProviders() ([]resource.Provider, error)
  • func (e *DredgeExec) GetResource(resourceName string) (*resource.Resource, error)
  • func (e *DredgeExec) GetResourceDefinition(resourceName string) (*api.ResourceDefinition, error)
  • func (e *DredgeExec) GetResources() ([]string, error)
  • func (e *DredgeExec) GetType(typeName string) (*api.Type, error)
  • func (exec *DredgeExec) GetWorkflow(bucketName, workflowName string) (*workflow.Workflow, error)
  • func (exec *DredgeExec) GetWorkflows() ([]*workflow.Workflow, error)
  • func (exec *DredgeExec) GetWorkflowsInBucket(b *workflow.Bucket) ([]*workflow.Workflow, error)
  • func (exec *DredgeExec) Import(source config.SourcePath) (*DredgeExec, error)
  • func (e *DredgeExec) Log(level api.LogLevel, msg string, args ...interface{}) error
  • func (e *DredgeExec) OpenUrl(url string) error
  • func (e *DredgeExec) RelativePathFromDredgefile(path string) (string, error)
  • func (e *DredgeExec) RequestInput(inputRequests []api.InputRequest) (map[string]string, error)
  • func (e *DredgeExec) SetEnv(name string, value interface{}) error
  • func (e *DredgeExec) Template(input string) (string, error)
• type Env
  • func NewEnv() Env
  • func (e Env) AddInput(input config.Input, reader io.Reader) error
  • func (e Env) AddInputs(inputs map[string]string)
  • func (e Env) AddVariables(v config.Variables)
  • func (e Env) Clone() Env

Constants

const (
	DefaultDredgefileName  = "Dredgefile"
	DefaultDredgeRepo      = "https://github.com/dredge-dev/dredge-repo.git"
	LocalDredgeStorage     = ".dredge"
	LocalDredgeRepoStorage = LocalDredgeStorage + "/repo/"
)

Variables

var TEMPLATE_FUNCTIONS = template.FuncMap{
	"replace": func(s, old, new string) string {
		return strings.Replace(s, old, new, -1)
	},
	"date": func(format string) string {
		return time.Now().Format(format)
	},
	"join": func(s1, s2, sep string) string {
		if len(s1) == 0 {
			return s2
		}
		if len(s2) == 0 {
			return s1
		}
		return s1 + sep + s2
	},
	"trimSpace": func(s string) string {
		return strings.TrimSpace(s)
	},
	"isTrue":  isTrue,
	"isFalse": isFalse,
}

Functions

func MergeSources

func MergeSources(parent config.SourcePath, child config.SourcePath) config.SourcePath

func ReadDredgeFile

func ReadDredgeFile(source config.SourcePath) (config.SourcePath, *config.DredgeFile, error)

Types

type DredgeExec

type DredgeExec struct {
	Parent              *DredgeExec
	Source              config.SourcePath
	DredgeFile          *config.DredgeFile
	Env                 Env
	ResourceDefinitions []api.ResourceDefinition
	// contains filtered or unexported fields
}

func EmptyExec

func EmptyExec(source config.SourcePath, rd []api.ResourceDefinition, c api.UserInteractionCallbacks) *DredgeExec

func NewExec

func NewExec(source config.SourcePath, rd []api.ResourceDefinition, c api.UserInteractionCallbacks) (*DredgeExec, error)

func (*DredgeExec) AddBucketToDredgefile

func (e *DredgeExec) AddBucketToDredgefile(b config.Bucket) error

func (*DredgeExec) AddProviderToDredgefile

func (e *DredgeExec) AddProviderToDredgefile(resource, provider string, providerConfig map[string]string) error

func (*DredgeExec) AddVariablesToDredgefile

func (e *DredgeExec) AddVariablesToDredgefile(variables map[string]string) error

func (*DredgeExec) AddWorkflowToDredgefile

func (e *DredgeExec) AddWorkflowToDredgefile(w config.Workflow) error

func (*DredgeExec) Confirm

func (e *DredgeExec) Confirm(msg string, args ...interface{}) (bool, error)

func (*DredgeExec) ExecuteResourceCommand

func (e *DredgeExec) ExecuteResourceCommand(resourceName string, commandName string) (*api.CommandOutput, error)

func (*DredgeExec) GetBucket

func (exec *DredgeExec) GetBucket(bucketName string) (*workflow.Bucket, error)

func (*DredgeExec) GetBuckets

func (exec *DredgeExec) GetBuckets() ([]*workflow.Bucket, error)

func (*DredgeExec) GetProviders

func (e *DredgeExec) GetProviders() ([]resource.Provider, error)

func (*DredgeExec) GetResource

func (e *DredgeExec) GetResource(resourceName string) (*resource.Resource, error)

func (*DredgeExec) GetResourceDefinition

func (e *DredgeExec) GetResourceDefinition(resourceName string) (*api.ResourceDefinition, error)

func (*DredgeExec) GetResources

func (e *DredgeExec) GetResources() ([]string, error)

func (*DredgeExec) GetType

func (e *DredgeExec) GetType(typeName string) (*api.Type, error)

func (*DredgeExec) GetWorkflow

func (exec *DredgeExec) GetWorkflow(bucketName, workflowName string) (*workflow.Workflow, error)

func (*DredgeExec) GetWorkflows

func (exec *DredgeExec) GetWorkflows() ([]*workflow.Workflow, error)

func (*DredgeExec) GetWorkflowsInBucket

func (exec *DredgeExec) GetWorkflowsInBucket(b *workflow.Bucket) ([]*workflow.Workflow, error)

func (*DredgeExec) Import

func (exec *DredgeExec) Import(source config.SourcePath) (*DredgeExec, error)

func (*DredgeExec) Log

func (e *DredgeExec) Log(level api.LogLevel, msg string, args ...interface{}) error

func (*DredgeExec) OpenUrl

func (e *DredgeExec) OpenUrl(url string) error

func (*DredgeExec) RelativePathFromDredgefile

func (e *DredgeExec) RelativePathFromDredgefile(path string) (string, error)

func (*DredgeExec) RequestInput

func (e *DredgeExec) RequestInput(inputRequests []api.InputRequest) (map[string]string, error)

func (*DredgeExec) SetEnv

func (e *DredgeExec) SetEnv(name string, value interface{}) error

func (*DredgeExec) Template

func (e *DredgeExec) Template(input string) (string, error)

type Env

type Env map[string]interface{}

func NewEnv

func NewEnv() Env

func (Env) AddInput

func (e Env) AddInput(input config.Input, reader io.Reader) error

func (Env) AddInputs

func (e Env) AddInputs(inputs map[string]string)

func (Env) AddVariables

func (e Env) AddVariables(v config.Variables)

func (Env) Clone

func (e Env) Clone() Env