writer

Documentation

Index

• Constants
• Variables
• func Close()
• func FlushToDB(key int64, items []*g.TrendResult)
• func Start()

Constants

const (
	DEFAULT_DB_WRITE_BATCH          = 200
	DEFAULT_DB_WRITE_BATCH_INTERVAL = 200 //默认200ms
)

Variables

var (
	DBWriteBatch         int
	DBWriteBatchInterval int
)

var DB *sql.DB

Functions

func Close

func Close()

func FlushToDB

func FlushToDB(key int64, items []*g.TrendResult)

func Start

func Start()