package cluster

import "github.com/ydb-platform/ydb-go-sdk/v3/internal/balancer/cluster"

Index ¶

• Variables
• func From(parent *Cluster) option
• func WithFallback(allowFallback bool) option
• func WithFilter(filter func(e endpoint.Info) bool) option
• type Cluster
• func New(endpoints []endpoint.Endpoint, opts ...option) *Cluster
• func Without(s *Cluster, required endpoint.Endpoint, other ...endpoint.Endpoint) *Cluster
• func (c *Cluster) All() (all []endpoint.Endpoint)
• func (c *Cluster) Availability() (percent float64)
• func (c *Cluster) Next(ctx context.Context) (endpoint.Endpoint, error)

Variables ¶

var (
	ErrNoEndpoints = xerrors.Wrap(fmt.Errorf("no endpoints"))
	ErrNilPtr      = xerrors.Wrap(fmt.Errorf("nil pointer"))
)

Functions ¶

func From ¶

func From(parent *Cluster) option

func WithFallback ¶

func WithFallback(allowFallback bool) option

func WithFilter ¶

func WithFilter(filter func(e endpoint.Info) bool) option

Types ¶

type Cluster ¶

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

func New ¶

func New(endpoints []endpoint.Endpoint, opts ...option) *Cluster

func Without ¶

func Without(s *Cluster, required endpoint.Endpoint, other ...endpoint.Endpoint) *Cluster

func (*Cluster) All ¶

func (c *Cluster) All() (all []endpoint.Endpoint)

func (*Cluster) Availability ¶

func (c *Cluster) Availability() (percent float64)

func (*Cluster) Next ¶

func (c *Cluster) Next(ctx context.Context) (endpoint.Endpoint, error)

Source Files ¶

cluster.go errors.go