output

type DynamoDB struct {
	TableName string
	Fields    []baker.FieldIndex
	Columns   []string
	Cfg       *DynamoDBConfig
	// contains filtered or unexported fields
}

type DynamoDBConfig struct {
	Regions         []string      `help:"DynamoDB regions to connect to" default:"us-west-2"`
	Table           string        `help:"Name of the table to modify" required:"true"`
	Columns         []string      `help:"Table columns that correspond to each of the fields being written"`
	FlushInterval   time.Duration `help:"Interval at which flush the data to DynamoDB even if we have not reached 25 records" default:"1s"`
	MaxWritesPerSec int64         `help:"Maximum number of writes per second that DynamoDB can accept (0 for unlimited)" default:"0"`
	MaxBackoff      time.Duration `help:"Maximum retry/backoff time in case of errors before giving up" default:"2m"`
	// contains filtered or unexported fields
}

type FileWriter struct {
	Cfg *FileWriterConfig

	Fields []baker.FieldIndex
	// contains filtered or unexported fields
}

type FileWriterConfig struct {
	PathString           string        `` /* 182-byte string literal not displayed */
	RotateInterval       time.Duration `help:"Time after which data will be rotated. If -1, it will not rotate until the end." default:"60s"`
	ZstdCompressionLevel int           `help:"zstd compression level, ranging from 1 (best speed) to 19 (best compression)." default:"3"`
	ZstdWindowLog        int           `` /* 183-byte string literal not displayed */
}

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

type NopConfig struct{}

type OpLog struct {
	Cfg *OpLogConfig

	Fields []baker.FieldIndex
	// contains filtered or unexported fields
}

type OpLogConfig struct{}

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

type SQLiteConfig struct {
	PathString string   `` /* 167-byte string literal not displayed */
	TableName  string   `help:"Table name to which to write the records to." required:"true"`
	PreRun     []string `help:"List of SQL statements to run at startup (before table creation)."`
	PostRun    []string `help:"List of SQL statements to run at exit. (good place to create indexes if needed)."`
	Clear      bool     `` /* 233-byte string literal not displayed */
	Vacuum     bool     `` /* 259-byte string literal not displayed */
	Wal        bool     `` /* 167-byte string literal not displayed */
	PageSize   int64    `help:"The page size to use for SQLite. By default, we use whatever SQLite decides to use as default."`
}

type SQLiteRawWriterConfig struct {
	PathString     string   `` /* 167-byte string literal not displayed */
	TableName      string   `help:"Table name to which to write the records to." required:"true"`
	PreRun         []string `help:"List of SQL statements to run at startup (before table creation)."`
	PostRun        []string `help:"List of SQL statements to run at exit. (good place to create indexes if needed)."`
	Clear          bool     `` /* 233-byte string literal not displayed */
	Vacuum         bool     `` /* 259-byte string literal not displayed */
	Wal            bool     `` /* 167-byte string literal not displayed */
	PageSize       int64    `help:"The page size to use for SQLite. By default, we use whatever SQLite decides to use as default."`
	RecordBlobName string   `help:"Name of the column in which the whole raw record should be put." required:"true"`
}

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

type StatsConfig struct {
	CountEmptyFields bool   `help:"Whether fields with empty values are counted or not" default:"false"`
	CSVPath          string `help:"Path of the CSV file to create" default:"stats.csv"`
	TimestampField   string `help:"Name of a field containing a POSIX timestamp (in seconds) used to build the times stats" required:"true"`
}

type WebSocket struct {
	Cfg *WebSocketConfig

	Fields []baker.FieldIndex
	// contains filtered or unexported fields
}

type WebSocketConfig struct{}