consumer_data

package
v0.0.0-...-9337120 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 30, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source
const (
	FailStatus    = 0
	SuccessStatus = 1
)

Variables

View Source
var TableColumnMap sync.Map

Functions

This section is empty.

Types

type FastjsonMetricData

type FastjsonMetricData struct {
	FastjsonMetric *parser.FastjsonMetric
	TableName      string
}

type RealTimeWarehousing

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

func NewRealTimeWarehousing

func NewRealTimeWarehousing(config model.BatchConfig) *RealTimeWarehousing

func (*RealTimeWarehousing) Add

func (this *RealTimeWarehousing) Add(data *RealTimeWarehousingData) (err error)

func (*RealTimeWarehousing) Flush

func (this *RealTimeWarehousing) Flush() (err error)

func (*RealTimeWarehousing) FlushAll

func (this *RealTimeWarehousing) FlushAll() error

func (*RealTimeWarehousing) RegularFlushing

func (this *RealTimeWarehousing) RegularFlushing()

type RealTimeWarehousingData

type RealTimeWarehousingData struct {
	Appid      int64
	EventName  string
	CreateTime string
	Data       []byte
}

type ReportAcceptStatus

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

func NewReportAcceptStatus

func NewReportAcceptStatus(config model.BatchConfig) *ReportAcceptStatus

func (*ReportAcceptStatus) Add

func (this *ReportAcceptStatus) Add(data *ReportAcceptStatusData) (err error)

func (*ReportAcceptStatus) Flush

func (this *ReportAcceptStatus) Flush() (err error)

func (*ReportAcceptStatus) FlushAll

func (this *ReportAcceptStatus) FlushAll() error

func (*ReportAcceptStatus) RegularFlushing

func (this *ReportAcceptStatus) RegularFlushing()

type ReportAcceptStatusData

type ReportAcceptStatusData struct {
	PartDate       string
	ReportType     string
	DataName       string
	ErrorReason    string
	ErrorHandling  string
	ReportData     string
	XwlKafkaOffset int64
	TableId        int
	Status         int
}

type ReportData2CK

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

func NewReportData2CK

func NewReportData2CK(config model.BatchConfig) *ReportData2CK

func (*ReportData2CK) Add

func (this *ReportData2CK) Add(data FastjsonMetricData) (err error)

func (*ReportData2CK) Flush

func (this *ReportData2CK) Flush() (err error)

func (*ReportData2CK) FlushAll

func (this *ReportData2CK) FlushAll() error

func (*ReportData2CK) RegularFlushing

func (this *ReportData2CK) RegularFlushing()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL