queue

Documentation

Index

• type Queue
  • func NewQueue(c *QueueConfig) *Queue
  • func (q *Queue) Flush() error
  • func (q *Queue) Push(values []interface{})
  • func (q *Queue) Run()
  • func (q *Queue) Stop() error
• type QueueConfig

Types

type Queue

type Queue struct {
	sync.Mutex
	*QueueConfig
	*time.Ticker
	// contains filtered or unexported fields
}

func NewQueue

func NewQueue(c *QueueConfig) *Queue

func (*Queue) Flush

func (q *Queue) Flush() error

func (*Queue) Push

func (q *Queue) Push(values []interface{})

func (*Queue) Run

func (q *Queue) Run()

func (*Queue) Stop

func (q *Queue) Stop() error

type QueueConfig

type QueueConfig struct {
	*sqlx.DB
	FlushInterval time.Duration
	FlushCount    int
	Sql           string
}