ckwriter

type CKItem interface {
	WriteBlock(block *ckdb.Block)
	OrgID() uint16
	Release()
}

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

type CKWriterManager struct {
	sync.Mutex
	// contains filtered or unexported fields
}

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

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
}