greptime

Jul 25, 2023

Changes in this version

type InsertsRequest

+ func (r *InsertsRequest) Append(insert InsertRequest) *InsertsRequest

type QueryRequest

+ func NewQueryRequest() *QueryRequest

+ type RespHeader struct

+ Code uint32

+ Msg string

+ func ParseRespHeader(r T) RespHeader

+ func (h RespHeader) IsNil() bool

+ func (h RespHeader) IsRateLimited() bool

+ func (h RespHeader) IsSuccess() bool

Jun 5, 2023

Changes in this version

+ var ErrEmptyInserts = errors.New("at least one insert is required in InsertsRequest")

+ type InsertsRequest struct

+ func (r *InsertsRequest) Insert(insert InsertRequest) *InsertsRequest

+ func (r *InsertsRequest) WithDatabase(database string) *InsertsRequest

May 1, 2023

Changes in this version

+ var ErrEmptyPromql = errors.New("promql is required in promql querying")

+ var ErrEmptyRange = errors.New("start and end is required in range promql")

+ var ErrEmptySql = errors.New("sql is required in querying")

+ var ErrNotImplemented = errors.New("not implemented!")

+ var ErrSqlInPromql = errors.New("Sql can not be used as Promql")

type Client

+ func (c *Client) PromqlQuery(ctx context.Context, req QueryRequest) ([]byte, error)

+ type InstantPromql struct

+ Query string

+ Ts time.Time

+ func NewInstantPromql(query string) *InstantPromql

+ func (ip *InstantPromql) WithQuery(query string) *InstantPromql

+ func (ip *InstantPromql) WithTime(ts time.Time) *InstantPromql

type QueryRequest

+ func (r *QueryRequest) WithInstantPromql(instantPromql *InstantPromql) *QueryRequest

type RangePromql

+ func NewRangePromql(query string) *RangePromql

+ func (rp *RangePromql) WithEnd(end time.Time) *RangePromql

+ func (rp *RangePromql) WithQuery(query string) *RangePromql

+ func (rp *RangePromql) WithStart(start time.Time) *RangePromql

+ func (rp *RangePromql) WithStep(step time.Duration) *RangePromql

+ type Sql struct

Apr 24, 2023

Changes in this version

type Config

+ Host string

Apr 19, 2023

Changes in this version

type Series

+ func (s *Series) AddBoolField(key string, val bool) error

+ func (s *Series) AddBoolTag(key string, val bool) error

+ func (s *Series) AddBytesField(key string, val []byte) error

+ func (s *Series) AddBytesTag(key string, val []byte) error

+ func (s *Series) AddFloatField(key string, val float64) error

+ func (s *Series) AddFloatTag(key string, val float64) error

+ func (s *Series) AddIntField(key string, val int64) error

+ func (s *Series) AddIntTag(key string, val int64) error

+ func (s *Series) AddStringField(key string, val string) error

+ func (s *Series) AddStringTag(key string, val string) error

+ func (s *Series) AddUintField(key string, val uint64) error

+ func (s *Series) AddUintTag(key string, val uint64) error

Apr 19, 2023

Changes in this version

type Series

+ func (s *Series) GetBool(key string) (bool, bool)

+ func (s *Series) GetBytes(key string) ([]byte, bool)

+ func (s *Series) GetFloat(key string) (float64, bool)

+ func (s *Series) GetInt(key string) (int64, bool)

+ func (s *Series) GetString(key string) (string, bool)

+ func (s *Series) GetUint(key string) (uint64, bool)

Apr 18, 2023

Changes in this version

type Config

+ Addr string

+ Port int

+ func (c *Config) WithAuth(username, password string) *Config

+ func (c *Config) WithPort(port int) *Config

type QueryRequest

+ func (r *QueryRequest) WithPromql(promql string) *QueryRequest

Apr 18, 2023

Changes in this version

+ var ErrEmptyDatabase = errors.New("name of database should not be empty")

+ var ErrEmptyKey = errors.New("key should not be empty")

+ var ErrEmptyQuery = errors.New("sql or promql is required in querying")

+ var ErrEmptyStep = errors.New("step is required in promql")

+ var ErrEmptyTable = errors.New("name of table should not be be empty")

+ var ErrEmptyTimestamp = errors.New("timestamp should not be empty")

+ var ErrInvalidTimePrecision = errors.New("precision of timestamp is not valid")

+ var ErrNoSeriesInMetric = errors.New("empty series in Metric")

+ func FromColumn(column array.Interface, idx int) (any, error)

+ func IsEmptyString(s string) bool

+ func ToColumnName(s string) (string, error)

+ type Client struct

+ func NewClient(cfg *Config) (*Client, error)

+ func (c *Client) Insert(ctx context.Context, req InsertRequest) (*greptimepb.AffectedRows, error)

+ func (c *Client) Query(ctx context.Context, req QueryRequest) (*Metric, error)

+ type Config struct

+ Address string

+ CallOptions []grpc.CallOption

+ Database string

+ DialOptions []grpc.DialOption

+ Password string

+ Username string

+ func NewCfg(addr string) *Config

+ func (c *Config) BuildAuthHeader() *greptimepb.AuthHeader

+ func (c *Config) WithCallOptions(options ...grpc.CallOption) *Config

+ func (c *Config) WithDatabase(database string) *Config

+ func (c *Config) WithDialOptions(options ...grpc.DialOption) *Config

+ func (c *Config) WithPassword(password string) *Config

+ func (c *Config) WithUserName(username string) *Config

+ type InsertRequest struct

+ func (r *InsertRequest) Build(cfg *Config) (*greptimepb.GreptimeRequest, error)

+ func (r *InsertRequest) RowCount() uint32

+ func (r *InsertRequest) WithDatabase(database string) *InsertRequest

+ func (r *InsertRequest) WithMetric(metric Metric) *InsertRequest

+ func (r *InsertRequest) WithTable(table string) *InsertRequest

+ type Metric struct

+ func (m *Metric) AddSeries(s Series) error

+ func (m *Metric) GetSeries() []Series

+ func (m *Metric) GetTagsAndFields() []string

+ func (m *Metric) GetTimestampAlias() string

+ func (m *Metric) SetTimePrecision(precision time.Duration) error

+ func (m *Metric) SetTimestampAlias(alias string) error

+ type QueryRequest struct

+ func (r *QueryRequest) Build(cfg *Config) (*greptimepb.GreptimeRequest, error)

+ func (r *QueryRequest) WithDatabase(database string) *QueryRequest

+ func (r *QueryRequest) WithRangePromql(rangePromql RangePromql) *QueryRequest

+ func (r *QueryRequest) WithSql(sql string) *QueryRequest

+ type RangePromql struct

+ End time.Time

+ Query string

+ Start time.Time

+ Step string

+ func (rp *RangePromql) Build() *greptimepb.QueryRequest_PromRangeQuery

+ func (rp *RangePromql) WithEndSecond(second int64) *RangePromql

+ func (rp *RangePromql) WithStartSecond(second int64) *RangePromql

+ type Series struct

+ func (s *Series) AddField(key string, val any) error

+ func (s *Series) AddTag(key string, val any) error

+ func (s *Series) Get(key string) (any, bool)

+ func (s *Series) GetTagsAndFields() []string

+ func (s *Series) GetTimestamp() (time.Time, bool)

+ func (s *Series) SetTimestamp(t time.Time) error

+ type StreamClient struct

+ func NewStreamClient(cfg *Config) (*StreamClient, error)

+ func (c *StreamClient) CloseAndRecv(ctx context.Context) (*greptimepb.AffectedRows, error)

+ func (c *StreamClient) Send(ctx context.Context, req InsertRequest) error