ping

package module

v1.1.48 Latest Latest Go to latest Published: Nov 7, 2025 License: Apache-2.0 Imports: 10 Imported by: 0

Details

This section is empty.

View Source

var ErrRetry = fmt.Errorf("retry")

func CtxLogger(ctx context.Context) *logrus.Entry

func GetLogger() *logrus.Logger

type Event struct {
	Id         string `json:"id"`
	Uid        string `json:"uid"`
	RetryCount int    `json:"retryCount"`
}

func (e *Event) Marshall() []byte

type Option struct {
	Prefix     string
	OfflineTTL int64
}

type Service struct {
	Prefix string
	// contains filtered or unexported fields
}

func NewService(redisClient redis.UniversalClient, opt *Option) *Service

func (s *Service) Ping(ctx context.Context, uid string) error

func (s *Service) RegisterOfflineHandle(f func(uid string) error)

func (s *Service) SetDebug(debug bool)

func (s *Service) StartTick()