ClusterCockpit/cc-metric-collector
1
0
Fork 0
mirror of https://github.com/ClusterCockpit/cc-metric-collector.git synced 2024-12-26 07:29:04 +01:00
Code Issues Packages Projects Releases Wiki Activity

Additional comments

Browse Source
This commit is contained in:
Holger Obermaier 2022-02-28 09:39:59 +01:00
parent a203370aaa
commit a2f9b23e85
1 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
sinks/sampleSink.go
View File

@ -10,15 +10,22 @@ import (
) )
type SampleSinkConfig struct { type SampleSinkConfig struct {
defaultSinkConfig // defines JSON tags for 'type' and 'meta_as_tags' // defines JSON tags for 'type' and 'meta_as_tags'
// Add additional options // See: metricSink.go
defaultSinkConfig
// Additional config options, for SampleSink
} }
type SampleSink struct { type SampleSink struct {
sink // declarate 'name' and 'meta_as_tags' // declares elements 'name' and 'meta_as_tags'
sink
config SampleSinkConfig // entry point to the SampleSinkConfig config SampleSinkConfig // entry point to the SampleSinkConfig
} }
// Implement functions required for Sink interface
// Write(...), Flush(), Close()
// See: metricSink.go
// Code to submit a single CCMetric to the sink // Code to submit a single CCMetric to the sink
func (s *SampleSink) Write(point lp.CCMetric) error { func (s *SampleSink) Write(point lp.CCMetric) error {
log.Print(point) log.Print(point)
@ -42,6 +49,7 @@ func NewSampleSink(name string, config json.RawMessage) (Sink, error) {
s.name = fmt.Sprintf("SampleSink(%s)", name) // Always specify a name here s.name = fmt.Sprintf("SampleSink(%s)", name) // Always specify a name here
// Set defaults in s.config // Set defaults in s.config
// Allow overwriting these defaults by reading config JSON
// Read in the config JSON // Read in the config JSON
if len(config) > 0 { if len(config) > 0 {
@ -52,7 +60,7 @@ func NewSampleSink(name string, config json.RawMessage) (Sink, error) {
} }
// Check if all required fields in the config are set // Check if all required fields in the config are set
// Use 'len(s.config.Option) > 0' for string settings // E.g. use 'len(s.config.Option) > 0' for string settings
// Establish connection to the server, library, ... // Establish connection to the server, library, ...
// Check required files exist and lookup path(s) of executable(s) // Check required files exist and lookup path(s) of executable(s)