tools

package
v0.0.0-...-01b7989 Latest Latest
Warning

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

 Go to latest Published: Jan 4, 2025 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TimeFormatFull     = "2006-01-02 15:04:05.000"
	TimeFormatStandard = "2006-01-02 15:04:05"
	TimeFormatDate     = "2006-01-02"
	TimeFormatTime     = "15:04:05"
)

TimeFormat 常用时间格式

View Source 
const (
	KB = 1024
	MB = 1024 * KB
	GB = 1024 * MB
	TB = 1024 * GB
)

ByteSize 字节大小单位

Variables

View Source 
var (
	ErrTaskExists       = errors.New("任务已存在")
	ErrTaskNotFound     = errors.New("任务不存在")
	ErrSchedulerStopped = errors.New("调度器已停止")
)
View Source 
var DefaultLogger = NewDaoLogger()

全局默认日志器

Functions

func Debug 

func Debug(format string, args ...interface{})

全局日志函数

func DeepCopy 

func DeepCopy(src interface{}, dst interface{}) error

DeepCopy 深拷贝

func EnsureDir 

func EnsureDir(path string) error

EnsureDir 确保目录存在，如果不存在则创建

func Error 

func Error(format string, args ...interface{})

func Fatal 

func Fatal(format string, args ...interface{})

func FormatFileSize 

func FormatFileSize(size int64) string

FormatFileSize 格式化文件大小

func GetCurrentDirectory 

func GetCurrentDirectory() string

GetCurrentDirectory 获取当前工作目录

func GetExecutablePath 

func GetExecutablePath() (string, error)

GetExecutablePath 获取可执行文件路径

func Info 

func Info(format string, args ...interface{})

func IsValidEmail 

func IsValidEmail(email string) bool

IsValidEmail 验证邮箱格式

func MD5 

func MD5(str string) string

MD5 计算字符串的 MD5 值

func PathExists 

func PathExists(path string) (bool, error)

PathExists 检查路径是否存在

func RandomString 

func RandomString(length int) string

RandomString 生成指定长度的随机字符串

func Retry 

func Retry(attempts int, sleep time.Duration, fn func() error) error

Retry 重试执行函数

func SHA256 

func SHA256(str string) string

SHA256 计算字符串的 SHA256 值

func TruncateString 

func TruncateString(str string, length int) string

TruncateString 截断字符串

func Warn 

func Warn(format string, args ...interface{})

Types

type AsyncRunner 

type AsyncRunner struct {
	// contains filtered or unexported fields
}

AsyncRunner 异步任务运行器

func NewAsyncRunner 

func NewAsyncRunner() *AsyncRunner

NewAsyncRunner 创建异步任务运行器

func (*AsyncRunner) Run 

func (r *AsyncRunner) Run(fn func())

Run 运行异步任务

func (*AsyncRunner) Wait 

func (r *AsyncRunner) Wait()

Wait 等待所有任务完成

type ConfigFormat 

type ConfigFormat string

ConfigFormat 配置文件格式 

const (
	FormatJSON ConfigFormat = "json"
	FormatXML  ConfigFormat = "xml"
	FormatYAML ConfigFormat = "yaml"
)

type ConfigOption 

type ConfigOption struct {
	AutoReload     bool          // 自动重载
	ReloadInterval time.Duration // 重载间隔
	BackupCount    int           // 备份数量
	Format         ConfigFormat  // 配置格式
}

ConfigOption 配置选项

type ConfigWatcher 

type ConfigWatcher interface {
	OnConfigChange(oldConfig, newConfig map[string]interface{})
}

ConfigWatcher 配置变更观察者

type DaoConfig 

type DaoConfig struct {
	// contains filtered or unexported fields
}

DaoConfig 配置管理器

func NewDaoConfig 

func NewDaoConfig(filepath string, opt ConfigOption) (*DaoConfig, error)

NewDaoConfig 创建新的配置管理器

func (*DaoConfig) AddWatcher 

func (dc *DaoConfig) AddWatcher(watcher ConfigWatcher)

AddWatcher 添加配置观察者

func (*DaoConfig) Close 

func (dc *DaoConfig) Close() error

Close 关闭配置管理器

func (*DaoConfig) Delete 

func (dc *DaoConfig) Delete(key string)

Delete 删除配置项

func (*DaoConfig) Get 

func (dc *DaoConfig) Get(key string) (interface{}, bool)

Get 获取配置项

func (*DaoConfig) Load 

func (dc *DaoConfig) Load() error

Load 加载配置文件

func (*DaoConfig) Save 

func (dc *DaoConfig) Save() error

Save 保存配置到文件

func (*DaoConfig) Set 

func (dc *DaoConfig) Set(key string, value interface{})

Set 设置配置项

type DaoLogger 

type DaoLogger struct {
	// contains filtered or unexported fields
}

DaoLogger 道家风格的日志器

func NewDaoLogger 

func NewDaoLogger(options ...LoggerOption) *DaoLogger

NewDaoLogger 创建新的日志器

func (*DaoLogger) Debug 

func (dl *DaoLogger) Debug(format string, args ...interface{})

Debug 调试日志

func (*DaoLogger) Error 

func (dl *DaoLogger) Error(format string, args ...interface{})

Error 错误日志

func (*DaoLogger) Fatal 

func (dl *DaoLogger) Fatal(format string, args ...interface{})

Fatal 致命错误日志

func (*DaoLogger) Info 

func (dl *DaoLogger) Info(format string, args ...interface{})

Info 信息日志

func (*DaoLogger) Rotate 

func (dl *DaoLogger) Rotate() error

Rotate 日志轮转

func (*DaoLogger) Warn 

func (dl *DaoLogger) Warn(format string, args ...interface{})

Warn 警告日志

type DaoScheduler 

type DaoScheduler struct {
	// contains filtered or unexported fields
}

DaoScheduler 调度器

func NewDaoScheduler 

func NewDaoScheduler(maxWorkers int) *DaoScheduler

NewDaoScheduler 创建新的调度器

func (*DaoScheduler) AddScheduledTask 

func (ds *DaoScheduler) AddScheduledTask(id string, name string, fn TaskFunc, interval time.Duration) error

AddScheduledTask 添加定时任务

func (*DaoScheduler) AddTask 

func (ds *DaoScheduler) AddTask(id string, name string, fn TaskFunc, priority TaskPriority) error

AddTask 添加任务

func (*DaoScheduler) GetTaskStatus 

func (ds *DaoScheduler) GetTaskStatus(id string) (TaskStatus, error)

GetTaskStatus 获取任务状态

func (*DaoScheduler) IsRunning 

func (ds *DaoScheduler) IsRunning() bool

IsRunning 检查调度器是否运行中

func (*DaoScheduler) RemoveTask 

func (ds *DaoScheduler) RemoveTask(id string) error

RemoveTask 移除任务

func (*DaoScheduler) Start 

func (ds *DaoScheduler) Start()

Start 启动调度器

func (*DaoScheduler) Stop 

func (ds *DaoScheduler) Stop()

Stop 停止调度器

type LogLevel 

type LogLevel int

LogLevel 日志级别 

const (
	DebugLevel LogLevel = iota
	InfoLevel
	WarnLevel
	ErrorLevel
	FatalLevel
)

type LoggerOption 

type LoggerOption func(*DaoLogger)

LoggerOption 日志配置选项

func WithFile 

func WithFile(filename string) LoggerOption

WithFile 添加文件输出

func WithLevel 

func WithLevel(level LogLevel) LoggerOption

WithLevel 设置日志级别

type MemoryCache 

type MemoryCache struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

MemoryCache 简单的内存缓存实现

func NewMemoryCache 

func NewMemoryCache() *MemoryCache

NewMemoryCache 创建新的内存缓存

func (*MemoryCache) Delete 

func (c *MemoryCache) Delete(key string)

Delete 删除缓存

func (*MemoryCache) Get 

func (c *MemoryCache) Get(key string) (interface{}, bool)

Get 获取缓存

func (*MemoryCache) Set 

func (c *MemoryCache) Set(key string, value interface{}, duration time.Duration)

Set 设置缓存

type RuntimeStats 

type RuntimeStats struct {
	GoVersion    string
	GOOS         string
	GOARCH       string
	NumCPU       int
	NumGoroutine int
	MemStats     runtime.MemStats
}

RuntimeStats 运行时统计信息

func GetRuntimeStats 

func GetRuntimeStats() RuntimeStats

GetRuntimeStats 获取运行时统计信息

type Task 

type Task struct {
	ID       string
	Name     string
	Func     TaskFunc
	Priority TaskPriority
	Status   TaskStatus
	Interval time.Duration // 定时任务间隔
	NextRun  time.Time
	LastRun  time.Time
	Error    error
	Context  context.Context
	Cancel   context.CancelFunc
}

Task 任务结构

type TaskFunc 

type TaskFunc func(ctx context.Context) error

TaskFunc 任务函数类型

type TaskPriority 

type TaskPriority int

TaskPriority 任务优先级 

const (
	PriorityLow TaskPriority = iota
	PriorityNormal
	PriorityHigh
	PriorityCritical
)

type TaskStatus 

type TaskStatus int

TaskStatus 任务状态 

const (
	StatusPending TaskStatus = iota
	StatusRunning
	StatusCompleted
	StatusFailed
	StatusCancelled
)

Source Files

View all Source files

Directories

Path Synopsis
tools/async/pool.go
 tools/async/pool.go
tools/cache/cache.go
 tools/cache/cache.go
tools/common/types.go
 tools/common/types.go
tools/config/config.go
 tools/config/config.go
tools/logger/logger.go
 tools/logger/logger.go
tools/scheduler/scheduler.go
 tools/scheduler/scheduler.go

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.