dbwriter

Documentation

Index

• Constants
• type DbWriter
  • func NewDbWriter(addrs []string, user, password, clusterName, storagePolicy string, ...) (*DbWriter, error)
  • func (w *DbWriter) Close()
  • func (w *DbWriter) Put(items ...interface{}) error

Constants

const (
	CACHE_SIZE = 10240
)

Types

type DbWriter

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

func NewDbWriter

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

func (*DbWriter) Close

func (w *DbWriter) Close()

func (*DbWriter) Put

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