cmd

Documentation

Index

• Constants
• Variables
• func AddConnection() *cli.Command
• func Clean(str string) string
• func CleanCmd() *cli.Command
• func ConnectionSchemas() *cli.Command
• func Connections() *cli.Command
• func DeleteConnection() *cli.Command
• func Docs() *cli.Command
• func Environments(isDebug *bool) *cli.Command
• func Format(isDebug *bool) *cli.Command
• func Init() *cli.Command
• func Internal() *cli.Command
• func Lineage() *cli.Command
• func Lint(isDebug *bool) *cli.Command
• func ListConnections() *cli.Command
• func ListEnvironments(isDebug *bool) *cli.Command
• func ParseAsset() *cli.Command
• func ParsePipeline() *cli.Command
• func PatchAsset() *cli.Command
• func PingConnection() *cli.Command
• func Query() *cli.Command
• func RecoverFromPanic()
• func Render() *cli.Command
• func Run(isDebug *bool) *cli.Command
• func VersionCmd(commit string) *cli.Command
• type CleanCommand
  • func (r *CleanCommand) Run(inputPath string) error
• type ConnectionsCommand
  • func (r *ConnectionsCommand) ListConnections(pathToProject, output string) error
• type EnvironmentListCommand
  • func (r *EnvironmentListCommand) Run(isDebug *bool, output string) error
• type ErrorResponse
• type ErrorResponses
• type Filter
  • func (f *Filter) ApplyFiltersAndMarkAssets(pipeline *pipeline.Pipeline, s *scheduler.Scheduler) error
• type LineageCommand
  • func (r *LineageCommand) Run(assetPath string, fullLineage bool, output string) error
• type ParseCommand
  • func (r *ParseCommand) ParsePipeline(assetPath string, lineage bool) error
  • func (r *ParseCommand) Run(assetPath string, lineage bool) error
• type RenderCommand
  • func (r *RenderCommand) Run(taskPath string) error
• type VersionInfo

Constants

const (
	DefaultTemplate   = "default"
	DefaultFolderName = "bruin-pipeline"
)

const LogsFolder = "logs"

Variables

var (
	DefaultGlossaryReader = &glossary.GlossaryReader{
		RepoFinder: &git.RepoFinder{},
		FileNames:  []string{"glossary.yml", "glossary.yaml"},
	}

	DefaultPipelineBuilder = pipeline.NewBuilder(builderConfig, pipeline.CreateTaskFromYamlDefinition(fs), pipeline.CreateTaskFromFileComments(fs), fs, DefaultGlossaryReader)
)

Functions

func AddConnection

func AddConnection() *cli.Command

func Clean

func Clean(str string) string

func CleanCmd

func CleanCmd() *cli.Command

func ConnectionSchemas

func ConnectionSchemas() *cli.Command

func Connections

func Connections() *cli.Command

func DeleteConnection

func DeleteConnection() *cli.Command

func Docs

func Docs() *cli.Command

func Environments

func Environments(isDebug *bool) *cli.Command

func Format

func Format(isDebug *bool) *cli.Command

func Init

func Init() *cli.Command

func Internal

func Internal() *cli.Command

func Lineage

func Lineage() *cli.Command

func Lint

func Lint(isDebug *bool) *cli.Command

func ListConnections

func ListConnections() *cli.Command

func ListEnvironments

func ListEnvironments(isDebug *bool) *cli.Command

func ParseAsset

func ParseAsset() *cli.Command

func ParsePipeline

func ParsePipeline() *cli.Command

func PatchAsset

func PatchAsset() *cli.Command

func PingConnection

func PingConnection() *cli.Command

func Query

func Query() *cli.Command

func RecoverFromPanic

func RecoverFromPanic()

func Render

func Render() *cli.Command

func Run

func Run(isDebug *bool) *cli.Command

func VersionCmd

func VersionCmd(commit string) *cli.Command

Types

type CleanCommand

type CleanCommand struct {
	// contains filtered or unexported fields
}

func (*CleanCommand) Run

func (r *CleanCommand) Run(inputPath string) error

type ConnectionsCommand

type ConnectionsCommand struct{}

func (*ConnectionsCommand) ListConnections

func (r *ConnectionsCommand) ListConnections(pathToProject, output string) error

type EnvironmentListCommand

type EnvironmentListCommand struct{}

func (*EnvironmentListCommand) Run

func (r *EnvironmentListCommand) Run(isDebug *bool, output string) error

type ErrorResponse

type ErrorResponse struct {
	Error string `json:"error"`
}

type ErrorResponses

type ErrorResponses struct {
	Error []string `json:"error"`
}

type Filter

type Filter struct {
	IncludeTag        string   // Tag to include assets (from `--tag`)
	OnlyTaskTypes     []string // Task types to include (from `--only`)
	IncludeDownstream bool     // Whether to include downstream tasks (from `--downstream`)
	PushMetaData      bool
	SingleTask        *pipeline.Asset
	ExcludeTag        string
}

func (*Filter) ApplyFiltersAndMarkAssets

func (f *Filter) ApplyFiltersAndMarkAssets(pipeline *pipeline.Pipeline, s *scheduler.Scheduler) error

type LineageCommand

type LineageCommand struct {
	// contains filtered or unexported fields
}

func (*LineageCommand) Run

func (r *LineageCommand) Run(assetPath string, fullLineage bool, output string) error

type ParseCommand

type ParseCommand struct {
	// contains filtered or unexported fields
}

func (*ParseCommand) ParsePipeline

func (r *ParseCommand) ParsePipeline(assetPath string, lineage bool) error

func (*ParseCommand) Run

func (r *ParseCommand) Run(assetPath string, lineage bool) error

type RenderCommand

type RenderCommand struct {
	// contains filtered or unexported fields
}

func (*RenderCommand) Run

func (r *RenderCommand) Run(taskPath string) error

type VersionInfo

type VersionInfo struct {
	Version string `json:"version"`
	Commit  string `json:"commit"`
	Latest  string `json:"latest"`
}