cluster

May 11, 2022

Changes in this version

type Cluster

+ func (c *Cluster) Allow(ctx context.Context, cc conn.Conn)

May 6, 2022

Changes in this version

type Cluster

+ func (c *Cluster) Ban(ctx context.Context, cc conn.Conn, cause error)

+ func (c *Cluster) Unban(ctx context.Context, cc conn.Conn)

Apr 20, 2022

Changes in this version

+ type CrudOption func(h *crudOptionsHolder)

Mar 24, 2022

Changes in this version

+ type Getter interface

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

+ type Inserter interface

+ Insert func(ctx context.Context, endpoint endpoint.Endpoint, opts ...crudOption) conn.Conn

+ type InserterRemoverExplorerLocker interface

+ type Remover interface

+ Remove func(ctx context.Context, endpoint endpoint.Endpoint, opts ...crudOption) conn.Conn

Feb 22, 2022

Changes in this version

+ func WithoutLock() crudOption

+ type CRUDExplorerLocker interface

+ type Locker interface

+ Lock func()

+ Unlock func()

Feb 16, 2022

Changes in this version

+ type CRUD interface

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

+ Insert func(ctx context.Context, endpoint endpoint.Endpoint) conn.Conn

+ Remove func(ctx context.Context, endpoint endpoint.Endpoint) conn.Conn

+ Update func(ctx context.Context, endpoint endpoint.Endpoint) conn.Conn

+ type CRUDExplorer interface

+ type Explorer interface

+ Force func()

+ SetExplorer func(repeater repeater.Repeater)

+ type Pessimizer interface

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

Jan 17, 2022

Changes in this version

+ func WithEndpoint(ctx context.Context, endpoint Endpoint) context.Context

+ type Endpoint interface

+ NodeID func() uint32

+ func ContextEndpoint(ctx context.Context) (e Endpoint, ok bool)

Jan 4, 2022

Changes in this version

+ const MaxGetConnTimeout

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

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

+ var ErrNilBalancerElement = errors.New("nil balancer element")

+ var ErrUnknownBalancerElement = errors.New("unknown balancer element")

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

+ var ErrUnknownTypeOfBalancerElement = errors.New("unknown types of balancer element")

+ 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