liteq

package

v0.0.0-...-b868a91 Latest Latest Go to latest Published: May 3, 2019 License: BSD-2-Clause Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

const TimeWithMsSqlite = "STRFTIME('%Y-%m-%d %H:%M:%f', 'NOW')"

TimeWithMsSqlite ... Special constant to get a time with milliseconds. This is helpful for checkout as the timeout might be sub second

This section is empty.

This section is empty.

type Liteq struct {
	DB     *sql.DB
	Prefix string
	TTL    time.Duration
	// contains filtered or unexported fields
}

Liteq Structure for sqlite

func (l *Liteq) Commit(recipts []*gq.Receipt) error

Commit ... Removes any messages that bave been comsusumed by the b

func (l *Liteq) ConsumeBatch(size int) ([]*gq.ConsumerMessage, error)

ConsumeBatch ... This consumes a number of messages up to the limit

func (l *Liteq) Create() error

Create ... builds any required tables

func (l *Liteq) Destroy() error

Destroy ... removes any tables

func (l *Liteq) Exit() bool

Exit ...

func (l *Liteq) Publish(messages []*gq.Message) error

Publish ... This pushes a list of messages into the DB

func (l *Liteq) StopConsumer()

StopConsumer ... Stop consuming messages

func (l *Liteq) Stream(size int, messages chan []*gq.ConsumerMessage, pause time.Duration)

Stream ... Creates a stream of consumption