utils

Documentation

Index

• type BinaryManager
  • func NewBinaryManager(dir string, stdoutChan, stderrChan chan string) *BinaryManager
  • func (b *BinaryManager) Push(githubUserName, githubToken, githubRepository, dir, assetOut string) error
• type CommandFlow
  • func NewCommandFlow(commands []string, dir string, stdoutChan, stderrChan chan string) *CommandFlow
  • func (f *CommandFlow) Restart() error
  • func (f *CommandFlow) Start() error
  • func (f *CommandFlow) Stop() error
  • func (f *CommandFlow) Wait() error
• type DockerManager
  • func NewDockerManager(dir string, stdoutChan, stderrChan chan string) *DockerManager
  • func (d *DockerManager) Build(file, context, tag string) error
  • func (d *DockerManager) BuildManifest(tag string, images []string) error
  • func (d *DockerManager) CopyFromImage(tag, assetInImage, assetOut string) error
  • func (d *DockerManager) Push(tag string) error
  • func (d *DockerManager) PushManifest(tag string) error
  • func (d *DockerManager) Run(tag, execLine string, dockerInDocker bool) error
• type HelmManager
  • func NewHelmManager(dir string, stdoutChan, stderrChan chan string) *HelmManager
  • func (h *HelmManager) Build(src, dist string) error
  • func (h *HelmManager) Push(...) error
• type ManageableCommand
  • func NewManageableCommand(execLine, dir string, stdoutChan chan string, stderrChan chan string) *ManageableCommand
  • func (r *ManageableCommand) GetDir() string
  • func (r *ManageableCommand) GetExecLine() string
  • func (r *ManageableCommand) GetStderrChan() chan string
  • func (r *ManageableCommand) GetStdoutChan() chan string
  • func (r *ManageableCommand) IsStopped() bool
  • func (r *ManageableCommand) Start() error
  • func (r *ManageableCommand) Stop() error
  • func (r *ManageableCommand) Wait() error
• type PathWatcher
  • func NewPathWatcher(pathWatch, pathInclude string, eventChan chan string) *PathWatcher
  • func (p *PathWatcher) Start() error

Types

type BinaryManager

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

BinaryManager manages binaries

func NewBinaryManager

func NewBinaryManager(dir string, stdoutChan, stderrChan chan string) *BinaryManager

NewBinaryManager creates a new BinaryManager

func (*BinaryManager) Push

func (b *BinaryManager) Push(githubUserName, githubToken, githubRepository, dir, assetOut string) error

Push releases a binary to GitHub releases

type CommandFlow

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

CommandFlow is a manageable collection of commands

func NewCommandFlow

func NewCommandFlow(commands []string, dir string, stdoutChan, stderrChan chan string) *CommandFlow

NewCommandFlow creates a new CommandFlow

func (*CommandFlow) Restart

func (f *CommandFlow) Restart() error

Restart restarts the flow

func (*CommandFlow) Start

func (f *CommandFlow) Start() error

Start starts the command flow

func (*CommandFlow) Stop

func (f *CommandFlow) Stop() error

TODO: Add test that ensures that it waits until all have stopped (this is necessary so that ports don't block) Stop stops the flow

func (*CommandFlow) Wait

func (f *CommandFlow) Wait() error

Wait waits for the command flow to complete

type DockerManager

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

DockerManager manages Docker

func NewDockerManager

func NewDockerManager(dir string, stdoutChan, stderrChan chan string) *DockerManager

NewDockerManager creates a new DockerManager

func (*DockerManager) Build

func (d *DockerManager) Build(file, context, tag string) error

Build builds and tags a Docker image

func (*DockerManager) BuildManifest

func (d *DockerManager) BuildManifest(tag string, images []string) error

BuildManifest builds a Docker manifest from multiple images

func (*DockerManager) CopyFromImage

func (d *DockerManager) CopyFromImage(tag, assetInImage, assetOut string) error

CopyFromImage copies an asset from a Docker image

func (*DockerManager) Push

func (d *DockerManager) Push(tag string) error

Push pushes a Docker image

func (*DockerManager) PushManifest

func (d *DockerManager) PushManifest(tag string) error

PushManifest pushes a Docker manifest

func (*DockerManager) Run

func (d *DockerManager) Run(tag, execLine string, dockerInDocker bool) error

Run runs a command in a Docker image

type HelmManager

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

HelmManager manages Helm

func NewHelmManager

func NewHelmManager(dir string, stdoutChan, stderrChan chan string) *HelmManager

NewHelmManager creates a new HelmManager

func (*HelmManager) Build

func (h *HelmManager) Build(src, dist string) error

Build builds a Helm chart

func (*HelmManager) Push

func (h *HelmManager) Push(gitUserName, gitUserEmail, gitCommitMessage, githubUserName, githubToken, githubRepositoryName, githubRepositoryUrl, githubPagesUrl, chartDist, cloneDir string) error

Push releases a Helm chart using GitHub, GitHub releases and GitHub pages

type ManageableCommand

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

ManageableCommand is a manageable command

func NewManageableCommand

func NewManageableCommand(execLine, dir string, stdoutChan chan string, stderrChan chan string) *ManageableCommand

NewManageableCommand creates a new ManageableCommand

func (*ManageableCommand) GetDir

func (r *ManageableCommand) GetDir() string

Dir returns the command's dir

func (*ManageableCommand) GetExecLine

func (r *ManageableCommand) GetExecLine() string

GetExecLine returns the command's execLine

func (*ManageableCommand) GetStderrChan

func (r *ManageableCommand) GetStderrChan() chan string

GetStderrChan returns the command's stderr channel

func (*ManageableCommand) GetStdoutChan

func (r *ManageableCommand) GetStdoutChan() chan string

GetStdoutChan returns the command's stdout channel

func (*ManageableCommand) IsStopped

func (r *ManageableCommand) IsStopped() bool

TODO: Add test for Zombie processes IsStopped returns true if the command has stopped. WARNING: This always returns false for Zombie processes.

func (*ManageableCommand) Start

func (r *ManageableCommand) Start() error

Start starts the command

func (*ManageableCommand) Stop

func (r *ManageableCommand) Stop() error

TODO: Add test for Zombie processes Stop stops the command

func (*ManageableCommand) Wait

func (r *ManageableCommand) Wait() error

Wait waits for the command to complete

type PathWatcher

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

PathWatcher watches for changes in a directory

func NewPathWatcher

func NewPathWatcher(pathWatch, pathInclude string, eventChan chan string) *PathWatcher

NewPathWatcher creates a new PathWatcher

func (*PathWatcher) Start

func (p *PathWatcher) Start() error

Start starts the PathWatcher