Versions in this module Expand all Collapse all v0 v0.0.1 Jan 22, 2026 Changes in this version + const TypeField + const TypeTimestamp + var FSMCallEmpty = func(ctx context.Context, command *ImportCommand) error + var MpbProgress = mpb.New(mpb.WithWidth(100)) + var ProgressedFilesPath string + var ResumeJsonPath string + func CreateNewProgressFolder() error + func EscapeFieldKey(in string) string + func EscapeMstName(in string) string + func EscapeStringFieldValue(in string) string + func EscapeTagKey(in string) string + func EscapeTagValue(in string) string + func NewColumnWriterClient(cfg *ImportConfig) (proto.WriteServiceClient, error) + func ReadLatestProgressFile() error + type DatabaseDiskInfo struct + type ExportCommand struct + func (c *ExportCommand) Run(config *ExportConfig) error + type ExportConfig struct + Compress bool + DBFilter string + DataDir string + Export bool + Format string + MeasurementFilter string + Out string + Remote string + RemotePassword string + RemoteSsl bool + RemoteUsername string + Resume bool + RetentionFilter string + TimeFilter string + WalDir string + type Exporter struct + Stderr io.Writer + Stdout io.Writer + func NewExporter() *Exporter + type FSMCall func(ctx context.Context, command *ImportCommand) error + type FieldPos struct + Name string + Pos int + type ImportCommand struct + func (c *ImportCommand) Run(config *ImportConfig) error + type ImportConfig struct + BatchSize int + ColumnWrite bool + ColumnWritePort int + Fields []string + Format string + Path string + Tags []string + TimeField string + type ImportFileFSM struct + type ImportState int + type InfoType int + const InfoTypeDatabase + const InfoTypeMeasurement + const InfoTypeRetentionPolicy + type JsonIResult struct + Fields []string + Measurement string + Tags map[string]string + Values [][]any + type JsonPResult struct + Metric map[string]string + Value [2]any + Values [][2]any + type OnlineExporter struct + func NewOnlineExporter(baseExporter *Exporter) *OnlineExporter + func (oe *OnlineExporter) Export(ctx context.Context, config *ExportConfig, progressedFiles map[string]struct{}) error + type TimeWindow struct + End time.Time + FilePath string + Start time.Time
Go to main page