write

package
v0.0.0-...-97a540d Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 4, 2021 License: AGPL-3.0 Imports: 15 Imported by: 0

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 OrderInsertS(s string, l *list.List)

func TAOSHashID

func TAOSHashID(ba []byte) int

func TaosStrCmp

func TaosStrCmp(a string, b string) bool

Types

type WriterProcessor

type WriterProcessor struct {
}

func NewProcessor

func NewProcessor() *WriterProcessor

func (*WriterProcessor) Check

func (p *WriterProcessor) Check(r *http.Request) (string, error)

func (*WriterProcessor) Process

func (p *WriterProcessor) Process(req *prompb.WriteRequest) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL