node

package

v1.3.4 Latest Latest Go to latest Published: Nov 13, 2025 License: Apache-2.0 Imports: 16 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/pipelane/pipelaner

Links

Open Source Insights

Documentation ¶

Index ¶

type AtomicData
type AtomicMessage
- func NewAtomicMessage(data any, success chan<- AtomicData, errors chan<- AtomicData) AtomicMessage
type Input
- func NewInput(cfg configinput.Input, logger *zerolog.Logger, opts ...Option) (*Input, error)
type Option
- func WithCallGC() Option
- func WithMetrics() Option
type Sequencer
- func NewSequencer(cfg configtransform.Transform, logger *zerolog.Logger, opts ...Option) (*Sequencer, error)
type Sink
- func NewSink(cfg configsink.Sink, logger *zerolog.Logger, opts ...Option) (*Sink, error)
type Transform
- func NewTransform(cfg configtransform.Transform, logger *zerolog.Logger, opts ...Option) (*Transform, error)
type Type

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type AtomicData ¶ added in v1.3.0

type AtomicData interface {
	Success() chan<- AtomicData
	Error() chan<- AtomicData
	Data() any
	ID() string
	UpdateData(data any) AtomicData
}

type AtomicMessage ¶ added in v1.3.0

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

func NewAtomicMessage ¶ added in v1.3.0

func NewAtomicMessage(data any, success chan<- AtomicData, errors chan<- AtomicData) AtomicMessage

func (AtomicMessage) Data ¶ added in v1.3.0

func (m AtomicMessage) Data() any

func (AtomicMessage) Error ¶ added in v1.3.0

func (m AtomicMessage) Error() chan<- AtomicData

func (AtomicMessage) ID ¶ added in v1.3.0

func (m AtomicMessage) ID() string

func (AtomicMessage) Success ¶ added in v1.3.0

func (m AtomicMessage) Success() chan<- AtomicData

func (AtomicMessage) UpdateData ¶ added in v1.3.0

func (m AtomicMessage) UpdateData(data any) AtomicData

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() uint

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 Sequencer ¶ added in v1.2.0

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

func NewSequencer ¶ added in v1.2.0

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

func (*Sequencer) AddInputChannel ¶ added in v1.2.0

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

func (*Sequencer) AddOutputChannel ¶ added in v1.2.0

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

func (*Sequencer) GetInputs ¶ added in v1.2.0

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

func (*Sequencer) GetName ¶ added in v1.2.0

func (t *Sequencer) GetName() string

func (*Sequencer) GetOutputBufferSize ¶ added in v1.2.0

func (t *Sequencer) GetOutputBufferSize() uint

func (*Sequencer) Run ¶ added in v1.2.0

func (s *Sequencer) Run() error

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

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() uint

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL