events

type ArtifactConverted struct {
	Base
	ExecutionId string
	Info        *types.DownloadedArtifactInfo
	RowCount    int64
}

type ArtifactDiscovered struct {
	Base
	ExecutionId string
	Info        *types.ArtifactInfo
}

type ArtifactDownloaded struct {
	Base
	ExecutionId string
	Info        *types.DownloadedArtifactInfo
}

type ArtifactExtracted struct {
	Base
	ExecutionId string
	Info        *types.DownloadedArtifactInfo
}

type Base struct {
}

type Chunk struct {
	Base
	ExecutionId string
	ChunkNumber int32
}

type Complete struct {
	Base
	ExecutionId   string
	RowCount      int64
	ChunksWritten int32
	Err           error
}

type Error struct {
	Base
	ExecutionId string
	Err         error
}

type Event interface {
	// contains filtered or unexported methods
}

type ProtoEvent interface {
	ToProto() *proto.Event
}

type RowExtracted struct {
	Base
	ExecutionId string

	// enrichment values passed from the source to the collection to include in the enrichment process
	SourceEnrichment schema.SourceEnrichment
	Row              any
}

type SourceComplete struct {
	Base
	ExecutionId string
	Err         error
}

type Started struct {
	Base
	ExecutionId string
}

type Status struct {
	Base
	ExecutionId              string
	LatestArtifactLocation   string
	ArtifactsDiscovered      int64
	ArtifactsDownloaded      int64
	ArtifactsDownloadedBytes int64
	ArtifactsExtracted       int64
	SourceErrors             []string
	RowsReceived             int64
	RowsEnriched             int64
	// deprecated
	Errors    int64
	RowErrors *error_types.RowErrors
	// contains filtered or unexported fields
}