queued

package

Go to main page

Versions in this module

v0

v0.1.4

Oct 19, 2013

Changes in this version

+ const Version

v0.1.3

Sep 27, 2013

Changes in this version

type Record

+ Mime string

+ func (r *Record) ContentType() string

v0.1.2

Sep 16, 2013

Changes in this version

type Config

+ Store string

+ func (c *Config) CreateStore() Store

type Iterator

+ NextRecord func() (*Record, bool)

+ type LevelIterator struct

+ func (it *LevelIterator) NextRecord() (*Record, bool)

+ type LevelStore struct

+ func NewLevelStore(path string, sync bool) *LevelStore

+ func (s *LevelStore) Close()

+ func (s *LevelStore) Drop()

+ func (s *LevelStore) Get(id int) (*Record, error)

+ func (s *LevelStore) Iterator() Iterator

+ func (s *LevelStore) Put(record *Record) error

+ func (s *LevelStore) Remove(id int) error

+ type MemoryIterator struct

+ func (it *MemoryIterator) NextRecord() (*Record, bool)

+ type MemoryStore struct

+ func NewMemoryStore() *MemoryStore

+ func (s *MemoryStore) Drop()

+ func (s *MemoryStore) Get(id int) (*Record, error)

+ func (s *MemoryStore) Iterator() Iterator

+ func (s *MemoryStore) Put(record *Record) error

+ func (s *MemoryStore) Remove(id int) error

v0.1.1

Sep 7, 2013

Changes in this version

type Application

+ func (a *Application) Stats(name string) map[string]int

type Queue

+ func (q *Queue) Stats() map[string]int

type Server

+ func (s *Server) StatsHandler(w http.ResponseWriter, req *http.Request)

+ type Stats struct

+ Counters map[string]int

+ func NewStats(counters map[string]int) *Stats

+ func (s *Stats) Dec(field string)

+ func (s *Stats) Get() map[string]int

+ func (s *Stats) Inc(field string)

v0.1.0

Sep 5, 2013

Changes in this version

+ const NilDuration

+ func Stod(val string, scale ...time.Duration) (time.Duration, error)

+ type Application struct

+ func NewApplication(store *Store) *Application

+ func (a *Application) Complete(name string, id int) (bool, error)

+ func (a *Application) Dequeue(name string, wait time.Duration, timeout time.Duration) (*Record, error)

+ func (a *Application) Enqueue(name string, value []byte) (*Record, error)

+ func (a *Application) GetItem(id int) (*Item, bool)

+ func (a *Application) GetQueue(name string) *Queue

+ func (a *Application) Info(name string, id int) (*Info, error)

+ func (a *Application) PutItem(item *Item)

+ func (a *Application) RemoveItem(id int)

+ type Config struct

+ Auth string

+ DbPath string

+ Port uint

+ Sync bool

+ func NewConfig() *Config

+ type Info struct

+ type Item struct

+ func NewItem(value int) *Item

+ func (item *Item) Complete()

+ type Iterator struct

+ func NewIterator(db *levigo.DB) *Iterator

+ func (it *Iterator) Record() *Record

+ type Json map[string]interface

+ type Queue struct

+ func NewQueue() *Queue

+ func (q *Queue) Dequeue(wait time.Duration, timeout time.Duration) *Item

+ func (q *Queue) Enqueue(value int) *Item

+ func (q *Queue) EnqueueItem(item *Item)

+ func (q *Queue) Stop()

+ type Reader struct

+ func NewReader(wait time.Duration, timeout time.Duration, expire func(*Item)) *Reader

+ func (r *Reader) Receive() *Item

+ func (r *Reader) Send(item *Item)

+ func (r *Reader) Timeout(item *Item)

+ func (r *Reader) Wait(ch chan *Item)

+ type Record struct

+ Queue string

+ Value []byte

+ func NewRecord(value []byte, queue string) *Record

+ type Server struct

+ Addr string

+ App *Application

+ Config *Config

+ Router *mux.Router

+ Store *Store

+ func NewServer(config *Config) *Server

+ func (s *Server) BeforeHandler(w http.ResponseWriter, req *http.Request) bool

+ func (s *Server) CompleteHandler(w http.ResponseWriter, req *http.Request)

+ func (s *Server) DequeueHandler(w http.ResponseWriter, req *http.Request)

+ func (s *Server) EnqueueHandler(w http.ResponseWriter, req *http.Request)

+ func (s *Server) HandleFunc(route string, fn func(http.ResponseWriter, *http.Request)) *mux.Route

+ func (s *Server) InfoHandler(w http.ResponseWriter, req *http.Request)

+ func (s *Server) ListenAndServe() error

+ func (s *Server) ServeHTTP(w http.ResponseWriter, req *http.Request)

+ type Store struct

+ func NewStore(path string, sync bool) *Store

+ func (s *Store) Close()

+ func (s *Store) Drop()

+ func (s *Store) Get(id int) (*Record, error)

+ func (s *Store) Iterator() *Iterator

+ func (s *Store) Put(record *Record) error

+ func (s *Store) Remove(id int) error

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