clickhouse

Documentation

Index

• type Client
  • func New(logger *zap.Logger, cfg *config.Config, forceMigrate bool) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) GetFlagEvaluationsCount(ctx context.Context, req *analytics.GetFlagEvaluationsCountRequest) ([]string, []float32, error)
  • func (c *Client) IncrementFlagEvaluationCounts(ctx context.Context, responses []*analytics.EvaluationResponse) error
  • func (c *Client) String() string
• type Step

Types

type Client

type Client struct {
	Conn *sql.DB
}

func New

func New(logger *zap.Logger, cfg *config.Config, forceMigrate bool) (*Client, error)

New constructs a new clickhouse client that conforms to the analytics.Client contract.

func (*Client) Close

func (c *Client) Close() error

Close will close the DB connection.

func (*Client) GetFlagEvaluationsCount

func (c *Client) GetFlagEvaluationsCount(ctx context.Context, req *analytics.GetFlagEvaluationsCountRequest) ([]string, []float32, error)

func (*Client) IncrementFlagEvaluationCounts

func (c *Client) IncrementFlagEvaluationCounts(ctx context.Context, responses []*analytics.EvaluationResponse) error

IncrementFlagEvaluationCounts does a batch insert of flag values from evaluations.

func (*Client) String

func (c *Client) String() string

type Step

type Step struct {
	// contains filtered or unexported fields
}

Step defines the value and interval name of the time windows for the Clickhouse query.