localsource

Documentation

Index

• func MakeCustomEndpointConsumer[T any](stream runtime.TypedInputStream[T], dataProducer DataProducer[T]) runtime.Consumer[T]
• type CustomDataSource
  • func (ds *CustomDataSource) Start(ctx context.Context) error
  • func (ds *CustomDataSource) Stop(ctx context.Context)
  • func (ds *CustomDataSource) WaitGroup() *sync.WaitGroup
• type CustomEndpoint
  • func (ep *CustomEndpoint) NextMessage()
  • func (ep *CustomEndpoint) Start(ctx context.Context) error
  • func (ep *CustomEndpoint) Stop(ctx context.Context)
• type CustomEndpointConsumer
• type CustomInputDataSource
• type CustomInputEndpoint
• type DataProducer
• type TypedCustomEndpointConsumer
  • func (ec *TypedCustomEndpointConsumer[T]) Consume(value T)
  • func (ec *TypedCustomEndpointConsumer[T]) Start(ctx context.Context) error
  • func (ec *TypedCustomEndpointConsumer[T]) Stop(ctx context.Context)

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) Start

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

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) 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.InputEndpointConsumer
	Start(context.Context) error
	Stop(context.Context)
}

type CustomInputDataSource

type CustomInputDataSource interface {
	runtime.DataSource
	WaitGroup() *sync.WaitGroup
}

type CustomInputEndpoint

type CustomInputEndpoint interface {
	runtime.InputEndpoint
	Start(context.Context) error
	Stop(context.Context)
	NextMessage()
}

type DataProducer

type DataProducer[T any] interface {
	Start(ctx context.Context, consumer runtime.Consumer[T]) error
	Stop(context.Context)
}

type TypedCustomEndpointConsumer

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

func (*TypedCustomEndpointConsumer[T]) Consume

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

func (*TypedCustomEndpointConsumer[T]) Start

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

func (*TypedCustomEndpointConsumer[T]) Stop

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