leaderelection

type Config struct {
	LeaseDuration int64    `yaml:"lease_duration"`
	Name          string   `yaml:"name"`
	KeyPrefix     string   `yaml:"key_prefix"`
	EtcdEndpoints []string `yaml:"etcd"`
}

type LeaderCallbacks struct {
	// OnStartedLeading is called when starts leading
	OnStartedLeading func(context.Context)
	// OnStoppedLeading is called when stops leading
	OnStoppedLeading func(context.Context)
}

type Manager interface {
	Start(ctx context.Context, callbacks LeaderCallbacks) error
	Stop(ctx context.Context) error
}

type MockManager struct {
	// contains filtered or unexported fields
}

type MockManagerMockRecorder struct {
	// contains filtered or unexported fields
}

type MockMutex struct {
	// contains filtered or unexported fields
}

type MockMutexMockRecorder struct {
	// contains filtered or unexported fields
}

type Mutex interface {
	TryLock(ctx context.Context) error
	Unlock(ctx context.Context) error
}