cluster

Documentation

Index

• Variables
• 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, endpoints ...endpoint.Endpoint) *Cluster
  • func (s *Cluster) All() (all []endpoint.Endpoint)
  • func (s *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 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, endpoints ...endpoint.Endpoint) *Cluster

func (*Cluster) All

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

func (*Cluster) Next

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