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 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 Maintainer ¶
type Maintainer struct {
Config
// contains filtered or unexported fields
}
Directories
¶
| Path | Synopsis |
|---|---|
|
This file was generated by counterfeiter
|
This file was generated by counterfeiter |
Click to show internal directories.
Click to hide internal directories.