Documentation
¶
Index ¶
- Constants
- Variables
- func DecodeConfig(name string, input interface{}, output interface{}) error
- func EncodeInterMetricCSV(d samplers.InterMetric, w *csv.Writer, partitionDate *time.Time, ...) error
- func EncodeInterMetricsCSV(metrics []samplers.InterMetric, delimiter rune, includeHeaders bool, ...) (io.ReadSeeker, error)
- type Regexp
- type Rune
- type StringSecret
- type Url
Constants ¶
const ( // the order in which these appear determines the // order of the fields in the resultant TSV TsvName tsvField = iota TsvTags TsvMetricType // The hostName of the server flushing the data TsvVeneurHostname TsvInterval TsvTimestamp TsvValue // This is the _partition field // required by the Redshift IncrementalLoader. // For our purposes, the current date is a good partition. TsvPartition )
const PartitionDateFormat = "20060102"
const Redacted = "REDACTED"
const RedshiftDateFormat = "2006-01-02 03:04:05"
Variables ¶
var PrintSecrets = flag.Bool( "print-secrets", false, "Disables redacting config secrets")
Functions ¶
func DecodeConfig ¶
DecodeConfig wraps the mapstructure decoder to unpack a map into a struct and the envconfig decoder to read environment variables.
This method provides logic to handle decoding into structs that implement the stringUnmarshaler interface and is intended to be used by sources and sinks while unpacking the configuration specific to that source or sink from within the entire config.
func EncodeInterMetricCSV ¶
func EncodeInterMetricCSV( d samplers.InterMetric, w *csv.Writer, partitionDate *time.Time, hostName string, interval int, ) error
EncodeInterMetricCSV generates a newline-terminated CSV row that describes the data represented by the InterMetric. The caller is responsible for setting w.Comma as the appropriate delimiter. For performance, encodeCSV does not flush after every call; the caller is expected to flush at the end of the operation cycle
func EncodeInterMetricsCSV ¶
func EncodeInterMetricsCSV( metrics []samplers.InterMetric, delimiter rune, includeHeaders bool, hostname string, interval int, ) (io.ReadSeeker, error)
EncodeInterMetricsCSV returns a reader containing the gzipped CSV representation of the InterMetric data, one row per InterMetric. the AWS sdk requires seekable input, so we return a ReadSeeker here
Types ¶
type Regexp ¶
func (Regexp) MarshalJSON ¶
func (Regexp) MarshalYAML ¶
func (*Regexp) UnmarshalYAML ¶
type StringSecret ¶
type StringSecret struct {
Value string
}
func (*StringSecret) Decode ¶
func (s *StringSecret) Decode(value string) error
implement Decode so that envconfig can read in StringSecrets
func (StringSecret) MarshalJSON ¶
func (s StringSecret) MarshalJSON() ([]byte, error)
func (StringSecret) MarshalYAML ¶
func (s StringSecret) MarshalYAML() (interface{}, error)
func (StringSecret) String ¶
func (s StringSecret) String() string
func (*StringSecret) UnmarshalYAML ¶
func (s *StringSecret) UnmarshalYAML(unmarshal func(interface{}) error) error
Source Files
Directories