Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

timeseries

package

Go to main page

Versions in this module

v0

v0.3.3

May 24, 2026

v0.3.2

May 24, 2026

v0.3.1

Apr 22, 2026

v0.3.0

Mar 29, 2026

Changes in this version

+ func NewClickHouseModule(name string, config map[string]any) (sdk.ModuleInstance, error)

+ func NewDruidCompactStep(name string, _ map[string]any) (sdk.StepInstance, error)

+ func NewDruidDatasourceStep(name string, _ map[string]any) (sdk.StepInstance, error)

+ func NewDruidIngestStep(name string, _ map[string]any) (sdk.StepInstance, error)

+ func NewDruidModule(name string, config map[string]any) (sdk.ModuleInstance, error)

+ func NewDruidQueryStep(name string, _ map[string]any) (sdk.StepInstance, error)

+ func NewInfluxModule(name string, config map[string]any) (sdk.ModuleInstance, error)

+ func NewQuestDBModule(name string, config map[string]any) (sdk.ModuleInstance, error)

+ func NewTSArchiveStep(name string, _ map[string]any) (sdk.StepInstance, error)

+ func NewTSClickHouseViewStep(name string, _ map[string]any) (sdk.StepInstance, error)

+ func NewTSContinuousQueryStep(name string, _ map[string]any) (sdk.StepInstance, error)

+ func NewTSDownsampleStep(name string, _ map[string]any) (sdk.StepInstance, error)

+ func NewTSQueryStep(name string, _ map[string]any) (sdk.StepInstance, error)

+ func NewTSRetentionStep(name string, _ map[string]any) (sdk.StepInstance, error)

+ func NewTSTierStatusStep(name string, _ map[string]any) (sdk.StepInstance, error)

+ func NewTSWriteBatchStep(name string, _ map[string]any) (sdk.StepInstance, error)

+ func NewTSWriteStep(name string, _ map[string]any) (sdk.StepInstance, error)

+ func NewTimescaleModule(name string, config map[string]any) (sdk.ModuleInstance, error)

+ func Register(name string, w TimeSeriesWriter) error

+ func Unregister(name string)

+ type ArchiveResult struct

+ BytesWritten int64

+ DeletedFromHot bool

+ Destination string

+ RowsArchived int64

+ type ClickHouseConfig struct

+ Compression string

+ Database string

+ DialTimeout time.Duration

+ Endpoints []string

+ MaxIdleConns int

+ MaxOpenConns int

+ Password string

+ Secure bool

+ Username string

+ type ClickHouseModule struct

+ func (m *ClickHouseModule) Archive(ctx context.Context, olderThan time.Duration, dest, format string, ...) (*ArchiveResult, error)

+ func (m *ClickHouseModule) Conn() driver.Conn

+ func (m *ClickHouseModule) Init() error

+ func (m *ClickHouseModule) Query(ctx context.Context, query string, args ...any) ([]map[string]any, error)

+ func (m *ClickHouseModule) Start(ctx context.Context) error

+ func (m *ClickHouseModule) Status(ctx context.Context, measurement string) (*TierStatus, error)

+ func (m *ClickHouseModule) Stop(_ context.Context) error

+ func (m *ClickHouseModule) WriteBatch(ctx context.Context, points []Point) error

+ func (m *ClickHouseModule) WritePoint(ctx context.Context, measurement string, tags map[string]string, ...) error

+ type CompactionConfig struct

+ SkipOffsetFromLatest string

+ TargetCompactionSizeBytes int64

+ type CompactionStatus struct

+ DataSource string

+ State string

+ type DatasourceInfo struct

+ Name string

+ Properties map[string]any

+ type DruidClient interface

+ DisableDatasource func(ctx context.Context, name string) error

+ GetCompactionStatus func(ctx context.Context, datasource string) (*CompactionStatus, error)

+ GetDatasource func(ctx context.Context, name string) (*DatasourceInfo, error)

+ GetStatus func(ctx context.Context) (*DruidStatus, error)

+ GetSupervisorStatus func(ctx context.Context, id string) (*SupervisorStatus, error)

+ ListDatasources func(ctx context.Context) ([]string, error)

+ NativeQuery func(ctx context.Context, query map[string]any) (*QueryResult, error)

+ ResumeSupervisor func(ctx context.Context, id string) error

+ SQLQuery func(ctx context.Context, query string, params []any) (*QueryResult, error)

+ SubmitCompaction func(ctx context.Context, datasource string, config CompactionConfig) error

+ SubmitSupervisor func(ctx context.Context, spec map[string]any) (*SupervisorStatus, error)

+ SuspendSupervisor func(ctx context.Context, id string) error

+ TerminateSupervisor func(ctx context.Context, id string) error

+ func NewDruidClient(routerURL, username, password string, timeout time.Duration) DruidClient

+ type DruidConfig struct

+ HTTPTimeout time.Duration

+ Password string

+ RouterURL string

+ Username string

+ type DruidModule struct

+ func (m *DruidModule) Client() DruidClient

+ func (m *DruidModule) Config() DruidConfig

+ func (m *DruidModule) Init() error

+ func (m *DruidModule) Query(ctx context.Context, query string, _ ...any) ([]map[string]any, error)

+ func (m *DruidModule) Start(ctx context.Context) error

+ func (m *DruidModule) Stop(_ context.Context) error

+ func (m *DruidModule) WriteBatch(ctx context.Context, points []Point) error

+ func (m *DruidModule) WritePoint(ctx context.Context, measurement string, tags map[string]string, ...) error

+ type DruidStatus struct

+ Loading bool

+ Version string

+ type HypertableConfig struct

+ ChunkInterval string

+ Table string

+ TimeColumn string

+ type InfluxConfig struct

+ BatchSize uint

+ Bucket string

+ FlushInterval time.Duration

+ Org string

+ Precision string

+ Token string

+ URL string

+ type InfluxModule struct

+ func (m *InfluxModule) Archive(ctx context.Context, olderThan time.Duration, dest, format string, ...) (*ArchiveResult, error)

+ func (m *InfluxModule) BucketsAPI() api.BucketsAPI

+ func (m *InfluxModule) Config() InfluxConfig

+ func (m *InfluxModule) Init() error

+ func (m *InfluxModule) Query(ctx context.Context, query string, _ ...any) ([]map[string]any, error)

+ func (m *InfluxModule) QueryAPI() api.QueryAPI

+ func (m *InfluxModule) Start(ctx context.Context) error

+ func (m *InfluxModule) Status(ctx context.Context, measurement string) (*TierStatus, error)

+ func (m *InfluxModule) Stop(_ context.Context) error

+ func (m *InfluxModule) UpdateBucketRetention(ctx context.Context, bucketName string, durationSeconds int64) error

+ func (m *InfluxModule) WriteAPI() api.WriteAPI

+ func (m *InfluxModule) WriteBatch(ctx context.Context, points []Point) error

+ func (m *InfluxModule) WritePoint(ctx context.Context, measurement string, tags map[string]string, ...) error

+ type Point struct

+ Fields map[string]any

+ Measurement string

+ Tags map[string]string

+ Timestamp time.Time

+ type QueryResult struct

+ Rows []map[string]any

+ type QuestDBConfig struct

+ AuthToken string

+ AutoFlush bool

+ FlushInterval time.Duration

+ HTTPEndpoint string

+ ILPEndpoint string

+ TLSEnabled bool

+ type QuestDBModule struct

+ func (m *QuestDBModule) Config() QuestDBConfig

+ func (m *QuestDBModule) Init() error

+ func (m *QuestDBModule) Query(ctx context.Context, query string, args ...any) ([]map[string]any, error)

+ func (m *QuestDBModule) Start(ctx context.Context) error

+ func (m *QuestDBModule) Stop(ctx context.Context) error

+ func (m *QuestDBModule) WriteBatch(ctx context.Context, points []Point) error

+ func (m *QuestDBModule) WritePoint(ctx context.Context, measurement string, tags map[string]string, ...) error

+ type SenderFactory func(ctx context.Context, cfg QuestDBConfig) (qdb.LineSender, error)

+ type SupervisorStatus struct

+ Healthy bool

+ ID string

+ State string

+ type TierManager interface

+ Archive func(ctx context.Context, olderThan time.Duration, dest, format string, ...) (*ArchiveResult, error)

+ Status func(ctx context.Context, measurement string) (*TierStatus, error)

+ type TierStatus struct

+ ColdFiles int

+ ColdOldestTimestamp *time.Time

+ HotOldestTimestamp *time.Time

+ HotRows int64

+ TotalBytes int64

+ type TimeSeriesWriter interface

+ Query func(ctx context.Context, query string, args ...any) ([]map[string]any, error)

+ WriteBatch func(ctx context.Context, points []Point) error

+ WritePoint func(ctx context.Context, measurement string, tags map[string]string, ...) error

+ func Lookup(name string) (TimeSeriesWriter, error)

+ type TimescaleConfig struct

+ Connection string

+ Hypertables []HypertableConfig

+ MaxIdleConns int

+ MaxOpenConns int

+ type TimescaleModule struct

+ func NewTimescaleModuleFromDB(name string, db *sql.DB) *TimescaleModule

+ func (m *TimescaleModule) CreateHypertable(ctx context.Context, table, timeColumn, chunkInterval string) error

+ func (m *TimescaleModule) DB() *sql.DB

+ func (m *TimescaleModule) Init() error

+ func (m *TimescaleModule) Query(ctx context.Context, query string, args ...any) ([]map[string]any, error)

+ func (m *TimescaleModule) Start(ctx context.Context) error

+ func (m *TimescaleModule) Stop(_ context.Context) error

+ func (m *TimescaleModule) WriteBatch(ctx context.Context, points []Point) error

+ func (m *TimescaleModule) WritePoint(ctx context.Context, measurement string, tags map[string]string, ...) error

v0.1.2

Mar 29, 2026

v0.1.1

Mar 29, 2026

v0.1.0

Mar 29, 2026