pipeline

package
v0.17.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 27, 2021 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Config

type Config struct {
}

type OutputFactory

type OutputFactory func() (string, outputs.Group, error)

type Pipeline

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

func Load

func Load(
	consumerInfo consumer.Info,
	logger *logp.Logger,
	config Config,
	makeOutput OutputFactory,
) (*Pipeline, error)

func New

func New(
	consumerInfo consumer.Info,
	logger *logp.Logger,
	out outputs.Group,
) (*Pipeline, error)

func (*Pipeline) Close

func (p *Pipeline) Close() error

func (*Pipeline) Connect

func (p *Pipeline) Connect() (consumer.Client, error)

func (*Pipeline) ConnectWith

func (p *Pipeline) ConnectWith(cfg consumer.ClientConfig) (consumer.Client, error)

func (*Pipeline) HandleMessage

func (p *Pipeline) HandleMessage(m consumer.Message) error

Jump to

Keyboard shortcuts

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