run

Documentation

Index

• type LocalApp
  • func (a *LocalApp) Run(outputCh chan<- *apiv1.RunOutputResponse) (*LocalAppRunInfo, error)
• type LocalAppRunInfo
  • func NewLocalAppRunInfo(a *LocalApp) (*LocalAppRunInfo, error)
  • func (a *LocalAppRunInfo) Run(outputCh chan<- *apiv1.RunOutputResponse) error
  • func (a *LocalAppRunInfo) Stop() error
  • func (a *LocalAppRunInfo) Wait() error
• type LocalDependency
  • func (d *LocalDependency) Run() (*LocalDependencyRunInfo, error)
• type LocalDependencyRunInfo
• type LocalRunResult
  • func Local(ctx context.Context, localApps []*LocalApp, localDeps []*LocalDependency) (*LocalRunResult, error)
  • func (l *LocalRunResult) Stop() error
  • func (l *LocalRunResult) Wait() error
• type PluginInfo
  • func (i *PluginInfo) Wait() error
• type PluginRunResult
  • func ThroughPlugin(ctx context.Context, runMap map[*plugins.Plugin]*apiv1.RunRequest) (*PluginRunResult, error)
  • func (l *PluginRunResult) Stop() error
  • func (l *PluginRunResult) Wait() error

Types

type LocalApp

type LocalApp struct {
	*apiv1.AppRun
	Command *command.StringCommand
}

func (*LocalApp) Run

func (a *LocalApp) Run(outputCh chan<- *apiv1.RunOutputResponse) (*LocalAppRunInfo, error)

type LocalAppRunInfo

type LocalAppRunInfo struct {
	*command.Cmd
	*LocalApp
	// contains filtered or unexported fields
}

func NewLocalAppRunInfo

func NewLocalAppRunInfo(a *LocalApp) (*LocalAppRunInfo, error)

func (*LocalAppRunInfo) Run

func (a *LocalAppRunInfo) Run(outputCh chan<- *apiv1.RunOutputResponse) error

func (*LocalAppRunInfo) Stop

func (a *LocalAppRunInfo) Stop() error

func (*LocalAppRunInfo) Wait

func (a *LocalAppRunInfo) Wait() error

type LocalDependency

type LocalDependency struct {
	*apiv1.DependencyRun
}

func (*LocalDependency) Run

func (d *LocalDependency) Run() (*LocalDependencyRunInfo, error)

type LocalDependencyRunInfo

type LocalDependencyRunInfo struct {
	*command.Cmd
	*LocalDependency
	StdoutCh chan string
	StderrCh chan string
}

type LocalRunResult

type LocalRunResult struct {
	Apps     map[string]*LocalAppRunInfo
	Deps     map[string]*LocalDependencyRunInfo
	OutputCh chan *apiv1.RunOutputResponse
}

func Local

func Local(ctx context.Context, localApps []*LocalApp, localDeps []*LocalDependency) (*LocalRunResult, error)

func (*LocalRunResult) Stop

func (l *LocalRunResult) Stop() error

func (*LocalRunResult) Wait

func (l *LocalRunResult) Wait() error

type PluginInfo

type PluginInfo struct {
	Response *apiv1.RunStartResponse
	// contains filtered or unexported fields
}

func (*PluginInfo) Wait

func (i *PluginInfo) Wait() error

type PluginRunResult

type PluginRunResult struct {
	Info     map[*plugins.Plugin]*PluginInfo
	OutputCh chan *apiv1.RunOutputResponse
}

func ThroughPlugin

func ThroughPlugin(ctx context.Context, runMap map[*plugins.Plugin]*apiv1.RunRequest) (*PluginRunResult, error)

func (*PluginRunResult) Stop

func (l *PluginRunResult) Stop() error

func (*PluginRunResult) Wait

func (l *PluginRunResult) Wait() error