bootstrap

README

This repo is no longer maintained and exists for archival purposes only.

Code and functionality are now in flynn/flynn

Learn more about Flynn

Documentation

Index

• func Register(name string, action Action)
• func Run(manifest []byte, ch chan<- *StepInfo, minHosts int) (err error)
• type Action
• type AddAppAction
  • func (a *AddAppAction) Cleanup(s *State) error
  • func (a *AddAppAction) Run(s *State) error
• type AddRouteAction
  • func (a *AddRouteAction) Run(s *State) error
• type AddRouteState
• type AppState
• type DeployAppAction
  • func (a *DeployAppAction) Run(s *State) error
• type GenRandomAction
  • func (a *GenRandomAction) Run(s *State) error
• type GenSSHKeyAction
  • func (a *GenSSHKeyAction) Run(s *State) error
• type GenTLSCertAction
  • func (a *GenTLSCertAction) Run(s *State) (err error)
• type Job
• type LogAction
  • func (a *LogAction) Run(s *State) error
• type LogMessage
  • func (l *LogMessage) String() string
• type Provider
• type RandomData
  • func (d *RandomData) String() string
• type RunAppAction
  • func (a *RunAppAction) Run(s *State) error
• type RunAppState
• type RunJobAction
  • func (a *RunJobAction) Run(s *State) (err error)
• type RunJobState
• type SSHKey
• type ScaleAppAction
  • func (a *ScaleAppAction) Run(s *State) error
• type State
  • func (s *State) ClusterClient() (*cluster.Client, error)
  • func (s *State) ControllerClient() (*controller.Client, error)
  • func (s *State) SetControllerKey(key string)
• type StepAction
• type StepInfo
• type TLSCert
  • func (c *TLSCert) String() string
• type WaitAction
  • func (a *WaitAction) Run(s *State) error

Functions

func Register

func Register(name string, action Action)

func Run

func Run(manifest []byte, ch chan<- *StepInfo, minHosts int) (err error)

Types

type Action

type Action interface {
	Run(*State) error
}

type AddAppAction

type AddAppAction struct {
	ID string `json:"id"`

	FromStep string  `json:"from_step"`
	App      *ct.App `json:"app"`
}

func (*AddAppAction) Cleanup

func (a *AddAppAction) Cleanup(s *State) error

func (*AddAppAction) Run

func (a *AddAppAction) Run(s *State) error

type AddRouteAction

type AddRouteAction struct {
	ID string `json:"id"`

	AppStep  string `json:"app_step"`
	CertStep string `json:"cert_step"`
	*strowger.Route
}

func (*AddRouteAction) Run

func (a *AddRouteAction) Run(s *State) error

type AddRouteState

type AddRouteState struct {
	App   *ct.App         `json:"app"`
	Route *strowger.Route `json:"route"`
}

type AppState

type AppState struct {
	*ct.ExpandedFormation
	Formation *ct.Formation  `json:"formation"`
	Resources []*ct.Resource `json:"resources"`
}

type DeployAppAction

type DeployAppAction struct {
	ID string `json:"id"`

	*ct.ExpandedFormation
	App       *ct.App        `json:"app"`
	Resources []*ct.Provider `json:"resources"`
}

func (*DeployAppAction) Run

func (a *DeployAppAction) Run(s *State) error

type GenRandomAction

type GenRandomAction struct {
	ID     string `json:"id"`
	Length int    `json:"length"`
	Data   string `json:"data"`

	ControllerKey bool `json:"controller_key"`
}

func (*GenRandomAction) Run

func (a *GenRandomAction) Run(s *State) error

type GenSSHKeyAction

type GenSSHKeyAction struct {
	ID string `json:"id"`
}

func (*GenSSHKeyAction) Run

func (a *GenSSHKeyAction) Run(s *State) error

type GenTLSCertAction

type GenTLSCertAction struct {
	ID    string   `json:"id"`
	Hosts []string `json:"hosts"`
}

func (*GenTLSCertAction) Run

func (a *GenTLSCertAction) Run(s *State) (err error)

type Job

type Job struct {
	HostID string `json:"host_id"`
	JobID  string `json:"job_id"`
}

type LogAction

type LogAction struct {
	ID     string `json:"id"`
	Output string `json:"output"`
}

func (*LogAction) Run

func (a *LogAction) Run(s *State) error

type LogMessage

type LogMessage struct {
	Msg string `json:"message"`
}

func (*LogMessage) String

func (l *LogMessage) String() string

type Provider

type Provider struct {
	Name string `json:"name"`
	URL  string `json:"url"`
}

type RandomData

type RandomData struct {
	Data string `json:"data"`
}

func (*RandomData) String

func (d *RandomData) String() string

type RunAppAction

type RunAppAction struct {
	*ct.ExpandedFormation

	ID        string         `json:"id"`
	AppStep   string         `json:"app_step"`
	Resources []*ct.Provider `json:"resources,omitempty"`
}

func (*RunAppAction) Run

func (a *RunAppAction) Run(s *State) error

type RunAppState

type RunAppState struct {
	*ct.ExpandedFormation
	Providers []*ct.Provider       `json:"providers"`
	Resources []*resource.Resource `json:"resources"`
	Jobs      []Job                `json:"jobs"`
}

type RunJobAction

type RunJobAction struct {
	ID  string    `json:"id"`
	Job *host.Job `json:"job"`
}

func (*RunJobAction) Run

func (a *RunJobAction) Run(s *State) (err error)

type RunJobState

type RunJobState struct {
	*Job
}

type SSHKey

type SSHKey struct {
	PrivateKeys string `json:"-"`

	RSAPublic   string `json:"rsa_public"`
	ECDSAPublic string `json:"ecdsa_public"`
}

type ScaleAppAction

type ScaleAppAction struct {
	AppStep string `json:"app_step"`

	*ct.Formation
}

func (*ScaleAppAction) Run

func (a *ScaleAppAction) Run(s *State) error

type State

type State struct {
	StepData  map[string]interface{}
	Providers map[string]*ct.Provider
	// contains filtered or unexported fields
}

func (*State) ClusterClient

func (s *State) ClusterClient() (*cluster.Client, error)

func (*State) ControllerClient

func (s *State) ControllerClient() (*controller.Client, error)

func (*State) SetControllerKey

func (s *State) SetControllerKey(key string)

type StepAction

type StepAction struct {
	ID     string `json:"id"`
	Action string `json:"action"`
}

type StepInfo

type StepInfo struct {
	StepAction
	StepData  interface{} `json:"data,omitempty"`
	State     string      `json:"state"`
	Error     string      `json:"error,omitempty"`
	Err       error       `json:"-"`
	Timestamp time.Time   `json:"ts"`
}

type TLSCert

type TLSCert struct {
	Cert string `json:"cert"`
	Pin  string `json:"pin"`

	PrivateKey string `json:"-"`
}

func (*TLSCert) String

func (c *TLSCert) String() string

type WaitAction

type WaitAction struct {
	URL    string `json:"url"`
	Status int    `json:"status"`
}

func (*WaitAction) Run

func (a *WaitAction) Run(s *State) error