buildeventrecorder

type Batcher[T any] struct {
	// contains filtered or unexported fields
}

type BuildEventRecorder interface {
	// StartLoggingConnectionMetadata starts a logging routine that will
	// log that there is a connection alive and well for the specific
	// invocation.
	StartLoggingConnectionMetadata(ctx context.Context)
	// SaveBatch saves a batch of build events to the storage layer.
	SaveBatch(ctx context.Context, batch []BuildEventWithInfo) error
}

type BuildEventWithInfo struct {
	Event *bes.BuildEvent
	// Sequence number is int64 by spec, however it is also starting at
	// 1 and incrementing by 1 for each event by spec. We therefore
	// assume we can fit the SequenceNumber in an uint32 and in case we
	// can not we will refuse to process the event.
	SequenceNumber uint32
}

type DataExtractors struct {
	AuthMetadataExtractors      *authmetadataextraction.AuthMetadataExtractors
	InvocationMetadataExtractor *jmespath.Expression
}

type Factory func(ctx context.Context, instanceName, invocationID string) (BuildEventRecorder, error)