impl

Documentation

Index

• func FileWatcher(watcher *fsnotify.Watcher, sideInputName string)
• type SimpleSource
  • func NewSimpleSource() *SimpleSource
  • func (s *SimpleSource) Ack(_ context.Context, request sourcesdk.AckRequest)
  • func (s *SimpleSource) Partitions(_ context.Context) []int32
  • func (s *SimpleSource) Pending(_ context.Context) int64
  • func (s *SimpleSource) Read(_ context.Context, readRequest sourcesdk.ReadRequest, ...)

Functions

func FileWatcher

func FileWatcher(watcher *fsnotify.Watcher, sideInputName string)

Types

type SimpleSource

type SimpleSource struct {
	// contains filtered or unexported fields
}

SimpleSource is a simple source implementation.

func NewSimpleSource

func NewSimpleSource() *SimpleSource

func (*SimpleSource) Ack

func (s *SimpleSource) Ack(_ context.Context, request sourcesdk.AckRequest)

func (*SimpleSource) Partitions

func (s *SimpleSource) Partitions(_ context.Context) []int32

func (*SimpleSource) Pending

func (s *SimpleSource) Pending(_ context.Context) int64

func (*SimpleSource) Read

func (s *SimpleSource) Read(_ context.Context, readRequest sourcesdk.ReadRequest, messageCh chan<- sourcesdk.Message)