nats_input

Documentation

Index

• type Config
• type NatsInput
  • func (n *NatsInput) Close() error
  • func (n *NatsInput) Dial(network, address string) (net.Conn, error)
  • func (n *NatsInput) SetEventProcessors(ps map[string]map[string]interface{}, logger *log.Logger, ...)
  • func (n *NatsInput) SetLogger(logger *log.Logger)
  • func (n *NatsInput) SetName(name string)
  • func (n *NatsInput) SetOutputs(outs map[string]outputs.Output)
  • func (n *NatsInput) Start(ctx context.Context, name string, cfg map[string]interface{}, ...) error

Types

type Config

type Config struct {
	Name            string        `mapstructure:"name,omitempty"`
	Address         string        `mapstructure:"address,omitempty"`
	Subject         string        `mapstructure:"subject,omitempty"`
	Queue           string        `mapstructure:"queue,omitempty"`
	Username        string        `mapstructure:"username,omitempty"`
	Password        string        `mapstructure:"password,omitempty"`
	ConnectTimeWait time.Duration `mapstructure:"connect-time-wait,omitempty"`
	Format          string        `mapstructure:"format,omitempty"`
	Debug           bool          `mapstructure:"debug,omitempty"`
	NumWorkers      int           `mapstructure:"num-workers,omitempty"`
	BufferSize      int           `mapstructure:"buffer-size,omitempty"`
	Outputs         []string      `mapstructure:"outputs,omitempty"`
	EventProcessors []string      `mapstructure:"event-processors,omitempty"`
}

Config //

type NatsInput

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

NatsInput //

func (*NatsInput) Close

func (n *NatsInput) Close() error

Close //

func (*NatsInput) Dial

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

Dial //

func (*NatsInput) SetEventProcessors

func (n *NatsInput) SetEventProcessors(ps map[string]map[string]interface{}, logger *log.Logger, tcs map[string]*types.TargetConfig)

func (*NatsInput) SetLogger

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

SetLogger //

func (*NatsInput) SetName

func (n *NatsInput) SetName(name string)

func (*NatsInput) SetOutputs

func (n *NatsInput) SetOutputs(outs map[string]outputs.Output)

SetOutputs //

func (*NatsInput) Start

func (n *NatsInput) Start(ctx context.Context, name string, cfg map[string]interface{}, opts ...inputs.Option) error

Init //