watcher

package
v0.0.0-...-1543d79 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 30, 2018 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MessageInfo

type MessageInfo struct {
	MessageID string
	Message   string
}

MessageInfo is the representation of a message from a queueing system

type Queue

type Queue interface {
	Setup()
	ReadNextMessage(url string) (*MessageInfo, error)
	DeleteMessage(messageID string, url string) error
}

Queue is the interface to specify a queue service

type QueueMonitor

type QueueMonitor struct {
	Queue Queue
}

QueueMonitor is the base system for creating unique queue monitors

type QueueWatcher

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

QueueWatcher is the aws sns implementation of the NotificationService

func (QueueWatcher) DeleteMessage

func (watcher QueueWatcher) DeleteMessage(messageID string, url string) error

DeleteMessage with ID from the specified queue

func (QueueWatcher) ReadNextMessage

func (watcher QueueWatcher) ReadNextMessage(url string) (*MessageInfo, error)

ReadNextMessage from the specified queue

func (*QueueWatcher) Setup

func (watcher *QueueWatcher) Setup()

Setup gets the watcher ready to use

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL