aerospike

package
v0.0.0-...-c72af41 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 26, 2024 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ASSuffix = utils.MetricSuffix + "_aerospike"
)

Functions

func AddFlags

func AddFlags(a *kingpin.Application, cfg *AerospikeProbeCommandLine)

func DurabilityCheck

func DurabilityCheck(p topology.ProbeableEndpoint) error

func DurabilityPrepare

func DurabilityPrepare(p topology.ProbeableEndpoint) error

func GetLevel

func GetLevel(s string) (asl.LogPriority, error)

func LatencyCheck

func LatencyCheck(p topology.ProbeableEndpoint) error

func ObserveOpLatency

func ObserveOpLatency(op func() error, labels []string) error

Types

type AerospikeChecksConfigs

type AerospikeChecksConfigs struct {
	LatencyCheckConfig    scheduler.CheckConfig `yaml:"latency_check,omitempty"`
	DurabilityCheckConfig scheduler.CheckConfig `yaml:"durability_check,omitempty"`
}

type AerospikeClientConfig

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

Config used to configure the client of Aerospike

type AerospikeEndpoint

type AerospikeEndpoint struct {
	Name         string
	ClusterLevel bool
	ClusterName  string
	Client       *as.Client
	Config       AerospikeClientConfig
	Logger       log.Logger
	Namespace    string
}

func (*AerospikeEndpoint) Close

func (e *AerospikeEndpoint) Close() error

func (*AerospikeEndpoint) Connect

func (e *AerospikeEndpoint) Connect() error

func (*AerospikeEndpoint) GetHash

func (e *AerospikeEndpoint) GetHash() string

func (*AerospikeEndpoint) GetName

func (e *AerospikeEndpoint) GetName() string

func (*AerospikeEndpoint) IsCluster

func (e *AerospikeEndpoint) IsCluster() bool

func (*AerospikeEndpoint) Refresh

func (e *AerospikeEndpoint) Refresh() error

type AerospikeEndpointConfig

type AerospikeEndpointConfig struct {
	AuthEnabled bool `yaml:"auth_enabled,omitempty"`
	// If AuthEnabled use Aerospike auth external otherwise use internal
	AuthExternal  bool `yaml:"auth_external,omitempty"`
	TLSSkipVerify bool `yaml:"tls_skip_verify,omitempty"`
	// ENV related config
	// Env variable name to use to load credentials for Aerospike
	UsernameEnv string `yaml:"username_env,omitempty"`
	PasswordEnv string `yaml:"password_env,omitempty"`
	// DISCOVERY related config
	// Tag to use to determine if Aerospike need to be configured with TLS
	TLSTag string `yaml:"tls_tag,omitempty"`
	// Metadata key to get the Hostname to use for TLS auth (only used if tlsTag is set)
	TLSHostnameMetaKey string `yaml:"tls_hostname_meta_key,omitempty"`
	// Probe configuration
	NamespaceMetaKey                  string        `yaml:"namespace_meta_key,omitempty"`
	NamespaceMetaKeyPrefix            string        `yaml:"namespace_meta_key_prefix,omitempty"`
	MonitoringSet                     string        `yaml:"monitoring_set,omitempty"`
	LatencyKeyPrefix                  string        `yaml:"latency_key_prefix,omitempty"`
	DurabilityKeyPrefix               string        `yaml:"durability_key_prefix,omitempty"`
	DurabilityKeyTotal                int           `yaml:"durability_key_total,omitempty"`
	ConnectionQueueSize               int           `yaml:"connection_queue_size,omitempty"`
	OpeningConnectionThreshold        int           `yaml:"opening_connection_threshold,omitempty"`
	MinConnectionsPerNode             int           `yaml:"min_connections_per_node,omitempty"`
	TendInterval                      time.Duration `yaml:"tend_interval,omitempty"`
	ExitFastOnExhaustedConnectionPool bool          `yaml:"exit_fast_on_exhausted_connection_pool,omitempty"`
}

Config used to configure the endpoint of Aerospike

func (*AerospikeEndpointConfig) UnmarshalYAML

func (c *AerospikeEndpointConfig) UnmarshalYAML(unmarshal func(interface{}) error) error

UnmarshalYAML implements the yaml.Unmarshaler interface.

type AerospikeProbeCommandLine

type AerospikeProbeCommandLine struct {
	AerospikeLogLevel string `yaml:"aeropsike_log_level,omitempty"`
}

type AerospikeProbeConfig

type AerospikeProbeConfig struct {
	// Generic consul configurations
	DiscoveryConfig discovery.GenericDiscoveryConfig `yaml:"discovery,omitempty"`
	// Client configuration
	AerospikeEndpointConfig AerospikeEndpointConfig `yaml:"client_config,omitempty"`
	// Check configurations
	AerospikeChecksConfigs AerospikeChecksConfigs `yaml:"checks_configs,omitempty"`
}

func (AerospikeProbeConfig) NamespacedTopologyBuilder

func (conf AerospikeProbeConfig) NamespacedTopologyBuilder() func(log.Logger, []discovery.ServiceEntry) (topology.ClusterMap, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL