stan_output

Nov 12, 2023

Changes in this version

+ var StanNumberOfFailSendMsgs = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var StanNumberOfSentBytes = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var StanNumberOfSentMsgs = prometheus.NewCounterVec(prometheus.CounterOpts{ ... }, []string{ ... })

+ var StanSendDuration = prometheus.NewGaugeVec(prometheus.GaugeOpts{ ... }, []string{ ... })

+ type Config struct

+ AddTarget string

+ Address string

+ ClusterName string

+ Debug bool

+ EnableMetrics bool

+ EventProcessors []string

+ Format string

+ Name string

+ NumWorkers int

+ OverrideTimestamps bool

+ Password string

+ PingInterval int

+ PingRetry int

+ RecoveryWaitTime time.Duration

+ Subject string

+ SubjectPrefix string

+ TargetTemplate string

+ Username string

+ WriteTimeout time.Duration

+ type StanOutput struct

+ Cfg *Config

+ func (s *StanOutput) Close() error

+ func (s *StanOutput) Init(ctx context.Context, name string, cfg map[string]interface{}, ...) error

+ func (s *StanOutput) RegisterMetrics(reg *prometheus.Registry)

+ func (s *StanOutput) SetClusterName(name string)

+ func (s *StanOutput) SetEventProcessors(ps map[string]map[string]interface{}, logger *log.Logger, ...) error

+ func (s *StanOutput) SetLogger(logger *log.Logger)

+ func (s *StanOutput) SetName(name string)

+ func (s *StanOutput) SetTargetsConfig(map[string]*types.TargetConfig)

+ func (s *StanOutput) String() string

+ func (s *StanOutput) Write(ctx context.Context, rsp protoreflect.ProtoMessage, meta outputs.Meta)

+ func (s *StanOutput) WriteEvent(ctx context.Context, ev *formatters.EventMsg)