datasink

Documentation

Index

• func NewFile(fs afero.Fs, conf FileConfig) core.DataSink
• func NewStderr() core.DataSink
• func NewStdout() core.DataSink
• type Buffer
  • func NewBuffer() *Buffer
  • func (b *Buffer) OpenSink() (wc io.WriteCloser, err error)
• type FileConfig

Functions

func NewFile

func NewFile(fs afero.Fs, conf FileConfig) core.DataSink

func NewStderr

func NewStderr() core.DataSink

func NewStdout

func NewStdout() core.DataSink

Types

type Buffer

type Buffer struct {
	bytes.Buffer
	ioutil2.NopCloser
}

func NewBuffer

func NewBuffer() *Buffer

func (*Buffer) OpenSink

func (b *Buffer) OpenSink() (wc io.WriteCloser, err error)

type FileConfig

type FileConfig struct {
	Path string `config:"path" validate:"required"`
}