Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type QueueManager ¶
type QueueManager struct {
// contains filtered or unexported fields
}
func NewQueueManager ¶
func NewQueueManager(repository interface_repository.RepositoryInterface, queue interface_queue.QueueInterface) *QueueManager
func (*QueueManager) ReadQueueItem ¶
func (state *QueueManager) ReadQueueItem() *flowfiles.Flowfile
func (*QueueManager) Receive ¶
func (state *QueueManager) Receive(context actor.Context)
func (*QueueManager) WriteQueueItem ¶
func (state *QueueManager) WriteQueueItem(item *flowfiles.Flowfile) error
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.