localsink

Documentation

Index

• func MakeCustomEndpointSink[T any](stream runtime.TypedSinkStream[T], dataConsumer DataConsumer[T]) runtime.Consumer[T]
• type CustomDataSink
  • func (ds *CustomDataSink) Start(ctx context.Context) error
  • func (ds *CustomDataSink) Stop(ctx context.Context)
• type CustomEndpoint
  • func (ep *CustomEndpoint) Start(ctx context.Context) error
  • func (ep *CustomEndpoint) Stop(ctx context.Context)
• type CustomEndpointConsumer
• type CustomSinkEndpoint
• type DataConsumer
• type TypedCustomEndpointConsumer
  • func (ep *TypedCustomEndpointConsumer[T]) Consume(value T)
  • func (ep *TypedCustomEndpointConsumer[T]) Start(ctx context.Context) error
  • func (ep *TypedCustomEndpointConsumer[T]) Stop(ctx context.Context)

Functions

func MakeCustomEndpointSink

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

Types

type CustomDataSink

type CustomDataSink struct {
	*runtime.OutputDataSink
}

func (*CustomDataSink) Start

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

func (*CustomDataSink) Stop

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

type CustomEndpoint

type CustomEndpoint struct {
	*runtime.DataSinkEndpoint
}

func (*CustomEndpoint) Start

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

func (*CustomEndpoint) Stop

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

type CustomEndpointConsumer

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

type CustomSinkEndpoint

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

type DataConsumer

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

type TypedCustomEndpointConsumer

type TypedCustomEndpointConsumer[T any] struct {
	*runtime.DataSinkEndpointConsumer[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)