Documentation ¶
Index ¶
- Constants
- func ExecSQL(conn clickhouse.Conn, query string) error
- func InitTable(addr, user, password, timeZone string, t *ckdb.Table, orgID uint16) error
- func IsNil(i interface{}) bool
- func RegisterToCkwriterManager(w *CKWriter)
- type CKItem
- type CKWriter
- type CKWriterManager
- type Cache
- type Counter
- type QueueContext
Constants ¶
View Source
const ( FLUSH_TIMEOUT = 10 * time.Second SQL_LOG_LENGTH = 256 RETRY_COUNT = 2 )
Variables ¶
This section is empty.
Functions ¶
func RegisterToCkwriterManager ¶
func RegisterToCkwriterManager(w *CKWriter)
Types ¶
type CKWriter ¶
type CKWriter struct {
// contains filtered or unexported fields
}
func NewCKWriter ¶
func (*CKWriter) ResetConnection ¶
type CKWriterManager ¶
func (*CKWriterManager) DropOrg ¶
func (m *CKWriterManager) DropOrg(orgId uint16) error
func (*CKWriterManager) EndpointsChange ¶
func (m *CKWriterManager) EndpointsChange(addrs []string)
type Cache ¶
type Cache struct {
// contains filtered or unexported fields
}
func (*Cache) OrgIdExists ¶
type Counter ¶
type Counter struct { WriteSuccessCount int64 `statsd:"write-success-count"` WriteFailedCount int64 `statsd:"write-failed-count"` RetryCount int64 `statsd:"retry-count"` RetryFailedCount int64 `statsd:"retry-failed-count"` OrgInvalidCount int64 `statsd:"org-invalid-count"` utils.Closable }
func (*Counter) GetCounter ¶
func (i *Counter) GetCounter() interface{}
type QueueContext ¶
type QueueContext struct {
// contains filtered or unexported fields
}
func (*QueueContext) EndpointsChange ¶
func (qc *QueueContext) EndpointsChange(addrs []string)
Click to show internal directories.
Click to hide internal directories.