embeddedqueue

Documentation

Index

• Variables
• func Factory(loader func(v interface{}) error) (notificationqueue.Directive, error)
• type Config
  • func (c *Config) AppylToPublisher(p *notificationqueue.Publisher) error
• type Engine
  • func New() *Engine
  • func (e *Engine) Insert(execution *notificationqueue.Execution) error
  • func (e *Engine) List(start string, count int) ([]*notificationqueue.Execution, string, error)
  • func (e *Engine) Remove(nid string) error
  • func (e *Engine) Replace(eid string, new *notificationqueue.Execution) error
  • func (e *Engine) Start() error
  • func (e *Engine) Stop() error

Variables

var DirectiveName = "embeddedqueue"

Functions

func Factory

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

Types

type Config

type Config struct {
	Engine kvdb.Config
	Queue  cronqueue.Config
	Retry  *cronqueue.PlainRetry
}

func (*Config) AppylToPublisher

func (c *Config) AppylToPublisher(p *notificationqueue.Publisher) error

type Engine

type Engine struct {
	DB *kvdb.Database
	// contains filtered or unexported fields
}

Engine embedded store

func New

func New() *Engine

New create embedded store

func (*Engine) Insert

func (e *Engine) Insert(execution *notificationqueue.Execution) error

Insert insert execution to queue. Do nothing if notifiaction exsits

func (*Engine) List

func (e *Engine) List(start string, count int) ([]*notificationqueue.Execution, string, error)

List list queued Execution form start

func (*Engine) Remove

func (e *Engine) Remove(nid string) error

Remove notifcation with given nid form queue. Do nothing if notificatio not found

func (*Engine) Replace

func (e *Engine) Replace(eid string, new *notificationqueue.Execution) error

Replace exectution in queue with given eid. Do nothing if eid not match.

func (*Engine) Start

func (e *Engine) Start() error

Start start store

func (*Engine) Stop

func (e *Engine) Stop() error

Stop stop store