cache

type DriverV1ClientGetter func(ctx context.Context) (driver.Connection, error)

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

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
}