watcher

Documentation

Index

• type MessageInfo
• type Queue
• type QueueMonitor
• type QueueWatcher
  • func (watcher QueueWatcher) DeleteMessage(messageID string, url string) error
  • func (watcher QueueWatcher) ReadNextMessage(url string) (*MessageInfo, error)
  • func (watcher *QueueWatcher) Setup()

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