maintain

package
v0.0.0-...-82c1071 Latest Latest
Warning

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

Go to latest
Published: Aug 9, 2017 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source
const CellSchemaKey = "cell"
View Source
const ExecutorPollInterval = time.Second

Variables

View Source
var ErrSignaledWhileWaiting = errors.New("signaled while waiting for executor")

Functions

func CellSchemaPath

func CellSchemaPath(cellID string) string

func CellSchemaRoot

func CellSchemaRoot() string

func NewCellPresenceClient

func NewCellPresenceClient(client consuladapter.Client, clock clock.Clock) *cellPresenceClient

Types

type CellPresenceClient

type CellPresenceClient interface {
	NewCellPresenceRunner(logger lager.Logger, cellPresence *models.CellPresence, retryInterval, lockTTL time.Duration) ifrit.Runner

	CellById(logger lager.Logger, cellId string) (*models.CellPresence, error)
	Cells(logger lager.Logger) (models.CellSet, error)
	CellEvents(logger lager.Logger) <-chan models.CellEvent
}

type Config

type Config struct {
	CellID                string
	RepAddress            string
	RepUrl                string
	Zone                  string
	RetryInterval         time.Duration
	RootFSProviders       []string
	PreloadedRootFSes     []string
	PlacementTags         []string
	OptionalPlacementTags []string
}

type Maintainer

type Maintainer struct {
	Config
	// contains filtered or unexported fields
}

func New

func New(
	logger lager.Logger,
	config Config,
	executorClient executor.Client,
	serviceClient CellPresenceClient,
	lockTTL time.Duration,
	clock clock.Clock,
) *Maintainer

func (*Maintainer) Run

func (m *Maintainer) Run(sigChan <-chan os.Signal, ready chan<- struct{}) error

Directories

Path Synopsis
This file was generated by counterfeiter
This file was generated by counterfeiter

Jump to

Keyboard shortcuts

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