flatjsonl

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

type Config struct {
	MatchLinePrefix    string             `json:"matchLinePrefix" yaml:"matchLinePrefix"`
	IncludeKeys        []string           `json:"includeKeys" yaml:"includeKeys"`
	IncludeKeysRegex   []string           `json:"includeKeysRegex" yaml:"includeKeysRegex"`
	ExcludeKeys        []string           `json:"excludeKeys" yaml:"excludeKeys" description:"List of keys remove from columns."`
	ReplaceKeys        map[string]string  `json:"replaceKeys" yaml:"replaceKeys"`
	ReplaceKeysRegex   map[string]string  `json:"replaceKeysRegex" yaml:"replaceKeysRegex"`
	ParseTime          map[string]string  `json:"parseTime" yaml:"parseTime" description:"Map of key to time format, RAW format means no processing of original value."`
	OutputTimeFormat   string             `` /* 140-byte string literal not displayed */
	OutputTimezone     string             `json:"outputTZ" yaml:"outputTZ" example:"UTC"`
	ConcatDelimiter    *string            `` /* 152-byte string literal not displayed */
	Transpose          map[string]string  `json:"transpose" yaml:"transpose" description:"Map of key prefixes to transposed table names."`
	ExtractValuesRegex map[string]extract `` /* 133-byte string literal not displayed */
}

type FastWalker struct {
	// These callbacks are invoked during JSON traversal.
	// Common arguments:
	// * seq is a sequence number of parent line,
	// * flatPath is a dot-separated path to the current element,
	// * parserPool is a length of parent prefix in flatPath,
	// * path holds a list of segments, it is nil if WantPath is false.
	FnNumber func(seq int64, flatPath []byte, path []string, value float64, raw []byte)
	FnString func(seq int64, flatPath []byte, path []string, value []byte) extractor
	FnBool   func(seq int64, flatPath []byte, path []string, value bool)
	FnNull   func(seq int64, flatPath []byte, path []string)

	WantPath       bool
	ExtractStrings bool
	// contains filtered or unexported fields
}

type Flags struct {
	Verbosity        int
	ProgressInterval time.Duration
	Input            string
	Output           string

	CSV string

	SQLite     string
	SQLMaxCols int
	SQLTable   string

	PGDump string

	Raw      string
	RawDelim string

	MaxLines     int
	OffsetLines  int
	MaxLinesKeys int
	FieldLimit   int
	KeyLimit     int
	BufSize      int

	Config            string
	GetKey            string
	ReplaceKeys       bool
	ExtractStrings    bool
	SkipZeroCols      bool
	AddSequence       bool
	MatchLinePrefix   string
	CaseSensitiveKeys bool

	ShowKeysFlat bool
	ShowKeysHier bool
	ShowKeysInfo bool

	Concurrency int
	MemLimit    int
}

type Input struct {
	FileName string
	Reader   interface {
		io.Reader
		Size() int64
		Reset()
		Compression() string
	}
}

type KeyHierarchy struct {
	Name string
	Sub  map[string]KeyHierarchy
}

type LoopReader struct {
	BytesLimit int
	// contains filtered or unexported fields
}

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

type Processor struct {
	Log    func(args ...any)
	Stdout io.Writer
	// contains filtered or unexported fields
}

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

type Reader struct {
	AddSequence bool
	MaxLines    int64
	OffsetLines int64
	OnError     func(err error)
	Progress    *progress.Progress
	Buf         []byte
	Concurrency int
	Processor   *Processor

	Sequence int64

	MatchPrefix    *regexp.Regexp
	ExtractStrings bool
	// contains filtered or unexported fields
}

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

type Type string

type URL struct {
	Scheme   string     `json:"scheme,omitempty"`
	User     string     `json:"user,omitempty"`
	Pass     string     `json:"pass,omitempty"`
	Host     string     `json:"host,omitempty"`
	Port     string     `json:"port,omitempty"`
	Query    url.Values `json:"query,omitempty"`
	Path     []string   `json:"path,omitempty"`
	Fragment string     `json:"fragment,omitempty"`
}

type Value struct {
	Dst       string
	Type      Type
	String    string
	Number    float64
	RawNumber string
	Bool      bool
}

type WriteReceiver interface {
	SetupKeys(keys []flKey) error
	ReceiveRow(seq int64, values []Value) error
	Close() error
}

type Writer struct {
	Progress *progress.Progress
	// contains filtered or unexported fields
}