models

Documentation

Index

• type MetaData
• type SinkInput
• type SourceOutput
• type TransformAfterConvert
• type TransformBeforeConvert
• type TransformOutput

Types

type MetaData

type MetaData struct {
	StreamName    string // stream name
	SourceTagName string // Source Tag name
	AliasName     string // Source alias name
	SourceObj     any    // Source obj like Kafka, Pulsar .etc
}

type SinkInput

type SinkInput struct {
	*MetaData
}

type SourceOutput

type SourceOutput struct {
	*MetaData
	SourceData any // data
}

SourceOutput source output struct

type TransformAfterConvert

type TransformAfterConvert struct {
	*SourceOutput
	AfterConvertData map[string][]any // data after convert
}

type TransformBeforeConvert

type TransformBeforeConvert struct {
	*SourceOutput
	BeforeConvertData any // data before convert
}

type TransformOutput

type TransformOutput struct {
	*SourceOutput
	Data     []any
	SinkName string
}