global

Documentation

Index

• Constants
• Variables
• type Application
• type DeferTask
  • func NewDeferTask(f func(...any), params ...any) *DeferTask
  • func (t *DeferTask) Execute()
• type DelayTask
  • func NewDelayTask(f func(...any), t time.Duration, params []any) *DelayTask
  • func (t *DelayTask) Execute()
• type PeriodTask
  • func NewPeriodTask(f func(...any), t time.Duration, params []any) *PeriodTask
  • func (t *PeriodTask) Execute()
• type Task

Constants

const (
	GOENVDev  = "dev"  // 开发环境
	GOENVProd = "prod" // 生产环境
)

Variables

var App = new(Application)

var DeferTaskQueue []*DeferTask

DeferTaskQueue 延迟任务队列

Types

type Application

type Application struct {
	Config           config.Configuration
	Log              *zap.Logger
	Engine           *gin.Engine
	MongoDB          *mongo.Client
	TiDB             *sql.DB
	Redis            *redis.Client
	WebSocketManager *ws.WebSocketManager
	MQChannel        *amqp.Channel
}

type DeferTask

type DeferTask struct {
	Function func(...any)
	Params   []any
}

DeferTask 释放资源

func NewDeferTask

func NewDeferTask(f func(...any), params ...any) *DeferTask

NewDeferTask 创建资源释放任务

func (*DeferTask) Execute

func (t *DeferTask) Execute()

type DelayTask

type DelayTask struct {
	Function func(...any)
	Params   []any
	Time     time.Duration
}

DelayTask 延迟任务

func NewDelayTask

func NewDelayTask(f func(...any), t time.Duration, params []any) *DelayTask

NewDelayTask 创建延迟任务

func (*DelayTask) Execute

func (t *DelayTask) Execute()

type PeriodTask

type PeriodTask struct {
	Function func(...any)
	Params   []any
	Time     time.Duration // TaskTypeDelay => 多长时间后执行; TaskTypeDefer => 无效; TaskTypePeriod => 执行的周期
}

PeriodTask 周期任务

func NewPeriodTask

func NewPeriodTask(f func(...any), t time.Duration, params []any) *PeriodTask

NewPeriodTask 创建周期任务

func (*PeriodTask) Execute

func (t *PeriodTask) Execute()

type Task

type Task interface {
	Execute()
}