kubernetes-event-exporter/pkg/sinks/syslog.go

package sinks

import (
	"context"
	"encoding/json"
	"github.com/opsgenie/kubernetes-event-exporter/pkg/kube"
	"log/syslog"
)

type SyslogConfig struct {
	Network string `yaml:"network"`
	Address string `yaml:"address"`
	Tag     string `yaml:"tag"`
}

type SyslogSink struct {
	sw *syslog.Writer
}

func NewSyslogSink(config *SyslogConfig) (Sink, error) {
	w, err := syslog.Dial(config.Network, config.Address, syslog.LOG_LOCAL0, config.Tag)
	if err != nil {
		return nil, err
	}
	return &SyslogSink{sw: w}, nil
}

func (w *SyslogSink) Close() {
	w.sw.Close()
}

func (w *SyslogSink) Send(ctx context.Context, ev *kube.EnhancedEvent) error {

	if b, err := json.Marshal(ev); err == nil {
		_, writeErr := w.sw.Write(b)

		if writeErr != nil {
			return writeErr
		}
	} else {
		return err
	}
	return nil
}