Documentation ¶
Index ¶
- func NewBaseLevelOption() *baseLevelOption
- func NewConfigInitOption() *configInitOption
- func NewCurrentIdOption() *currentIdOption
- func NewPoolOption() *poolOption
- func NewProtocolOption() *protocolOption
- func NewReloadOption() *reloadOption
- func NewRunnerOption() *runnerOption
- func NewStoreOption() *storeOption
- func NewTimerOption() *timerOption
- func NewTransportersOption() *transportersOption
- func NewWorkerOption() *workerOption
- type DelayQueue
- type InitOption
- type InitStoreFunc
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewBaseLevelOption ¶
func NewBaseLevelOption() *baseLevelOption
func NewConfigInitOption ¶
func NewConfigInitOption() *configInitOption
func NewCurrentIdOption ¶
func NewCurrentIdOption() *currentIdOption
func NewPoolOption ¶
func NewPoolOption() *poolOption
func NewProtocolOption ¶
func NewProtocolOption() *protocolOption
func NewReloadOption ¶
func NewReloadOption() *reloadOption
func NewRunnerOption ¶
func NewRunnerOption() *runnerOption
func NewStoreOption ¶
func NewStoreOption() *storeOption
func NewTimerOption ¶
func NewTimerOption() *timerOption
func NewTransportersOption ¶
func NewTransportersOption() *transportersOption
func NewWorkerOption ¶
func NewWorkerOption() *workerOption
Types ¶
type DelayQueue ¶
type DelayQueue struct {
// contains filtered or unexported fields
}
func NewDelayQueue ¶
func NewDelayQueue(opts ...InitOption) *DelayQueue
func (*DelayQueue) Run ¶
func (dq *DelayQueue) Run() error
type InitOption ¶
type InitOption interface { Run(*DelayQueue) error Stop(*DelayQueue) error }
func AcquireServerInits ¶
func AcquireServerInits() []InitOption
type InitStoreFunc ¶
type InitStoreFunc func(*DelayQueue) error
Source Files ¶
Click to show internal directories.
Click to hide internal directories.