new_session_channel

package

v1.2.54 Latest Latest Go to latest Published: Feb 21, 2024 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type QueueImpl struct {
}

func (this *QueueImpl) Empty(channel int64)

func (this *QueueImpl) GetLatest(channel int64, latestId int64) (newId int64)

func (this *QueueImpl) GetRedisListKey(channel int64) string

func (this *QueueImpl) Init() QueueInterface

func (this *QueueImpl) Push(channel int64, newId int64)

type QueueInterface interface {
	Empty(channel int64)
	Push(channel int64, newId int64)
	GetLatest(channel int64, latestId int64) (newId int64)
}

var Session QueueInterface