delay

package
v0.0.0-...-e55934f Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 6, 2022 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DoneDelay

func DoneDelay(msg string) error

DoneDelay DoneDelay

Types

type API

type API struct {
	Service Service
}

API API

func ProvideAPI

func ProvideAPI(service Service) API

ProvideAPI ProvideAPI

func (*API) Callback

func (a *API) Callback(c *gin.Context)

Callback Callback

func (*API) Send

func (a *API) Send(c *gin.Context)

Send Send

type Service

type Service struct {
	Producer *nsq.Producer
	Redis    *redis.Client
}

Service Service

func ProvideService

func ProvideService(p *nsq.Producer, redis *redis.Client) Service

ProvideService ProvideService

func (*Service) CheckUnionKey

func (s *Service) CheckUnionKey(id string) bool

CheckUnionKey CheckUnionKey

func (*Service) DeferredPublish

func (s *Service) DeferredPublish(topic string, delay time.Duration, body []byte) error

DeferredPublish DeferredPublish

func (*Service) Publish

func (s *Service) Publish(topic string, body []byte) error

Publish Publish

func (*Service) SetUnionKey

func (s *Service) SetUnionKey(id string) bool

SetUnionKey SetUnionKey

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL