cache

Documentation

Index

• type DriverV1ClientGetter
• type DriverV1DiscoveryAdapter
  • func (da *DriverV1DiscoveryAdapter) Discover(ctx context.Context) (conn.Connection, error)
• type LeaderDiscovery
  • func NewDriverV1DiscoveryAdapter(fn DriverV1ClientGetter) LeaderDiscovery
• type StateLoader

Types

type DriverV1ClientGetter

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

type DriverV1DiscoveryAdapter

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

func (*DriverV1DiscoveryAdapter) Discover

func (da *DriverV1DiscoveryAdapter) Discover(ctx context.Context) (conn.Connection, error)

type LeaderDiscovery

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

func NewDriverV1DiscoveryAdapter

func NewDriverV1DiscoveryAdapter(fn DriverV1ClientGetter) LeaderDiscovery

NewDriverV1DiscoveryAdapter accepts a function which returns driver.Connection and returns a compatible LeaderDiscovery implementation

type StateLoader

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

	Invalidate()
	Valid() bool

	UpdateTime() time.Time

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