Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func FileWatcher ¶
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) Read ¶
func (s *SimpleSource) Read(_ context.Context, readRequest sourcesdk.ReadRequest, messageCh chan<- sourcesdk.Message)
Source Files
Click to show internal directories.
Click to hide internal directories.