Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

gojobs

package module

Go to main page

Versions in this module

v1

v1.0.163

Aug 19, 2024

v1.0.162

Jul 31, 2024

v1.0.161

Jul 31, 2024

Changes in this version

+ func EntTaskAnnotations() []schema.Annotation

+ func EntTaskFields() []ent.Field

+ func EntTaskIndexes() []ent.Index

+ func EntTaskLogAnnotations() []schema.Annotation

+ func EntTaskLogFields() []ent.Field

+ func EntTaskLogIndexes() []ent.Index

v1.0.160

Jul 26, 2024

v1.0.159

Jul 26, 2024

v1.0.158

Jul 23, 2024

v1.0.157

Jul 13, 2024

Changes in this version

+ const CodeAbnormal

+ const CodeEnd

+ const CodeError

+ const CodeSuccess

+ const SpecifyIpNull

+ const TASK_ERROR

+ const TASK_IN

+ const TASK_SUCCESS

+ const TASK_TIMEOUT

+ const TASK_WAIT

+ const Version

+ func GetRedisKeyName(taskType string) string

+ func NewTraceStartSpan(ctx context.Context, spanName string) (context.Context, trace.Span)

+ func SetRedisKeyValue(ctx context.Context, taskType string) (context.Context, string, any, time.Duration)

+ func SetRedisKeyValueExpiration(ctx context.Context, taskType string, expiration int64) (context.Context, string, any, time.Duration)

+ func TraceEndSpan(span trace.Span)

+ func TraceGetSpanID(ctx context.Context) (spanID string)

+ func TraceGetTraceID(ctx context.Context) (traceID string)

+ func TraceRecordError(ctx context.Context, err error, options ...trace.EventOption)

+ func TraceSetAttributes(ctx context.Context, kv ...attribute.KeyValue)

+ func TraceSetStatus(ctx context.Context, code codes.Code, description string)

+ func TraceStartSpan(ctx context.Context, spanName string) (context.Context, trace.Span)

+ type Client struct

+ func NewClient(ctx context.Context, currentIP string) (*Client, error)

+ func (c *Client) ConfigGormClientFun(ctx context.Context, client *gorm.DB, taskTableName string, taskLogStatus bool, ...) error

+ func (c *Client) ConfigRedisClientFun(ctx context.Context, client *redis.Client, lockKeyPrefix string, ...) error

+ func (c *Client) CreateInCustomId(ctx context.Context, config *ConfigCreateInCustomId) error

+ func (c *Client) CreateInCustomIdMaxNumber(ctx context.Context, config *ConfigCreateInCustomIdMaxNumber) error

+ func (c *Client) CreateInCustomIdMaxNumberOnly(ctx context.Context, config *ConfigCreateInCustomIdMaxNumberOnly) error

+ func (c *Client) CreateInCustomIdOnly(ctx context.Context, config *ConfigCreateInCustomIdOnly) error

+ func (c *Client) CreateWaitCustomId(ctx context.Context, config *ConfigCreateWaitCustomId) error

+ func (c *Client) EditTask(ctx context.Context, tx *gorm.DB, id uint) *gorm.DB

+ func (c *Client) EndHandle(ctx context.Context, key any)

+ func (c *Client) Filter(ctx context.Context, isMandatoryIp bool, specifyIp string, ...) (newTasks []GormModelTask)

+ func (c *Client) GetCurrentIp() string

+ func (c *Client) GetDb() *gorm.DB

+ func (c *Client) GetGormDb() *gorm.DB

+ func (c *Client) GetIssueAddress(ctx context.Context, workers []string, v *GormModelTask) (string, error)

+ func (c *Client) GetRedisDb() *redis.Client

+ func (c *Client) GetSubscribeAddress() string

+ func (c *Client) GetSubscribeClientList(ctx context.Context) (client []string, err error)

+ func (c *Client) GormTaskLogDelete(ctx context.Context, hour int64) error

+ func (c *Client) GormTaskLogErrorDelete(ctx context.Context, hour int64) error

+ func (c *Client) GormTaskLogInDelete(ctx context.Context, hour int64) error

+ func (c *Client) GormTaskLogRecord(ctx context.Context, task GormModelTask, runId string, taskResultCode int, ...)

+ func (c *Client) GormTaskLogSuccessDelete(ctx context.Context, hour int64) error

+ func (c *Client) GormTaskLogTimeoutDelete(ctx context.Context, hour int64) error

+ func (c *Client) GormTaskLogWaitDelete(ctx context.Context, hour int64) error

+ func (c *Client) Lock(ctx context.Context, info *GormModelTask, id any) (string, error)

+ func (c *Client) LockCustomId(ctx context.Context, info *GormModelTask) (string, error)

+ func (c *Client) LockForever(ctx context.Context, info *GormModelTask, id any) (string, error)

+ func (c *Client) LockForeverCustomId(ctx context.Context, info *GormModelTask) (string, error)

+ func (c *Client) LockForeverId(ctx context.Context, info *GormModelTask) (string, error)

+ func (c *Client) LockId(ctx context.Context, info *GormModelTask) (string, error)

+ func (c *Client) NewLock(task *GormModelTask) (*TaskLockOperation, error)

+ func (c *Client) PSubscribe(ctx context.Context) SubscribeResult

+ func (c *Client) Publish(ctx context.Context, channel string, message interface{}) error

+ func (c *Client) Run(ctx context.Context, task GormModelTask, taskResultCode int, ...)

+ func (c *Client) StartCronClean(ctx context.Context, cr *cron.Cron, cp string, hour int64) (cron.EntryID, error)

+ func (c *Client) StartHandle(ctx context.Context, key any, overdue int64) error

+ func (c *Client) StartTask(ctx context.Context, tx *gorm.DB, id uint) error

+ func (c *Client) StartTaskCustom(ctx context.Context, tx *gorm.DB, customId string, customSequence int64) error

+ func (c *Client) Subscribe(ctx context.Context) SubscribeResult

+ func (c *Client) TaskFindAll(ctx context.Context, tx *gorm.DB, frequency int64) (results []GormModelTask)

+ func (c *Client) TaskFindAllError(ctx context.Context, tx *gorm.DB, frequency int64) []GormModelTask

+ func (c *Client) TaskFindAllErrorType(ctx context.Context, tx *gorm.DB, Type string) []GormModelTask

+ func (c *Client) TaskFindAllIn(ctx context.Context, tx *gorm.DB, frequency int64) []GormModelTask

+ func (c *Client) TaskFindAllInType(ctx context.Context, tx *gorm.DB, Type string) []GormModelTask

+ func (c *Client) TaskFindAllSuccess(ctx context.Context, tx *gorm.DB, frequency int64) []GormModelTask

+ func (c *Client) TaskFindAllSuccessType(ctx context.Context, tx *gorm.DB, Type string) []GormModelTask

+ func (c *Client) TaskFindAllTimeout(ctx context.Context, tx *gorm.DB, frequency int64) []GormModelTask

+ func (c *Client) TaskFindAllTimeoutType(ctx context.Context, tx *gorm.DB, Type string) []GormModelTask

+ func (c *Client) TaskFindAllType(ctx context.Context, tx *gorm.DB, Type string, frequency int64) (results []GormModelTask)

+ func (c *Client) TaskFindAllWait(ctx context.Context, tx *gorm.DB, frequency int64) []GormModelTask

+ func (c *Client) TaskFindAllWaitType(ctx context.Context, tx *gorm.DB, Type string) []GormModelTask

+ func (c *Client) TaskTake(ctx context.Context, tx *gorm.DB, customId string) (result GormModelTask)

+ func (c *Client) TaskTakeError(ctx context.Context, tx *gorm.DB, customId string) GormModelTask

+ func (c *Client) TaskTakeId(ctx context.Context, tx *gorm.DB, id uint) (result GormModelTask)

+ func (c *Client) TaskTakeIn(ctx context.Context, tx *gorm.DB, customId string) GormModelTask

+ func (c *Client) TaskTakeSuccess(ctx context.Context, tx *gorm.DB, customId string) GormModelTask

+ func (c *Client) TaskTakeTimeout(ctx context.Context, tx *gorm.DB, customId string) GormModelTask

+ func (c *Client) TaskTakeWait(ctx context.Context, tx *gorm.DB, customId string) GormModelTask

+ func (c *Client) TaskTypeTake(ctx context.Context, tx *gorm.DB, customId, Type string) (result GormModelTask)

+ func (c *Client) TaskTypeTakeError(ctx context.Context, tx *gorm.DB, customId, Type string) GormModelTask

+ func (c *Client) TaskTypeTakeIn(ctx context.Context, tx *gorm.DB, customId, Type string) GormModelTask

+ func (c *Client) TaskTypeTakeSuccess(ctx context.Context, tx *gorm.DB, customId, Type string) GormModelTask

+ func (c *Client) TaskTypeTakeTimeout(ctx context.Context, tx *gorm.DB, customId, Type string) GormModelTask

+ func (c *Client) TaskTypeTakeWait(ctx context.Context, tx *gorm.DB, customId, Type string) GormModelTask

+ func (c *Client) Unlock(ctx context.Context, info *GormModelTask, id any) error

+ func (c *Client) UnlockCustomId(ctx context.Context, info *GormModelTask) error

+ func (c *Client) UnlockId(ctx context.Context, info *GormModelTask) error

+ func (c *Client) UpdateFrequency(ctx context.Context, tx *gorm.DB, id uint, frequency int64) error

+ type ConfigCreateInCustomId struct

+ CurrentIP string

+ CustomID string

+ CustomSequence int64

+ Frequency int64

+ Params string

+ Spec string

+ SpecifyIP string

+ Tx *gorm.DB

+ Type string

+ TypeName string

+ type ConfigCreateInCustomIdMaxNumber struct

+ CurrentIP string

+ CustomID string

+ CustomSequence int64

+ Frequency int64

+ MaxNumber int64

+ Params string

+ Spec string

+ SpecifyIP string

+ Tx *gorm.DB

+ Type string

+ TypeName string

+ type ConfigCreateInCustomIdMaxNumberOnly struct

+ CurrentIP string

+ CustomID string

+ CustomSequence int64

+ Frequency int64

+ MaxNumber int64

+ Params string

+ Spec string

+ SpecifyIP string

+ Tx *gorm.DB

+ Type string

+ TypeName string

+ type ConfigCreateInCustomIdOnly struct

+ CurrentIP string

+ CustomID string

+ CustomSequence int64

+ Frequency int64

+ Params string

+ Spec string

+ SpecifyIP string

+ Tx *gorm.DB

+ Type string

+ TypeName string

+ type ConfigCreateWaitCustomId struct

+ CurrentIP string

+ CustomID string

+ CustomSequence int64

+ Frequency int64

+ Params string

+ Spec string

+ SpecifyIP string

+ Tx *gorm.DB

+ Type string

+ TypeName string

+ type Cron struct

+ func NewCron(opts ...CronOption) *Cron

+ func NewCronWithSeconds(opts ...CronOption) *Cron

+ func (c *Cron) AddFunc(spec string, cmd func()) (cron.EntryID, error)

+ func (c *Cron) AddJob(spec string, cmd cron.Job) (cron.EntryID, error)

+ func (c *Cron) AddTask(name string, spec string, cmd func()) (cron.EntryID, error)

+ func (c *Cron) Entry(id cron.EntryID) cron.Entry

+ func (c *Cron) GetDrive() *cron.Cron

+ func (c *Cron) List() []cron.EntryID

+ func (c *Cron) ListShow()

+ func (c *Cron) ListTask()

+ func (c *Cron) PrintNameTask(id cron.EntryID, name string, content ...string)

+ func (c *Cron) PrintTask(id cron.EntryID, content ...string)

+ func (c *Cron) QueryInfo(id cron.EntryID) (cron.EntryID, string)

+ func (c *Cron) QueryTask(id cron.EntryID) cron.Entry

+ func (c *Cron) Remove(id cron.EntryID)

+ func (c *Cron) RemoveTask(id cron.EntryID)

+ func (c *Cron) RunListShow(spec string)

+ func (c *Cron) RunListTask(spec string)

+ func (c *Cron) Start()

+ func (c *Cron) Stop() context.Context

+ type CronOption func(*Cron)

+ func WithCronLog() CronOption

+ type GormModelTask struct

+ CreatedAt time.Time

+ CreatedIP string

+ CustomID string

+ CustomSequence int64

+ DeletedAt gorm.DeletedAt

+ Frequency int64

+ ID uint

+ MaxNumber int64

+ NextRunTime time.Time

+ Number int64

+ Params string

+ Result string

+ RunID string

+ Spec string

+ SpecifyIP string

+ Status string

+ StatusDesc string

+ Type string

+ TypeName string

+ UpdatedAt time.Time

+ UpdatedIP string

+ type GormModelTaskLog struct

+ LogID uint

+ LogTime time.Time

+ SystemInsideIP string

+ SystemOutsideIP string

+ TaskID uint

+ TaskResultCode int

+ TaskResultDesc string

+ TaskRunID string

+ type Hour struct

+ func GetHour(n int64) *Hour

+ func (s Hour) Frequency() int64

+ func (s Hour) Spec() string

+ type HourInterval struct

+ func GetHourInterval(n int64) *HourInterval

+ func (s HourInterval) Frequency() int64

+ func (s HourInterval) Spec() string

+ type Minutes struct

+ func GetMinutes(n int64) *Minutes

+ func (s Minutes) Frequency() int64

+ func (s Minutes) Spec() string

+ type PubSubClient struct

+ func NewPubSub(ctx context.Context, client *redis.Client) *PubSubClient

+ func (c *PubSubClient) DbRunSingleTask(ctx context.Context, message string, ...)

+ func (c *PubSubClient) PSubscribe(ctx context.Context, channel ...string) *redis.PubSub

+ func (c *PubSubClient) Publish(ctx context.Context, channel string, message interface{}) error

+ func (c *PubSubClient) Subscribe(ctx context.Context, channel ...string) *redis.PubSub

+ type Seconds struct

+ func GetSeconds(n int64) *Seconds

+ func (s Seconds) Frequency() int64

+ func (s Seconds) Spec() string

+ type SubscribeResult struct

+ Message *redis.PubSub

+ type TaskCustomHelper struct

+ Ctx context.Context

+ Span trace.Span

+ func NewTaskCustomHelper(rootCtx context.Context, taskType string, opts ...TaskHelperOption) *TaskCustomHelper

+ func (th *TaskCustomHelper) EndRunTaskList()

+ func (th *TaskCustomHelper) GetTaskList() []*TaskCustomHelperTaskList

+ func (th *TaskCustomHelper) QueryTaskList(rootCtx context.Context, ...) (isContinue bool)

+ func (th *TaskCustomHelper) RunMultipleTask(rootCtx context.Context, wait int64, ...)

+ func (th *TaskCustomHelper) RunSingleTask(rootCtx context.Context, task *TaskCustomHelperTaskList, ...)

+ type TaskCustomHelperTaskList struct

+ CustomContent string

+ CustomID string

+ TaskID string

+ TaskName string

+ TaskParams string

+ type TaskHelper struct

+ Ctx context.Context

+ Span trace.Span

+ func NewTaskHelper(rootCtx context.Context, taskType string, opts ...TaskHelperOption) *TaskHelper

+ func (th *TaskHelper) EndRunTaskList()

+ func (th *TaskHelper) FilterTaskList(rootCtx context.Context, isMandatoryIp bool, specifyIp string) (isContinue bool)

+ func (th *TaskHelper) GetTaskList() []*GormModelTask

+ func (th *TaskHelper) QueryTaskList(rootCtx context.Context, ...) (isContinue bool)

+ func (th *TaskHelper) RunMultipleTask(rootCtx context.Context, wait int64, ...)

+ func (th *TaskHelper) RunSingleTask(rootCtx context.Context, task *GormModelTask, ...)

+ type TaskHelperOption interface

+ func TaskHelperWithDebug(is bool) TaskHelperOption

+ func TaskHelperWithFilter(is bool, keyName string, keyValue string) TaskHelperOption

+ type TaskHelperRunSingleTaskResponse struct

+ RequestID string

+ RunCode int

+ RunDesc string

+ RunID string

+ SpanID string

+ TraceID string

+ type TaskLockOperation struct

+ func (tlo *TaskLockOperation) Lock(ctx context.Context, id any) error

+ func (tlo *TaskLockOperation) LockCustomId(ctx context.Context) error

+ func (tlo *TaskLockOperation) LockForever(ctx context.Context, id any) error

+ func (tlo *TaskLockOperation) LockForeverCustomId(ctx context.Context) error

+ func (tlo *TaskLockOperation) LockForeverId(ctx context.Context) error

+ func (tlo *TaskLockOperation) LockId(ctx context.Context) error

+ func (tlo *TaskLockOperation) Unlock(ctx context.Context, id any) error

+ func (tlo *TaskLockOperation) UnlockCustomId(ctx context.Context) error

+ func (tlo *TaskLockOperation) UnlockId(ctx context.Context) error

Other modules containing this package

go.dtapp.net/library