namedpipe

Documentation

Index

• Constants
• type Callback
• type NamedPipeIngester
  • func NewNamedPipeIngester(logger *zap.SugaredLogger, h *health.Health) NamedPipeIngester
  • func (n *NamedPipeIngester) Ingest(ctx context.Context, filePath string, delim byte, callback Callback) error

Constants

const (
	// NamedPipeProcessorComponentName is the name of the component
	// that reads from a named pipe. This is used in the health check.
	NamedPipeProcessorComponentName = "named-pipe-processor"
)

Types

type Callback

type Callback func(context.Context, string) error

type NamedPipeIngester

type NamedPipeIngester struct {
	Logger *zap.SugaredLogger
	Health *health.Health
}

func NewNamedPipeIngester

func NewNamedPipeIngester(logger *zap.SugaredLogger, h *health.Health) NamedPipeIngester

func (*NamedPipeIngester) Ingest

func (n *NamedPipeIngester) Ingest(
	ctx context.Context,
	filePath string,
	delim byte,
	callback Callback,
) error