Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AlivenessChecker ¶
type AlivenessChecker interface {
Alive() bool
}
type CheckingSyncWrapper ¶
type CheckingSyncWrapper struct {
// contains filtered or unexported fields
}
CheckingSyncWrapper wraps calls to the factory.SyncFunc in order to track when it last ran successfully.
func NewCheckingSyncWrapper ¶
func NewCheckingSyncWrapper(sync factory.SyncFunc, livenessThreshold time.Duration) *CheckingSyncWrapper
func NewDefaultCheckingSyncWrapper ¶
func NewDefaultCheckingSyncWrapper(sync factory.SyncFunc) *CheckingSyncWrapper
NewDefaultCheckingSyncWrapper creates a new CheckingSyncWrapper with 5m threshold
func (*CheckingSyncWrapper) Alive ¶
func (r *CheckingSyncWrapper) Alive() bool
func (*CheckingSyncWrapper) Sync ¶
func (r *CheckingSyncWrapper) Sync(ctx context.Context, controllerContext factory.SyncContext) error
type MultiAlivenessChecker ¶
type MultiAlivenessChecker struct {
// contains filtered or unexported fields
}
func NewMultiAlivenessChecker ¶
func NewMultiAlivenessChecker() *MultiAlivenessChecker
func (*MultiAlivenessChecker) Add ¶
func (r *MultiAlivenessChecker) Add(name string, c AlivenessChecker)
func (*MultiAlivenessChecker) Alive ¶
func (r *MultiAlivenessChecker) Alive() bool
Source Files
Click to show internal directories.
Click to hide internal directories.