Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MakeCustomEndpointConsumer ¶
func MakeCustomEndpointConsumer[T any](stream runtime.TypedInputStream[T], dataProducer DataProducer[T]) runtime.Consumer[T]
Types ¶
type CustomDataSource ¶
type CustomDataSource struct { *runtime.InputDataSource // contains filtered or unexported fields }
func (*CustomDataSource) Stop ¶
func (ds *CustomDataSource) Stop(ctx context.Context)
func (*CustomDataSource) WaitGroup ¶
func (ds *CustomDataSource) WaitGroup() *sync.WaitGroup
type CustomEndpoint ¶
type CustomEndpoint struct { *runtime.DataSourceEndpoint // contains filtered or unexported fields }
func (*CustomEndpoint) NextMessage ¶
func (ep *CustomEndpoint) NextMessage()
func (*CustomEndpoint) Stop ¶
func (ep *CustomEndpoint) Stop(ctx context.Context)
type CustomEndpointConsumer ¶
type CustomInputDataSource ¶
type CustomInputDataSource interface { runtime.DataSource WaitGroup() *sync.WaitGroup }
type CustomInputEndpoint ¶
type DataProducer ¶
type TypedCustomEndpointConsumer ¶
type TypedCustomEndpointConsumer[T any] struct { *runtime.DataSourceEndpointConsumer[T] // contains filtered or unexported fields }
func (*TypedCustomEndpointConsumer[T]) Consume ¶
func (ep *TypedCustomEndpointConsumer[T]) Consume(value T)
func (*TypedCustomEndpointConsumer[T]) Start ¶
func (ep *TypedCustomEndpointConsumer[T]) Start(ctx context.Context) error
func (*TypedCustomEndpointConsumer[T]) Stop ¶
func (ep *TypedCustomEndpointConsumer[T]) Stop(ctx context.Context)
Click to show internal directories.
Click to hide internal directories.