file

Documentation

Overview

Implements a file sink, intended for testing. It's possible people may want to use this for JSON dumps of their database, but it may need extending to better suit that use-case.

Index

• func New(opts Options) (generic.Sink, error)
• type Options
  • func (opt *Options) Bind(cmd *kingpin.CmdClause, prefix string) *Options

Functions

func New

func New(opts Options) (generic.Sink, error)

Types

type Options

type Options struct {
	SchemasPath       string
	ModificationsPath string
	BufferSize        int
	Instrument        bool
	FlushInterval     time.Duration
}

func (*Options) Bind

func (opt *Options) Bind(cmd *kingpin.CmdClause, prefix string) *Options