nats_output

Documentation

Index

• Variables
• type Config
• type NatsOutput
  • func (n *NatsOutput) Close() error
  • func (n *NatsOutput) Dial(network, address string) (net.Conn, error)
  • func (n *NatsOutput) Init(ctx context.Context, name string, cfg map[string]interface{}, ...) error
  • func (n *NatsOutput) RegisterMetrics(reg *prometheus.Registry)
  • func (n *NatsOutput) SetClusterName(name string)
  • func (n *NatsOutput) SetEventProcessors(ps map[string]map[string]interface{}, logger *log.Logger)
  • func (n *NatsOutput) SetLogger(logger *log.Logger)
  • func (n *NatsOutput) SetName(name string)
  • func (n *NatsOutput) String() string
  • func (n *NatsOutput) Write(ctx context.Context, rsp proto.Message, meta outputs.Meta)
  • func (n *NatsOutput) WriteEvent(ctx context.Context, ev *formatters.EventMsg)

Variables

var NatsNumberOfFailSendMsgs = prometheus.NewCounterVec(prometheus.CounterOpts{
	Namespace: "gnmic",
	Subsystem: "nats_output",
	Name:      "number_of_nats_msgs_sent_fail_total",
	Help:      "Number of failed msgs sent by gnmic nats output",
}, []string{"publisher_id", "reason"})

var NatsNumberOfSentBytes = prometheus.NewCounterVec(prometheus.CounterOpts{
	Namespace: "gnmic",
	Subsystem: "nats_output",
	Name:      "number_of_written_nats_bytes_total",
	Help:      "Number of bytes written by gnmic nats output",
}, []string{"publisher_id", "subject"})

var NatsNumberOfSentMsgs = prometheus.NewCounterVec(prometheus.CounterOpts{
	Namespace: "gnmic",
	Subsystem: "nats_output",
	Name:      "number_of_nats_msgs_sent_success_total",
	Help:      "Number of msgs successfully sent by gnmic nats output",
}, []string{"publisher_id", "subject"})

var NatsSendDuration = prometheus.NewGaugeVec(prometheus.GaugeOpts{
	Namespace: "gnmic",
	Subsystem: "nats_output",
	Name:      "msg_send_duration_ns",
	Help:      "gnmic nats output send duration in ns",
}, []string{"publisher_id"})

Types

type Config

type Config struct {
	Name            string        `mapstructure:"name,omitempty"`
	Address         string        `mapstructure:"address,omitempty"`
	SubjectPrefix   string        `mapstructure:"subject-prefix,omitempty"`
	Subject         string        `mapstructure:"subject,omitempty"`
	Username        string        `mapstructure:"username,omitempty"`
	Password        string        `mapstructure:"password,omitempty"`
	ConnectTimeWait time.Duration `mapstructure:"connect-time-wait,omitempty"`
	Format          string        `mapstructure:"format,omitempty"`
	NumWorkers      int           `mapstructure:"num-workers,omitempty"`
	WriteTimeout    time.Duration `mapstructure:"write-timeout,omitempty"`
	Debug           bool          `mapstructure:"debug,omitempty"`
	EnableMetrics   bool          `mapstructure:"enable-metrics,omitempty"`
	EventProcessors []string      `mapstructure:"event-processors,omitempty"`
}

Config //

type NatsOutput

type NatsOutput struct {
	Cfg *Config
	// contains filtered or unexported fields
}

NatsOutput //

func (*NatsOutput) Close

func (n *NatsOutput) Close() error

Close //

func (*NatsOutput) Dial

func (n *NatsOutput) Dial(network, address string) (net.Conn, error)

Dial //

func (*NatsOutput) Init

func (n *NatsOutput) Init(ctx context.Context, name string, cfg map[string]interface{}, opts ...outputs.Option) error

Init //

func (*NatsOutput) RegisterMetrics

func (n *NatsOutput) RegisterMetrics(reg *prometheus.Registry)

Metrics //

func (*NatsOutput) SetClusterName

func (n *NatsOutput) SetClusterName(name string)

func (*NatsOutput) SetEventProcessors

func (n *NatsOutput) SetEventProcessors(ps map[string]map[string]interface{}, logger *log.Logger)

func (*NatsOutput) SetLogger

func (n *NatsOutput) SetLogger(logger *log.Logger)

func (*NatsOutput) SetName

func (n *NatsOutput) SetName(name string)

func (*NatsOutput) String

func (n *NatsOutput) String() string

func (*NatsOutput) Write

func (n *NatsOutput) Write(ctx context.Context, rsp proto.Message, meta outputs.Meta)

Write //

func (*NatsOutput) WriteEvent

func (n *NatsOutput) WriteEvent(ctx context.Context, ev *formatters.EventMsg)