Documentation ¶
Index ¶
- Variables
- func AddFlags(a *kingpin.Application, cfg *AerospikeProbeCommandLine)
- func DurabilityCheck(p topology.ProbeableEndpoint) error
- func DurabilityPrepare(p topology.ProbeableEndpoint) error
- func GetLevel(s string) (asl.LogPriority, error)
- func LatencyCheck(p topology.ProbeableEndpoint) error
- func ObserveOpLatency(op func() error, labels []string) error
- type AerospikeChecksConfigs
- type AerospikeClientConfig
- type AerospikeEndpoint
- type AerospikeEndpointConfig
- type AerospikeProbeCommandLine
- type AerospikeProbeConfig
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 LatencyCheck ¶
func LatencyCheck(p topology.ProbeableEndpoint) error
func ObserveOpLatency ¶
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)
Click to show internal directories.
Click to hide internal directories.