Documentation ¶
Overview ¶
Package file implements a file-system producer.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewPublisher ¶
NewPublisher inits a publisher within a root directory.
func NewSubscriber ¶
func NewSubscriber(root string) bps.Subscriber
NewSubscriber inits a subscriber within a root directory. It assumes, that file is not being written to anymore. It starts handling from the first (oldest) available message. It iterates entire file (all records) without tracking processed messages.
Types ¶
Click to show internal directories.
Click to hide internal directories.