consumer_data

Documentation

Index

• Constants
• Variables
• type FastjsonMetricData
• type RealTimeWarehousing
  • func NewRealTimeWarehousing(config model.BatchConfig) *RealTimeWarehousing
  • func (this *RealTimeWarehousing) Add(data *RealTimeWarehousingData) (err error)
  • func (this *RealTimeWarehousing) Flush() (err error)
  • func (this *RealTimeWarehousing) FlushAll() error
  • func (this *RealTimeWarehousing) RegularFlushing()
• type RealTimeWarehousingData
• type ReportAcceptStatus
  • func NewReportAcceptStatus(config model.BatchConfig) *ReportAcceptStatus
  • func (this *ReportAcceptStatus) Add(data *ReportAcceptStatusData) (err error)
  • func (this *ReportAcceptStatus) Flush() (err error)
  • func (this *ReportAcceptStatus) FlushAll() error
  • func (this *ReportAcceptStatus) RegularFlushing()
• type ReportAcceptStatusData
• type ReportData2CK
  • func NewReportData2CK(config model.BatchConfig) *ReportData2CK
  • func (this *ReportData2CK) Add(data FastjsonMetricData) (err error)
  • func (this *ReportData2CK) Flush() (err error)
  • func (this *ReportData2CK) FlushAll() error
  • func (this *ReportData2CK) RegularFlushing()

Constants

const (
	FailStatus    = 0
	SuccessStatus = 1
)

Variables

var TableColumnMap sync.Map

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()