Versions in this module Expand all Collapse all v1 v1.0.0 Dec 19, 2023 Changes in this version + var ErrTimePointNotIncluded = errors.New("time point not included in this data file") + type ExportOptions struct + Bar *progressbar.ProgressBar + Bucket string + DbAddress string + Hostname string + Org string + ShowOnly bool + Target time.Time + Token string + WriteDb bool + type FastExporter struct + func NewFastExporter(f string, fs afero.Fs) (*FastExporter, error) + func (r *FastExporter) Close() + func (r *FastExporter) Export(w io.Writer, option *ExportOptions) error + func (r *FastExporter) ReadAt(offset int64, len uint32) ([]byte, error) + func (r *FastExporter) ReadRange(ra Range) ([]byte, error) + func (r *FastExporter) Scan() ([]RecordRange, error) + func (r *FastExporter) UnmarshalMetric(buf []byte) (*gproto.Metric, error) + type ImportOption struct + Address string + Bucket string + Hostname string + Org string + Token string + type Importer struct + func NewImporter(option *ImportOption) *Importer + func (im *Importer) Close() + func (im *Importer) Submit(metric *gproto.Metric) error + type LineProtocolExporter struct + func New(hostname string, writer io.Writer) *LineProtocolExporter + func (e *LineProtocolExporter) ExportMetric(m *gproto.Metric) + func (e *LineProtocolExporter) Printf(format string, a ...any) + type MetricConv struct + Hostname string + func NewMetricConv(hostname string) *MetricConv + func (c *MetricConv) Metric(metric *gproto.Metric) (int64, []*write.Point) + func (c *MetricConv) Net(metric *gproto.NetstatMetric) []*write.Point + func (c *MetricConv) Nic(metric *gproto.NicMetric) []*write.Point + func (c *MetricConv) Tcp(metric *gproto.TcpMetric) []*write.Point + type Range struct + Len uint32 + Offset int64 + type RecordRange struct + Body Range + Header Range