node

Documentation

Index

• type Input
  • func NewInput(cfg configinput.Input, logger *zerolog.Logger, opts ...Option) (*Input, error)
  • func (i *Input) AddOutputChannel(ch chan any)
  • func (i *Input) GetName() string
  • func (i *Input) GetOutputBufferSize() int
  • func (i *Input) Run(ctx context.Context) error
• type Option
  • func WithCallGC() Option
  • func WithMetrics() Option
• type Sink
  • func NewSink(cfg configsink.Sink, logger *zerolog.Logger, opts ...Option) (*Sink, error)
  • func (s *Sink) AddInputChannel(inputChannel chan any)
  • func (s *Sink) GetInputs() []string
  • func (s *Sink) Run() error
• type Transform
  • func NewTransform(cfg configtransform.Transform, logger *zerolog.Logger, opts ...Option) (*Transform, error)
  • func (t *Transform) AddInputChannel(ch chan any)
  • func (t *Transform) AddOutputChannel(ch chan any)
  • func (t *Transform) GetInputs() []string
  • func (t *Transform) GetName() string
  • func (t *Transform) GetOutputBufferSize() int
  • func (t *Transform) Run() error
• type Type

Types

type Input

type Input struct {
	// contains filtered or unexported fields
}

func NewInput

func NewInput(cfg configinput.Input, logger *zerolog.Logger, opts ...Option) (*Input, error)

func (*Input) AddOutputChannel

func (i *Input) AddOutputChannel(ch chan any)

func (*Input) GetName

func (i *Input) GetName() string

func (*Input) GetOutputBufferSize

func (i *Input) GetOutputBufferSize() int

func (*Input) Run

func (i *Input) Run(ctx context.Context) error

type Option

type Option func(*nodeCfg)

func WithCallGC

func WithCallGC() Option

func WithMetrics

func WithMetrics() Option

type Sink

type Sink struct {
	// contains filtered or unexported fields
}

func NewSink

func NewSink(
	cfg configsink.Sink,
	logger *zerolog.Logger,
	opts ...Option,
) (*Sink, error)

func (*Sink) AddInputChannel

func (s *Sink) AddInputChannel(inputChannel chan any)

func (*Sink) GetInputs

func (s *Sink) GetInputs() []string

func (*Sink) Run

func (s *Sink) Run() error

type Transform

type Transform struct {
	// contains filtered or unexported fields
}

func NewTransform

func NewTransform(
	cfg configtransform.Transform,
	logger *zerolog.Logger,
	opts ...Option,
) (*Transform, error)

func (*Transform) AddInputChannel

func (t *Transform) AddInputChannel(ch chan any)

func (*Transform) AddOutputChannel

func (t *Transform) AddOutputChannel(ch chan any)

func (*Transform) GetInputs

func (t *Transform) GetInputs() []string

func (*Transform) GetName

func (t *Transform) GetName() string

func (*Transform) GetOutputBufferSize

func (t *Transform) GetOutputBufferSize() int

func (*Transform) Run

func (t *Transform) Run() error

Run non-blocking call that start Transform node action in separated goroutine.

type Type

type Type string