core

Documentation

Index

• func ConfigPush(nodes []Node, spec *spec.Spec, filename string) error
• func CronDisable(nodes []Node, spec *spec.Spec, keys []string) error
• func CronEnable(nodes []Node, spec *spec.Spec, keys []string) error
• func CronStatus(nodes []Node, spec *spec.Spec, keys []string) error
• func Deploy(nodes []Node, spec *spec.Spec, rel *Release) error
• func Df(nodes []Node, spec *spec.Spec) error
• func Forward(nodes []Node, spec *spec.Spec, port string) error
• func Log(nodes []Node, spec *spec.Spec, key string, no int) error
• func Prune(nodes []Node, spec *spec.Spec) error
• func Restart(nodes []Node, spec *spec.Spec) error
• func Run(nodes []Node, spec *spec.Spec, key string) error
• func Scale(nodes []Node, spec *spec.Spec, comp *Composition) error
• func Setup(nodes []Node, spec *spec.Spec, config string) error
• func Status(nodes []Node, spec *spec.Spec) error
• func Top(node Node, spec *spec.Spec) error
• type Composition
  • func DefaultComposition(n Node, spec *spec.Spec) (*Composition, error)
  • func NewComposition(args []string) (*Composition, error)
• type Node
  • func ParseNodeSet(hosts string, port int, identity string) ([]Node, error)
  • func SelectNode(nodes []Node) Node
  • func SelectNodes(nodes []Node) []Node
  • func (n Node) Addr() string
  • func (n Node) HasTag(tag string) bool
  • func (n Node) HasTags(tags []string) bool
  • func (n Node) Label() string
• type NodeHW
• type Release
  • func NewRelease(tarPath string) (*Release, error)
• type Tarball

Functions

func ConfigPush

func ConfigPush(nodes []Node, spec *spec.Spec, filename string) error

func CronDisable

func CronDisable(nodes []Node, spec *spec.Spec, keys []string) error

func CronEnable

func CronEnable(nodes []Node, spec *spec.Spec, keys []string) error

func CronStatus

func CronStatus(nodes []Node, spec *spec.Spec, keys []string) error

func Deploy

func Deploy(nodes []Node, spec *spec.Spec, rel *Release) error

func Df

func Df(nodes []Node, spec *spec.Spec) error

func Forward

func Forward(nodes []Node, spec *spec.Spec, port string) error

func Log

func Log(nodes []Node, spec *spec.Spec, key string, no int) error

func Prune

func Prune(nodes []Node, spec *spec.Spec) error

func Restart

func Restart(nodes []Node, spec *spec.Spec) error

func Run

func Run(nodes []Node, spec *spec.Spec, key string) error

func Scale

func Scale(nodes []Node, spec *spec.Spec, comp *Composition) error

func Setup

func Setup(nodes []Node, spec *spec.Spec, config string) error

func Status

func Status(nodes []Node, spec *spec.Spec) error

func Top

func Top(node Node, spec *spec.Spec) error

Types

type Composition

type Composition struct {
	Sizes map[string]int
}

func DefaultComposition

func DefaultComposition(n Node, spec *spec.Spec) (*Composition, error)

func NewComposition

func NewComposition(args []string) (*Composition, error)

type Node

type Node struct {
	Name string
	Host string
	Port int
	Tags []string
	HW   NodeHW

	Identity string
}

func ParseNodeSet

func ParseNodeSet(hosts string, port int, identity string) ([]Node, error)

func SelectNode

func SelectNode(nodes []Node) Node

func SelectNodes

func SelectNodes(nodes []Node) []Node

func (Node) Addr

func (n Node) Addr() string

func (Node) HasTag

func (n Node) HasTag(tag string) bool

func (Node) HasTags

func (n Node) HasTags(tags []string) bool

func (Node) Label

func (n Node) Label() string

type NodeHW

type NodeHW struct {
	Cores  int
	Memory int // In megabyte
}

type Release

type Release struct {
	Time    string
	Hash    string
	Tarball Tarball
}

func NewRelease

func NewRelease(tarPath string) (*Release, error)

type Tarball

type Tarball struct {
	Path string
}