localsink

package

v0.0.176 Latest Latest Go to latest Published: Nov 11, 2024 License: BSD-3-Clause Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

func MakeCustomEndpointSink[T any](stream runtime.TypedSinkStream[T], dataConsumer DataConsumer[T]) runtime.Consumer[T]

type CustomDataSink struct {
	*runtime.OutputDataSink
	// contains filtered or unexported fields
}

func (ds *CustomDataSink) Start(ctx context.Context) error

func (ds *CustomDataSink) Stop(ctx context.Context)

func (ds *CustomDataSink) WaitGroup() *sync.WaitGroup

type CustomEndpoint struct {
	*runtime.DataSinkEndpoint
}

func (ep *CustomEndpoint) Start(ctx context.Context) error

func (ep *CustomEndpoint) Stop(ctx context.Context)

type CustomEndpointConsumer interface {
	runtime.OutputEndpointConsumer
	Start(context.Context) error
	Stop(context.Context)
}

type CustomOutputDataSink interface {
	runtime.DataSink
	WaitGroup() *sync.WaitGroup
}

type CustomSinkEndpoint interface {
	runtime.SinkEndpoint
	Start(context.Context) error
	Stop(context.Context)
}

type DataConsumer[T any] interface {
	runtime.Consumer[T]
	Start(context.Context) error
	Stop(context.Context)
}

type TypedCustomEndpointConsumer[T any] struct {
	*runtime.DataSinkEndpointConsumer[T]
	// contains filtered or unexported fields
}

func (ep *TypedCustomEndpointConsumer[T]) Consume(value T)

func (ep *TypedCustomEndpointConsumer[T]) Start(ctx context.Context) error

func (ep *TypedCustomEndpointConsumer[T]) Stop(ctx context.Context)