service

Documentation

Index

• type NotificationQueue
  • func NewNotificationQueue() *NotificationQueue
  • func (queue *NotificationQueue) Notifications(name string) []*notification.Notification
  • func (queue *NotificationQueue) Notify(notification *notification.Notification)
• type Service

Types

type NotificationQueue

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

func NewNotificationQueue

func NewNotificationQueue() *NotificationQueue

func (*NotificationQueue) Notifications

func (queue *NotificationQueue) Notifications(name string) []*notification.Notification

func (*NotificationQueue) Notify

func (queue *NotificationQueue) Notify(notification *notification.Notification)

type Service

type Service interface {
	Start(*NotificationQueue, log.Logger) error
	Configure(*config.GAkisitorConfig) error
	Process() error
	Stop() error

	Name() string
	State() byte
}