balancertesting

Oct 13, 2023

Changes in this version

+ func DeterministicReconciler(newAddrs []resolver.Address, removeConns []conn.Conn)

+ func FindConn(set conns.Set, addr resolver.Address, index int) conn.Conn

+ func NewFakePicker(_ picker.Picker, connections conn.Conns) picker.Picker

+ type ConnHealth map[conn.Conn]health.State

+ func (ch ConnHealth) AsSet() conns.Set

+ type FakeConn struct

+ Index int

+ func (c *FakeConn) Address() resolver.Address

+ func (c *FakeConn) Prewarm(ctx context.Context) error

+ func (c *FakeConn) RoundTrip(*http.Request, func()) (*http.Response, error)

+ func (c *FakeConn) Scheme() string

+ func (c *FakeConn) UpdateAttributes(values attribute.Values)

+ type FakeConnPool struct

+ Prewarm func(conn.Conn, context.Context) error

+ func NewFakeConnPool() *FakeConnPool

+ func (p *FakeConnPool) AwaitConnUpdate(ctx context.Context) (conns.Set, error)

+ func (p *FakeConnPool) AwaitPickerUpdate(ctx context.Context) (PickerState, error)

+ func (p *FakeConnPool) AwaitResolveNow(ctx context.Context) (int, error)

+ func (p *FakeConnPool) Conns() conn.Conns

+ func (p *FakeConnPool) NewConn(address resolver.Address) (conn.Conn, bool)

+ func (p *FakeConnPool) RemoveConn(toRemove conn.Conn) bool

+ func (p *FakeConnPool) ResolveNow()

+ func (p *FakeConnPool) SnapshotConns() conns.Set

+ func (p *FakeConnPool) UpdatePicker(picker picker.Picker, isWarm bool)

+ type FakeHealthChecker struct

+ func NewFakeHealthChecker() *FakeHealthChecker

+ func (hc *FakeHealthChecker) AwaitCheckerUpdate(ctx context.Context) (ConnHealth, error)

+ func (hc *FakeHealthChecker) AwaitConnectionInitialized(ctx context.Context, connection conn.Conn) (health.State, error)

+ func (hc *FakeHealthChecker) New(_ context.Context, connection conn.Conn, tracker health.Tracker) io.Closer

+ func (hc *FakeHealthChecker) SetInitialState(state health.State)

+ func (hc *FakeHealthChecker) SnapshotConns() ConnHealth

+ func (hc *FakeHealthChecker) UpdateHealthState(connection conn.Conn, state health.State)

+ type FakePicker struct

+ Conns conns.Set

+ func (p *FakePicker) Pick(*http.Request) (conn conn.Conn, whenDone func(), err error)

+ type PickerState struct

+ IsWarm bool

+ Picker picker.Picker

+ SnapshotConns conns.Set