kaiwudb

Documentation

Index

• Constants
• Variables
• func FastFormat(buf *bytes.Buffer, v interface{}) string
• func HostRangeFast(qry string, debug bool) (string, []interface{})
• func NewBenchmark(dbName string, opts *LoadingOptions, dataSourceConfig *source.DataSourceConfig) (targets.Benchmark, error)
• func NewTarget() targets.ImplementedTarget
• type Ctx
• type LoadingOptions
• type ParsePrepare
  • func NewParsePrepare(label string) *ParsePrepare
  • func (p *ParsePrepare) HostRange(qry string, debug bool) (string, []interface{})
  • func (p *ParsePrepare) HostsRange(qry string, debug bool) (string, []interface{})
  • func (p *ParsePrepare) Less(qry string, debug bool) (string, []interface{})
  • func (p *ParsePrepare) NotChange(qry string, debug bool) (string, []interface{})
  • func (p *ParsePrepare) Parse(qry string, debug bool) (string, []interface{})
  • func (p *ParsePrepare) Range(qry string, debug bool) (string, []interface{})
• type Serializer
  • func (s *Serializer) Serialize(p *data.Point, w io.Writer) error
• type Table

Constants

const (
	InsertMetric       = '1'
	CreateTable        = '2'
	InsertMetricAndTag = '3'
	InsertTag          = '4'
	NotNull            = " not null"
)

const Size1M = 1 * 1024 * 1024

Variables

var (
	KAIWUINSERT     = "insert"
	KAIWUPREPARE    = "prepare"
	KAIWUPREPAREIOT = "prepareiot"
)

var DEVOPSPRE = []string{"cpu", "diskio", "disk", "kernel", "mem", "net", "nginx", "postgresl", "redis"}

var GlobalTable = sync.Map{}

var IOTPRE = []string{"readings", "diagnostics"}

Functions

func FastFormat

func FastFormat(buf *bytes.Buffer, v interface{}) string

func HostRangeFast

func HostRangeFast(qry string, debug bool) (string, []interface{})

func NewBenchmark

func NewBenchmark(dbName string, opts *LoadingOptions, dataSourceConfig *source.DataSourceConfig) (targets.Benchmark, error)

func NewTarget

func NewTarget() targets.ImplementedTarget

Types

type Ctx

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

type LoadingOptions

type LoadingOptions struct {
	User     string
	Pass     string
	Host     []string
	Port     []int
	Buffer   int
	DBName   string
	Workers  int
	DoCreate bool
	Type     string
}

type ParsePrepare

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

func NewParsePrepare

func NewParsePrepare(label string) *ParsePrepare

func (*ParsePrepare) HostRange

func (p *ParsePrepare) HostRange(qry string, debug bool) (string, []interface{})

func (*ParsePrepare) HostsRange

func (p *ParsePrepare) HostsRange(qry string, debug bool) (string, []interface{})

func (*ParsePrepare) Less

func (p *ParsePrepare) Less(qry string, debug bool) (string, []interface{})

func (*ParsePrepare) NotChange

func (p *ParsePrepare) NotChange(qry string, debug bool) (string, []interface{})

func (*ParsePrepare) Parse

func (p *ParsePrepare) Parse(qry string, debug bool) (string, []interface{})

func (*ParsePrepare) Range

func (p *ParsePrepare) Range(qry string, debug bool) (string, []interface{})

type Serializer

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

func (*Serializer) Serialize

func (s *Serializer) Serialize(p *data.Point, w io.Writer) error

type Table

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