db

package
v0.0.0-...-be1249d Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 10, 2015 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Model

type Model struct {
	TableName string
	DB        *sql.DB
	Tx        *sql.Tx
	RWLock    sync.RWMutex
}

func NewModel

func NewModel(connectionString, name string) (model *Model, err error)

func (*Model) Add

func (m *Model) Add(key string, task []byte) (err error)

func (*Model) BatchTransaction

func (m *Model) BatchTransaction()

func (*Model) Count

func (m *Model) Count() int

func (*Model) Delete

func (m *Model) Delete(key string) (err error)

func (*Model) Read

func (m *Model) Read(offset, limit int) chan []byte

func (*Model) TransactionEnd

func (m *Model) TransactionEnd()

func (*Model) Update

func (m *Model) Update(key string, task []byte) (err error)

type QueueIteam

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

Jump to

Keyboard shortcuts

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