dbwriter

Documentation

Index

• Constants
• type CkDbWriter
  • func (w *CkDbWriter) Close()
  • func (w *CkDbWriter) Put(items ...interface{}) error
• type DbWriter
  • func NewCkDbWriter(addrs []string, ...) (DbWriter, error)

Constants

const (
	CACHE_SIZE       = 10240
	QUEUE_BATCH_SIZE = 1024
)

Types

type CkDbWriter

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

func (*CkDbWriter) Close

func (w *CkDbWriter) Close()

func (*CkDbWriter) Put

func (w *CkDbWriter) Put(items ...interface{}) error

type DbWriter

type DbWriter interface {
	Put(items ...interface{}) error
	Close()
}

DbWriter 指标数据写入的接口定义

func NewCkDbWriter

func NewCkDbWriter(addrs []string, user, password, clusterName, storagePolicy, timeZone, ckdbType string, ckWriterCfg config.CKWriterConfig, flowMetricsTtl flowmetricsconfig.FlowMetricsTTL, coldStorages map[string]*ckdb.ColdStorage, ckdbWatcher *config.Watcher) (DbWriter, error)