stan_output

Documentation

Index

• type Config
• type StanOutput
  • func (s *StanOutput) Close() error
  • func (s *StanOutput) Init(cfg map[string]interface{}, logger *log.Logger) error
  • func (s *StanOutput) Metrics() []prometheus.Collector
  • func (s *StanOutput) String() string
  • func (s *StanOutput) Write(rsp protoreflect.ProtoMessage, meta outputs.Meta)

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"`
	ClusterName   string `mapstructure:"cluster-name,omitempty"`
	Timeout       int    `mapstructure:"timeout,omitempty"`
	PingInterval  int    `mapstructure:"ping-interval,omitempty"`
	PingRetry     int    `mapstructure:"ping-retry,omitempty"`
	Format        string `mapstructure:"format,omitempty"`
}

Config //

type StanOutput

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

StanOutput //

func (*StanOutput) Close

func (s *StanOutput) Close() error

Close //

func (*StanOutput) Init

func (s *StanOutput) Init(cfg map[string]interface{}, logger *log.Logger) error

Init //

func (*StanOutput) Metrics

func (s *StanOutput) Metrics() []prometheus.Collector

Metrics //

func (*StanOutput) String

func (s *StanOutput) String() string

func (*StanOutput) Write

func (s *StanOutput) Write(rsp protoreflect.ProtoMessage, meta outputs.Meta)

Write //