sinks

type GangliaMetric struct {
	Name  string
	Type  string
	Slope string
	Tmax  int
	Unit  string
}

type GangliaMetricConfig struct {
	Type  string
	Slope string
	Tmax  int
	Unit  string
	Group string
	Value string
	Name  string
}

type GangliaMetricGroup struct {
	Name    string
	Metrics []GangliaMetric
}

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

type GangliaSinkConfig struct {
	GmetricPath     string `json:"gmetric_path,omitempty"`
	GmetricConfig   string `json:"gmetric_config,omitempty"`
	AddGangliaGroup bool   `json:"add_ganglia_group,omitempty"`
	AddTagsAsDesc   bool   `json:"add_tags_as_desc,omitempty"`
	ClusterName     string `json:"cluster_name,omitempty"`
	AddTypeToName   bool   `json:"add_type_to_name,omitempty"`
	AddUnits        bool   `json:"add_units,omitempty"`
	// contains filtered or unexported fields
}

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

type HttpSinkConfig struct {

	// The full URL of the endpoint
	URL string `json:"url"`

	// JSON web tokens for authentication (Using the *Bearer* scheme)
	JWT string `json:"jwt,omitempty"`

	// Basic authentication
	Username string `json:"username"`
	Password string `json:"password"`

	// time limit for requests made by the http client
	Timeout string `json:"timeout,omitempty"`

	// Maximum amount of time an idle (keep-alive) connection will remain idle before closing itself
	// should be larger than the measurement interval to keep the connection open
	IdleConnTimeout string `json:"idle_connection_timeout,omitempty"`

	// Batch all writes arriving in during this duration
	// (default '5s', batching can be disabled by setting it to 0)
	FlushDelay string `json:"flush_delay,omitempty"`

	// Maximum number of retries to connect to the http server (default: 3)
	MaxRetries int `json:"max_retries,omitempty"`

	// Timestamp precision
	Precision string `json:"precision,omitempty"`
	// contains filtered or unexported fields
}

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

type InfluxAsyncSinkConfig struct {
	Host         string `json:"host,omitempty"`
	Port         string `json:"port,omitempty"`
	Database     string `json:"database,omitempty"`
	User         string `json:"user,omitempty"`
	Password     string `json:"password,omitempty"`
	Organization string `json:"organization,omitempty"`
	SSL          bool   `json:"ssl,omitempty"`
	// Maximum number of points sent to server in single request. Default 5000
	BatchSize uint `json:"batch_size,omitempty"`
	// Interval, in ms, in which is buffer flushed if it has not been already written (by reaching batch size) . Default 1000ms
	FlushInterval         uint   `json:"flush_interval,omitempty"`
	InfluxRetryInterval   string `json:"retry_interval,omitempty"`
	InfluxExponentialBase uint   `json:"retry_exponential_base,omitempty"`
	InfluxMaxRetries      uint   `json:"max_retries,omitempty"`
	InfluxMaxRetryTime    string `json:"max_retry_time,omitempty"`
	CustomFlushInterval   string `json:"custom_flush_interval,omitempty"`
	MaxRetryAttempts      uint   `json:"max_retry_attempts,omitempty"`
	// Timestamp precision
	Precision string `json:"precision,omitempty"`
	// contains filtered or unexported fields
}

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

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

type LibgangliaSinkConfig struct {
	GangliaLib      string `json:"libganglia_path,omitempty"`
	GmondConfig     string `json:"gmond_config,omitempty"`
	AddGangliaGroup bool   `json:"add_ganglia_group,omitempty"`
	AddTypeToName   bool   `json:"add_type_to_name,omitempty"`
	AddUnits        bool   `json:"add_units,omitempty"`
	ClusterName     string `json:"cluster_name,omitempty"`
	// contains filtered or unexported fields
}

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

type NatsSinkConfig struct {
	Host       string `json:"host,omitempty"`
	Port       string `json:"port,omitempty"`
	Subject    string `json:"subject,omitempty"`
	User       string `json:"user,omitempty"`
	Password   string `json:"password,omitempty"`
	FlushDelay string `json:"flush_delay,omitempty"`

	NkeyFile string `json:"nkey_file,omitempty"`
	// Timestamp precision
	Precision string `json:"precision,omitempty"`
	// contains filtered or unexported fields
}

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

type PrometheusSinkConfig struct {
	Host             string `json:"host,omitempty"`
	Port             string `json:"port"`
	Path             string `json:"path,omitempty"`
	GroupAsNameSpace bool   `json:"group_as_namespace,omitempty"`
	// contains filtered or unexported fields
}

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

type QuestDBSinkConfig struct {

	// Address to connect to. Should be in the "host:port" format
	Address string `json:"address,omitempty"`
	// Authentication options for QuestDB:
	// Basic authentication with username and password
	Username string `json:"username,omitempty"`
	Password string `json:"password,omitempty"`
	// Authentication with bearer token in HTTP header
	BearerToken string `json:"bearer_token,omitempty"`
	// Auto flush configuration
	// Interval at which the sender automatically flushes its buffer
	AutoFlushInterval string `json:"auto_flush_interval,omitempty"`
	// Number of rows after which the sender automatically flushes its buffer
	AutoFlushRows int `json:"auto_flush_rows,omitempty"`
	// Enable TLS for secure connections
	UseTLS bool `json:"use_tls,omitempty"`
	// contains filtered or unexported fields
}

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

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

type Sink interface {
	Write(point lp.CCMessage) error // Write metric to the sink
	Flush() error                   // Flush buffered metrics
	Close()                         // Close / finish metric sink
	Name() string                   // Name of the metric sink
}

type SinkManager interface {
	Init(wg *sync.WaitGroup, sinkConfig json.RawMessage) error
	AddInput(input chan lp.CCMessage)
	AddOutput(name string, config json.RawMessage) error
	Start()
	Close()
}

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