cache

type LeaderDiscovery interface {
	Discover(ctx context.Context) (conn.Connection, error)
}

type StateLoader[T interface{}] interface {
	State() (*T, uint64, bool)

	Invalidate()
	Valid() bool

	UpdateTime() time.Time

	Refresh(ctx context.Context, discovery LeaderDiscovery) error
}