Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( BatchChannels []chan string //multi table one chan BufPool sync.Pool WorkersGroup sync.WaitGroup IsSTableCreated sync.Map IsTableCreated sync.Map TdUrl string TagStr string HttpWorkers int SqlWorkers int )
main vars
View Source
var ( DaemonIP string DaemonName string BatchSize int BufferSize int DbName string DbUser string DbPassword string RWPort string ApiPort string DebugPrt int TagLen int TagLimit int = 1024 TagNumLimit int TablePervNode int DriverName string )
write vars
Functions ¶
func HandleStable ¶
func HandleStable(ts *prompb.TimeSeries, db *sql.DB) error
func OrderInsertS ¶
func TAOSHashID ¶
func TaosStrCmp ¶
Types ¶
type WriterProcessor ¶
type WriterProcessor struct { }
func NewProcessor ¶
func NewProcessor() *WriterProcessor
func (*WriterProcessor) Process ¶
func (p *WriterProcessor) Process(req *prompb.WriteRequest) error
Click to show internal directories.
Click to hide internal directories.