poller

Documentation

Index

• func WithBatchSize(size int) func(*Opts)
• type Option
• type Opts
• type Poller
• type Source
  • func New[T any](p Poller[T], opts ...Option) *Source[T]
  • func (s *Source[T]) Recv(ctx context.Context) (kawa.Message[T], func(), error)
  • func (s *Source[T]) Run(ctx context.Context) error

Functions

func WithBatchSize

func WithBatchSize(size int) func(*Opts)

Types

type Option

type Option func(*Opts)

type Opts

type Opts struct {
	BatchSize int
}

type Poller

type Poller[T any] interface {
	Poll(context.Context, int) ([]kawa.Message[T], func(), error)
}

type Source

type Source[T any] struct {
	// contains filtered or unexported fields
}

func New

func New[T any](p Poller[T], opts ...Option) *Source[T]

func (*Source[T]) Recv

func (s *Source[T]) Recv(ctx context.Context) (kawa.Message[T], func(), error)

func (*Source[T]) Run

func (s *Source[T]) Run(ctx context.Context) error