Documentation
¶
Index ¶
- Variables
- type ClickHouse
- func (c *ClickHouse) AllowWriteSeries(sid, mid int64) (allowed bool)
- func (c *ClickHouse) ChangeSchema(newKeys *sync.Map) (err error)
- func (c *ClickHouse) Drain()
- func (c *ClickHouse) GetMetricTable() string
- func (c *ClickHouse) GetSeriesQuotaKey() string
- func (c *ClickHouse) Init() (err error)
- func (c *ClickHouse) Send(batch *model.Batch, traceId string)
- func (c *ClickHouse) SetSeriesQuota(sq *model.SeriesQuota)
- type DistTblInfo
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrTblNotExist = errors.Newf("table doesn't exist") SeriesQuotas sync.Map )
Functions ¶
This section is empty.
Types ¶
type ClickHouse ¶
type ClickHouse struct {
Dims []*model.ColumnWithType
NumDims int
IdxSerID int
NameKey string
TableName string
DimSerID string
DimMgmtID string
// contains filtered or unexported fields
}
ClickHouse is an output service consumers from kafka messages
func NewClickHouse ¶
func NewClickHouse(cfg *config.Config, taskCfg *config.TaskConfig) *ClickHouse
NewClickHouse new a clickhouse instance
func (*ClickHouse) AllowWriteSeries ¶ added in v0.5.0
func (c *ClickHouse) AllowWriteSeries(sid, mid int64) (allowed bool)
func (*ClickHouse) ChangeSchema ¶
func (c *ClickHouse) ChangeSchema(newKeys *sync.Map) (err error)
func (*ClickHouse) GetMetricTable ¶ added in v0.5.0
func (c *ClickHouse) GetMetricTable() string
func (*ClickHouse) GetSeriesQuotaKey ¶ added in v0.5.0
func (c *ClickHouse) GetSeriesQuotaKey() string
func (*ClickHouse) Send ¶
func (c *ClickHouse) Send(batch *model.Batch, traceId string)
Send a batch to clickhouse
func (*ClickHouse) SetSeriesQuota ¶ added in v0.5.0
func (c *ClickHouse) SetSeriesQuota(sq *model.SeriesQuota)
type DistTblInfo ¶ added in v0.5.0
type DistTblInfo struct {
// contains filtered or unexported fields
}
Source Files
Click to show internal directories.
Click to hide internal directories.