fixer

Documentation

Index

• type ClusterFixer
  • func NewClusterFixer(hosts []*cluster.Host, c *cluster.Client, l log15.Logger) *ClusterFixer
  • func (f *ClusterFixer) FindAppReleaseJobs(app, typ string) []map[string]*host.Job
  • func (f *ClusterFixer) FixController(instances []*discoverd.Instance, startScheduler bool) error
  • func (f *ClusterFixer) FixDiscoverd() error
  • func (f *ClusterFixer) FixFlannel() error
  • func (f *ClusterFixer) FixJobEnv(job *host.Job)
  • func (f *ClusterFixer) FixSirenia(svc string) error
  • func (f *ClusterFixer) GetJob(jobID string) (*host.Job, *cluster.Host, error)
  • func (f *ClusterFixer) Host(id string) *cluster.Host
  • func (f *ClusterFixer) KillSchedulers() error
  • func (f *ClusterFixer) Run(args *docopt.Args, c *cluster.Client) error
  • func (f *ClusterFixer) StartAppJob(app, typ, service string) ([]*discoverd.Instance, error)
  • func (f *ClusterFixer) StartScheduler(client controller.Client, cf *ct.Formation) error
• type ReleasesByCreate
  • func (p ReleasesByCreate) Len() int
  • func (p ReleasesByCreate) Less(i, j int) bool
  • func (p ReleasesByCreate) Swap(i, j int)
• type SortableRelease

Types

type ClusterFixer

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

func NewClusterFixer

func NewClusterFixer(hosts []*cluster.Host, c *cluster.Client, l log15.Logger) *ClusterFixer

func (*ClusterFixer) FindAppReleaseJobs

func (f *ClusterFixer) FindAppReleaseJobs(app, typ string) []map[string]*host.Job

FindAppReleaseJobs returns a slice with one map of host id to job for each known release of the given app and type, most recent first

func (*ClusterFixer) FixController

func (f *ClusterFixer) FixController(instances []*discoverd.Instance, startScheduler bool) error

func (*ClusterFixer) FixDiscoverd

func (f *ClusterFixer) FixDiscoverd() error

func (*ClusterFixer) FixFlannel

func (f *ClusterFixer) FixFlannel() error

func (*ClusterFixer) FixJobEnv

func (f *ClusterFixer) FixJobEnv(job *host.Job)

func (*ClusterFixer) FixSirenia

func (f *ClusterFixer) FixSirenia(svc string) error

func (*ClusterFixer) GetJob

func (f *ClusterFixer) GetJob(jobID string) (*host.Job, *cluster.Host, error)

func (*ClusterFixer) Host

func (f *ClusterFixer) Host(id string) *cluster.Host

func (*ClusterFixer) KillSchedulers

func (f *ClusterFixer) KillSchedulers() error

func (*ClusterFixer) Run

func (f *ClusterFixer) Run(args *docopt.Args, c *cluster.Client) error

func (*ClusterFixer) StartAppJob

func (f *ClusterFixer) StartAppJob(app, typ, service string) ([]*discoverd.Instance, error)

func (*ClusterFixer) StartScheduler

func (f *ClusterFixer) StartScheduler(client controller.Client, cf *ct.Formation) error

type ReleasesByCreate

type ReleasesByCreate []SortableRelease

func (ReleasesByCreate) Len

func (p ReleasesByCreate) Len() int

func (ReleasesByCreate) Less

func (p ReleasesByCreate) Less(i, j int) bool

func (ReleasesByCreate) Swap

func (p ReleasesByCreate) Swap(i, j int)

type SortableRelease

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