fixer

package
v0.0.0-...-b359386 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 15, 2020 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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) CheckSirenia

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

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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL