timescale

Documentation

Index

• type GetColumnLastResponse
• type GetColumnLastTemplateParameters
  • func (t *GetColumnLastTemplateParameters) Hash() string
  • func (t *GetColumnLastTemplateParameters) String() string
• type GetColumnResponse
• type GetColumnTemplateParameters
  • func (t *GetColumnTemplateParameters) Hash() string
  • func (t *GetColumnTemplateParameters) String() string
• type TimescaleClient
  • func NewTimescaleClient(ctx context.Context, connString string, opts ...TimescaleClientOption) (*TimescaleClient, error)
  • func (c *TimescaleClient) Close()
  • func (c *TimescaleClient) GetColumn(ctx context.Context, tp GetColumnTemplateParameters) ([]GetColumnResponse, error)
  • func (c *TimescaleClient) GetColumnLast(ctx context.Context, tp GetColumnLastTemplateParameters) (*GetColumnLastResponse, error)
• type TimescaleClientOption
  • func WithDragonflyClient(dfly *dragonfly.DragonflyClient) TimescaleClientOption

Types

type GetColumnLastResponse

type GetColumnLastResponse struct {
	Time time.Time `json:"time"`
	Last float64   `json:"last"`
}

type GetColumnLastTemplateParameters

type GetColumnLastTemplateParameters struct {
	ColumnName string
	TableName  string
}

func (*GetColumnLastTemplateParameters) Hash

func (t *GetColumnLastTemplateParameters) Hash() string

func (*GetColumnLastTemplateParameters) String

func (t *GetColumnLastTemplateParameters) String() string

type GetColumnResponse

type GetColumnResponse struct {
	Time time.Time `json:"time"`
	Min  float64   `json:"min"`
	Max  float64   `json:"max"`
	Avg  float64   `json:"avg"`
}

type GetColumnTemplateParameters

type GetColumnTemplateParameters struct {
	ColumnName       string
	TimeBucket       string
	LookbackInterval string
	TableName        string
}

func (*GetColumnTemplateParameters) Hash

func (t *GetColumnTemplateParameters) Hash() string

func (*GetColumnTemplateParameters) String

func (t *GetColumnTemplateParameters) String() string

type TimescaleClient

type TimescaleClient struct {
	Pool *pgxpool.Pool
	Dfly *dragonfly.DragonflyClient
	// contains filtered or unexported fields
}

func NewTimescaleClient

func NewTimescaleClient(ctx context.Context, connString string, opts ...TimescaleClientOption) (*TimescaleClient, error)

func (*TimescaleClient) Close

func (c *TimescaleClient) Close()

func (*TimescaleClient) GetColumn

func (c *TimescaleClient) GetColumn(ctx context.Context, tp GetColumnTemplateParameters) ([]GetColumnResponse, error)

func (*TimescaleClient) GetColumnLast

func (c *TimescaleClient) GetColumnLast(ctx context.Context, tp GetColumnLastTemplateParameters) (*GetColumnLastResponse, error)

type TimescaleClientOption

type TimescaleClientOption func(*TimescaleClient)

func WithDragonflyClient

func WithDragonflyClient(dfly *dragonfly.DragonflyClient) TimescaleClientOption