nats_output

Documentation

Index

• 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, cfg map[string]interface{}, logger *log.Logger) error
  • func (n *NatsOutput) Metrics() []prometheus.Collector
  • func (n *NatsOutput) String() string
  • func (n *NatsOutput) Write(_ context.Context, rsp proto.Message, 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"`
	ConnectTimeWait time.Duration `mapstructure:"connect-time-wait,omitempty"`
	Format          string        `mapstructure:"format,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, cfg map[string]interface{}, logger *log.Logger) error

Init //

func (*NatsOutput) Metrics

func (n *NatsOutput) Metrics() []prometheus.Collector

Metrics //

func (*NatsOutput) String

func (n *NatsOutput) String() string

func (*NatsOutput) Write

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

Write //