cluster

Oct 22, 2021

Changes in this version

+ const MaxGetConnTimeout

+ var ErrClusterClosed = errors.New("cluster closed")

+ var ErrClusterEmpty = errors.New("cluster empty")

+ var ErrUnknownEndpoint = errors.New("unknown endpoint")

+ func DiffEndpoints(curr, next []endpoint.Endpoint, eq, add, del func(i, j int))

+ func SortEndpoints(es []endpoint.Endpoint)

+ func WithConnConfig(connConfig conn.Config) option

+ func WithWG(wg wg.WG) option

+ type Cluster interface

+ Close func(ctx context.Context) error

+ Force func()

+ Get func(ctx context.Context) (conn conn.Conn, err error)

+ Insert func(ctx context.Context, endpoint endpoint.Endpoint, opts ...option)

+ Pessimize func(ctx context.Context, endpoint endpoint.Endpoint) error

+ Remove func(ctx context.Context, endpoint endpoint.Endpoint, wg ...option)

+ SetExplorer func(repeater repeater.Repeater)

+ Update func(ctx context.Context, endpoint endpoint.Endpoint, opts ...option)

+ func New(trace trace.Driver, ...) Cluster