utils

Documentation

Index

• type OpsQueue
  • func NewOpsQueue(logger logger.Logger, name string, size int) *OpsQueue
  • func (oq *OpsQueue) Enqueue(op func())
  • func (oq *OpsQueue) IsStarted() bool
  • func (oq *OpsQueue) SetLogger(logger logger.Logger)
  • func (oq *OpsQueue) Start()
  • func (oq *OpsQueue) Stop()

Types

type OpsQueue

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

func NewOpsQueue

func NewOpsQueue(logger logger.Logger, name string, size int) *OpsQueue

func (*OpsQueue) Enqueue

func (oq *OpsQueue) Enqueue(op func())

func (*OpsQueue) IsStarted

func (oq *OpsQueue) IsStarted() bool

func (*OpsQueue) SetLogger

func (oq *OpsQueue) SetLogger(logger logger.Logger)

func (*OpsQueue) Start

func (oq *OpsQueue) Start()

func (*OpsQueue) Stop

func (oq *OpsQueue) Stop()