plug

type Leased struct {
	Plug
	// contains filtered or unexported fields
}

type Leaser interface {
	// AcquireAndHold tries to acquire the lease and hold it until it expires, the lease is deleted,
	// or we observe another party take the lease. The notify channel will be sent a nil value
	// when the lease is held, and closed when the lease is lost. If an error is sent the lease
	// is also considered lost.
	AcquireAndHold(chan error)
	Release()
}

type Plug interface {
	// Begins operation of the plug and unblocks WaitForStart().
	// May be invoked multiple times but only the first invocation has
	// an effect.
	Start()
	// Ends operation of the plug and unblocks WaitForStop()
	// May be invoked multiple times but only the first invocation has
	// an effect. Calling Stop() before Start() is undefined. An error
	// may be returned with the stop.
	Stop(err error)
	// Blocks until Start() is invoked
	WaitForStart()
	// Blocks until Stop() is invoked
	WaitForStop() error
	// Returns true if Start() has been invoked
	IsStarted() bool
}