dbwriter

Documentation

Index

• Constants
• func GetFlowLogTables(engine ckdb.EngineType, cluster, storagePolicy string, ...) []*ckdb.Table
• type FlowLogWriter
  • func NewFlowLogWriter(addrs []string, user, password, cluster, storagePolicy, timeZone string, ...) (*FlowLogWriter, error)
  • func (w *FlowLogWriter) Close()
  • func (w *FlowLogWriter) Put(index int, items ...interface{})

Constants

const (
	CACHE_SIZE       = 10240
	DefaultPartition = ckdb.TimeFuncHour
)

Functions

func GetFlowLogTables

func GetFlowLogTables(engine ckdb.EngineType, cluster, storagePolicy string, l4LogTtl, l7LogTtl, l4PacketTtl int, coldStorages map[string]*ckdb.ColdStorage) []*ckdb.Table

Types

type FlowLogWriter

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

func NewFlowLogWriter

func NewFlowLogWriter(addrs []string, user, password, cluster, storagePolicy, timeZone string, ckWriterCfg config.CKWriterConfig, flowLogTtl flowlogconfig.FlowLogTTL, coldStorages map[string]*ckdb.ColdStorage) (*FlowLogWriter, error)

func (*FlowLogWriter) Close

func (w *FlowLogWriter) Close()

func (*FlowLogWriter) Put

func (w *FlowLogWriter) Put(index int, items ...interface{})