cluster

Documentation

Overview

Copyright The OpenTelemetry Authors

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright The OpenTelemetry Authors

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright The OpenTelemetry Authors

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

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