producer

Documentation

Index

• func IsEnableAsync() bool
• type AsyncProducer
  • func NewDbAsyncProducer(workerChan chan<- interface{}) *AsyncProducer
  • func (p *AsyncProducer) IsStart() bool
  • func (p *AsyncProducer) Produce(asyncFunc interface{})
  • func (p *AsyncProducer) Start()
  • func (p *AsyncProducer) Stop()

Functions

func IsEnableAsync

func IsEnableAsync() bool

IsEnableAsync 是否开启异步

Types

type AsyncProducer

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

AsyncProducer DB异步操作生产者

var (
	AsyncProducerInstance *AsyncProducer
)

func NewDbAsyncProducer

func NewDbAsyncProducer(workerChan chan<- interface{}) *AsyncProducer

func (*AsyncProducer) IsStart

func (p *AsyncProducer) IsStart() bool

IsStart 是否启动

func (*AsyncProducer) Produce

func (p *AsyncProducer) Produce(asyncFunc interface{})

Produce 生产

func (*AsyncProducer) Start

func (p *AsyncProducer) Start()

Start 启动

func (*AsyncProducer) Stop

func (p *AsyncProducer) Stop()

Stop 关闭