cluster

Documentation

Overview

Copyright The OpenTelemetry Authors SPDX-License-Identifier: Apache-2.0

Copyright The OpenTelemetry Authors SPDX-License-Identifier: Apache-2.0

Copyright The OpenTelemetry Authors SPDX-License-Identifier: Apache-2.0

Index

• type Cluster
  • func NewCluster(policy *as.ClientPolicy, hosts []*as.Host) (*Cluster, error)
  • func (c *Cluster) Close()
  • func (c *Cluster) GetNodes() []Node
• type Node
• type SubsetCluster
  • func NewSubsetCluster(policy *as.ClientPolicy, hosts []*as.Host, authEnabled bool) (*SubsetCluster, error)
  • func (c *SubsetCluster) Close()
  • func (c *SubsetCluster) GetNodes() []Node

Types

type Cluster

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

wrap aerospike Cluster so we can return node interfaces

func NewCluster

func NewCluster(policy *as.ClientPolicy, hosts []*as.Host) (*Cluster, error)

func (*Cluster) Close

func (c *Cluster) Close()

func (*Cluster) GetNodes

func (c *Cluster) GetNodes() []Node

type Node

type Node interface {
	RequestInfo(*as.InfoPolicy, ...string) (map[string]string, as.Error)
	GetName() string
	Close()
}

type SubsetCluster

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

func NewSubsetCluster

func NewSubsetCluster(policy *as.ClientPolicy, hosts []*as.Host, authEnabled bool) (*SubsetCluster, error)

func (*SubsetCluster) Close

func (c *SubsetCluster) Close()

func (*SubsetCluster) GetNodes

func (c *SubsetCluster) GetNodes() []Node