app

Documentation

Index

• Constants
• func PseudoCloneDocument(doc *Document)
• func ReleaseDocument(doc *Document)
• type Document
  • func AcquireDocument() *Document
  • func CloneDocument(doc *Document) *Document
  • func DecodeForQueueMonitor(decoder *codec.SimpleDecoder) (*Document, error)
  • func DecodePB(decoder *codec.SimpleDecoder, pbDoc *pb.Document) (*Document, error)
  • func (d *Document) EncodePB(encoder *codec.SimpleEncoder, i interface{}) error
  • func (d *Document) Release()
  • func (d Document) String() string
  • func (d *Document) TableID() (uint8, error)
  • func (d *Document) WriteBlock(block *ckdb.Block)
  • func (d *Document) WriteToPB(p *pb.Document) error
• type DocumentFlag
• type FlowProcessor
• type MeteringProcessor

Constants

const (
	VERSION                   = 20220117 // 修改Document的序列化结构时需同步修改此常量
	LAST_SIMPLE_CODEC_VERSION = 20220111 // 这个版本及之前的版本使用 simple_codec, 之后的版本使用pb_codec
)

Functions

func PseudoCloneDocument

func PseudoCloneDocument(doc *Document)

func ReleaseDocument

func ReleaseDocument(doc *Document)

Types

type Document

type Document struct {
	pool.ReferenceCount

	Timestamp uint32
	zerodoc.Tagger
	zerodoc.Meter
	Flags DocumentFlag
}

func AcquireDocument

func AcquireDocument() *Document

func CloneDocument

func CloneDocument(doc *Document) *Document

func DecodeForQueueMonitor

func DecodeForQueueMonitor(decoder *codec.SimpleDecoder) (*Document, error)

queue monitor 打印时使用

func DecodePB

func DecodePB(decoder *codec.SimpleDecoder, pbDoc *pb.Document) (*Document, error)

func (*Document) EncodePB

func (d *Document) EncodePB(encoder *codec.SimpleEncoder, i interface{}) error

func (*Document) Release

func (d *Document) Release()

func (Document) String

func (d Document) String() string

func (*Document) TableID

func (d *Document) TableID() (uint8, error)

func (*Document) WriteBlock

func (d *Document) WriteBlock(block *ckdb.Block)

func (*Document) WriteToPB

func (d *Document) WriteToPB(p *pb.Document) error

type DocumentFlag

type DocumentFlag uint32

const (
	FLAG_PER_SECOND_METRICS DocumentFlag = 1 << iota
)

type FlowProcessor

type FlowProcessor interface {
	GetName() string
	Prepare()
	Process(*datatype.TaggedFlow, bool) []interface{}
}

type MeteringProcessor

type MeteringProcessor interface {
	GetName() string
	Prepare()
	Process(*datatype.TaggedFlow, bool) []interface{}
}