Interface IntakeIngressProducer

All Known Implementing Classes:

RedisStreamIntakeIngressProducer

public interface IntakeIngressProducer

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static final record	IntakeIngressProducer.EnqueueResult

Method Summary

Modifier and Type	Method	Description
IntakeIngressProducer.EnqueueResult	enqueue(ai.pipestream.engine.v1.IntakeHandoffRequest request, String sourceDocId)

Method Details

enqueue

IntakeIngressProducer.EnqueueResult enqueue(ai.pipestream.engine.v1.IntakeHandoffRequest request,
 String sourceDocId)