io

Documentation

Index

• func NewReaderFactory() component.Factory
• func NewWriterFactory() component.Factory
• func NopCloser(w io.Writer) io.WriteCloser
• type Reader
  • func NewReader(rawConfig string) (*Reader, error)
  • func (r *Reader) Instance() component.Instance
  • func (r *Reader) Start() error
  • func (r *Reader) Stop() error
• type ReaderConfig
  • func (c ReaderConfig) Marshal() ([]byte, error)
• type Writer
  • func NewWriter(rawConfig string) (*Writer, error)
  • func (w *Writer) Instance() component.Instance
  • func (w *Writer) Start() error
  • func (w *Writer) Stop() error
• type WriterConfig
  • func (c WriterConfig) Marshal() ([]byte, error)

Functions

func NewReaderFactory

func NewReaderFactory() component.Factory

func NewWriterFactory

func NewWriterFactory() component.Factory

func NopCloser

func NopCloser(w io.Writer) io.WriteCloser

Types

type Reader

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

func NewReader

func NewReader(rawConfig string) (*Reader, error)

func (*Reader) Instance

func (r *Reader) Instance() component.Instance

func (*Reader) Start

func (r *Reader) Start() error

func (*Reader) Stop

func (r *Reader) Stop() error

type ReaderConfig

type ReaderConfig struct {
	Name string
	Path string
}

func (ReaderConfig) Marshal

func (c ReaderConfig) Marshal() ([]byte, error)

type Writer

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

func NewWriter

func NewWriter(rawConfig string) (*Writer, error)

func (*Writer) Instance

func (w *Writer) Instance() component.Instance

func (*Writer) Start

func (w *Writer) Start() error

func (*Writer) Stop

func (w *Writer) Stop() error

type WriterConfig

type WriterConfig struct {
	Name string
	Path string
}

func (WriterConfig) Marshal

func (c WriterConfig) Marshal() ([]byte, error)