passthroughqueue

Documentation

Index

• Variables
• func Factory(loader func(v interface{}) error) (notificationqueue.Directive, error)
• type Passthroughqueue
  • func New() *Passthroughqueue
  • func (q *Passthroughqueue) AppylToPublisher(p *notificationqueue.Publisher) error
  • func (q *Passthroughqueue) AttachTo(n *notificationqueue.Notifier) error
  • func (pq *Passthroughqueue) Detach() error
  • func (q *Passthroughqueue) PopChan() (<-chan *notificationqueue.Execution, error)
  • func (q *Passthroughqueue) Push(n *notification.Notification) error
  • func (q *Passthroughqueue) Remove(nid string) error
  • func (q *Passthroughqueue) Start() error
  • func (q *Passthroughqueue) Stop() error

Variables

var DirectiveName = "passthroughqueue"

Functions

func Factory

func Factory(loader func(v interface{}) error) (notificationqueue.Directive, error)

Types

type Passthroughqueue

type Passthroughqueue struct {
	IDGenerator func() (string, error)
	// contains filtered or unexported fields
}

func New

func New() *Passthroughqueue

func (*Passthroughqueue) AppylToPublisher

func (q *Passthroughqueue) AppylToPublisher(p *notificationqueue.Publisher) error

func (*Passthroughqueue) AttachTo

func (q *Passthroughqueue) AttachTo(n *notificationqueue.Notifier) error

AttachTo attach queue to notifier

func (*Passthroughqueue) Detach

func (pq *Passthroughqueue) Detach() error

Detach detach queue.

func (*Passthroughqueue) PopChan

func (q *Passthroughqueue) PopChan() (<-chan *notificationqueue.Execution, error)

PopChan return execution chan

func (*Passthroughqueue) Push

func (q *Passthroughqueue) Push(n *notification.Notification) error

Push push notification to queue

func (*Passthroughqueue) Remove

func (q *Passthroughqueue) Remove(nid string) error

Remove remove notification by given id

func (*Passthroughqueue) Start

func (q *Passthroughqueue) Start() error

Start start queue

func (*Passthroughqueue) Stop

func (q *Passthroughqueue) Stop() error

Stop stop queue