localsink

package

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

Details

This section is empty.

This section is empty.

func MakeCustomEndpointSink[T, R any](stream runtime.TypedSinkStream[T, R], dataConsumer DataConsumer[T]) runtime.SinkConsumer[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 {
	Consume(T) error
	Start(context.Context) error
	Stop(context.Context)
}

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

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

func (ep *TypedCustomEndpointConsumer[T, R]) SetSinkCallback(callback runtime.SinkCallback[T])

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

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