locker

type EtcdLeaseManager interface {
	Start(ctx context.Context) error
	Stop(ctx context.Context)
	GetLease(ctx context.Context) (clientv3.LeaseID, error)                                    // This will get the current lease or wait for one to be generated
	MarkLeaseAsDirty(ctx context.Context, leaseID clientv3.LeaseID) error                      // This is sent by clients if they think that there might be an issue with the Lease
	SubscribeToLeaseChange(ctx context.Context, callback LeaseChangedCallback) (string, error) // Subscribe to lease changes. This function returns an ID that should be used to unsubscribe.
	UnsubscribeToLeaseChange(ctx context.Context, id string) error                             // Unsubscribe from the lease changes
}

type LeaseChangedCallback func(ctx context.Context, oldLeaseID, newLeaseID clientv3.LeaseID)

type Locker interface {
	Refresh(context.Context) error          // Refresh must be called to refresh our TTL or to try to get the lock
	Unlock(context.Context) error           // Unlock remove the lock and mark the lock accessible for re-election
	IsMaster(context.Context) (bool, error) // IsMaster return true if the lock is allocated to our node
	Stop(context.Context) error             // Stop the locker (cleanup)
}

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

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