dbwriter

Documentation

Index

• Constants
• func GenPcapCKTable(cluster, storagePolicy, ckdbType string, ttl int, ...) *ckdb.Table
• func PcapStoreColumns() []*ckdb.Column
• func ReleasePcapStore(l *PcapStore)
• type PcapStore
  • func AcquirePcapStore() *PcapStore
  • func (s *PcapStore) OrgID() uint16
  • func (p *PcapStore) Release()
  • func (p *PcapStore) String() string
  • func (s *PcapStore) WriteBlock(block *ckdb.Block)
• type PcapWriter
  • func NewPcapWriter(config *config.Config) (*PcapWriter, error)
  • func (w *PcapWriter) Write(m interface{})

Constants

const (
	PCAP_DB    = "flow_log"
	PCAP_TABLE = "l7_packet"
)

const (
	DefaultPcapPartition = ckdb.TimeFuncHour
)

Functions

func GenPcapCKTable

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

func PcapStoreColumns

func PcapStoreColumns() []*ckdb.Column

func ReleasePcapStore

func ReleasePcapStore(l *PcapStore)

Types

type PcapStore

type PcapStore struct {
	Time        uint32
	StartTime   int64
	EndTime     int64
	FlowID      uint64
	VtapID      uint16
	PacketCount uint32
	PacketBatch []byte
	AclGids     []uint16

	// Not stored, only determines which database to store in.
	// When Orgid is 0 or 1, it is stored in database 'flow_log', otherwise stored in '<OrgId>_flow_log'.
	OrgId  uint16
	TeamID uint16
}

func AcquirePcapStore

func AcquirePcapStore() *PcapStore

func (*PcapStore) OrgID

func (s *PcapStore) OrgID() uint16

func (*PcapStore) Release

func (p *PcapStore) Release()

func (*PcapStore) String

func (p *PcapStore) String() string

func (*PcapStore) WriteBlock

func (s *PcapStore) WriteBlock(block *ckdb.Block)

type PcapWriter

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

func NewPcapWriter

func NewPcapWriter(config *config.Config) (*PcapWriter, error)

func (*PcapWriter) Write

func (w *PcapWriter) Write(m interface{})