cluster

Documentation

Index

• Constants
• Variables
• type Cluster
  • func New(ctx context.Context, config config.Config, pool *conn.Pool, ...) *Cluster
  • func (c *Cluster) Allow(ctx context.Context, cc conn.Conn)
  • func (c *Cluster) Ban(ctx context.Context, cc conn.Conn, cause error)
  • func (c *Cluster) Close(ctx context.Context) (err error)
  • func (c *Cluster) Get(ctx context.Context) (cc conn.Conn, err error)

Constants

const (
	MaxGetConnTimeout = 10 * time.Second
)

Variables

var (
	// ErrClusterEmpty returned when no connections left in cluster.
	ErrClusterEmpty = xerrors.Wrap(fmt.Errorf("cluster empty"))
)

nolint: gofumpt nolint: nolintlint

Types

type Cluster

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

func New

func New(
	ctx context.Context,
	config config.Config,
	pool *conn.Pool,
	endpoints []endpoint.Endpoint,
	onBadStateCallback balancer.OnBadStateCallback,
) *Cluster

func (*Cluster) Allow

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

Allow connection in underling pool

func (*Cluster) Ban

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

Ban connection in underling pool

func (*Cluster) Close

func (c *Cluster) Close(ctx context.Context) (err error)

func (*Cluster) Get

func (c *Cluster) Get(ctx context.Context) (cc conn.Conn, err error)

Get returns next available connection. It returns error on given deadline cancellation or when cluster become closed.