dbwriter

Documentation

Index

• Constants
• func GenSpanWithTraceIDCKTable(cluster, storagePolicy, ckdbType string, ttl int, ...) *ckdb.Table
• func GenTraceTreeCKTable(cluster, storagePolicy, ckdbType string, ttl int, ...) *ckdb.Table
• func GetFlowLogTables(engine ckdb.EngineType, cluster, storagePolicy, ckdbType string, ...) []*ckdb.Table
• func SpanWithTraceIDColumns() []*ckdb.Column
• type FlowLogWriter
  • func NewFlowLogWriter(addrs []string, ...) (*FlowLogWriter, error)
  • func (w *FlowLogWriter) Close()
  • func (w *FlowLogWriter) Put(index int, items ...interface{})
• type SpanWithTraceID
  • func (t *SpanWithTraceID) Encode()
  • func (t *SpanWithTraceID) OrgID() uint16
  • func (t *SpanWithTraceID) Release()
  • func (t *SpanWithTraceID) WriteBlock(block *ckdb.Block)
• type SpanWriter
  • func NewSpanWriter(config *config.Config) (*SpanWriter, error)
  • func (s *SpanWriter) Close()
  • func (s *SpanWriter) Put(items []interface{})
  • func (s *SpanWriter) Start()
• type TraceTreeWriter
  • func NewTraceTreeWriter(config *config.Config, traceTreeQueue queue.QueueReader) (*TraceTreeWriter, error)
  • func (s *TraceTreeWriter) Close()
  • func (s *TraceTreeWriter) Put(items []interface{})
  • func (s *TraceTreeWriter) Start()

Constants

const (
	CACHE_SIZE       = 10240
	DefaultPartition = ckdb.TimeFuncHour
)

const (
	TRACE_TREE_TABLE = "trace_tree"
	BUFFER_SIZE      = 1024
)

const (
	SPAN_WITH_TRACE_ID_TABLE = "span_with_trace_id"
)

Functions

func GenSpanWithTraceIDCKTable

func GenSpanWithTraceIDCKTable(cluster, storagePolicy, ckdbType string, ttl int, coldStorage *ckdb.ColdStorage) *ckdb.Table

func GenTraceTreeCKTable

func GenTraceTreeCKTable(cluster, storagePolicy, ckdbType string, ttl int, coldStorage *ckdb.ColdStorage) *ckdb.Table

func GetFlowLogTables

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

func SpanWithTraceIDColumns

func SpanWithTraceIDColumns() []*ckdb.Column

Types

type FlowLogWriter

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

func NewFlowLogWriter

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

func (*FlowLogWriter) Close

func (w *FlowLogWriter) Close()

func (*FlowLogWriter) Put

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

type SpanWithTraceID

type SpanWithTraceID logdata.L7FlowLog

func (*SpanWithTraceID) Encode

func (t *SpanWithTraceID) Encode()

func (*SpanWithTraceID) OrgID

func (t *SpanWithTraceID) OrgID() uint16

func (*SpanWithTraceID) Release

func (t *SpanWithTraceID) Release()

func (*SpanWithTraceID) WriteBlock

func (t *SpanWithTraceID) WriteBlock(block *ckdb.Block)

type SpanWriter

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

func NewSpanWriter

func NewSpanWriter(config *config.Config) (*SpanWriter, error)

func (*SpanWriter) Close

func (s *SpanWriter) Close()

func (*SpanWriter) Put

func (s *SpanWriter) Put(items []interface{})

func (*SpanWriter) Start

func (s *SpanWriter) Start()

type TraceTreeWriter

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

func NewTraceTreeWriter

func NewTraceTreeWriter(config *config.Config, traceTreeQueue queue.QueueReader) (*TraceTreeWriter, error)

func (*TraceTreeWriter) Close

func (s *TraceTreeWriter) Close()

func (*TraceTreeWriter) Put

func (s *TraceTreeWriter) Put(items []interface{})

func (*TraceTreeWriter) Start

func (s *TraceTreeWriter) Start()