util

Mar 30, 2022

Changes in this version

type Zapt

+ func ZaptByCfg(mod string, file string) *Zapt

Mar 17, 2022

Changes in this version

type ProctCmd

+ I int

+ N string

+ func (cmd *ProctCmd) WithPid() *ProctCmd

Mar 9, 2022

Changes in this version

+ const TickWorkerModeContinue

+ const TickWorkerModeNextTick

+ const TickWorkerModeQuit

+ func ContextRet(ctx context.Context) gilix.RET

+ type TickWorkerMode int

Mar 1, 2022

Changes in this version

+ const SyncerWaitModeAny

+ const SyncerWaitModeCancel

+ const SyncerWaitModeIdle

+ type SyncerWaitMode int

Feb 25, 2022

Changes in this version

+ type Proct struct

+ func NewProct(ctx context.Context) *Proct

+ func (p *Proct) AddCmd(f ProctCb, path string, args ...string)

+ func (p *Proct) Wait()

+ type ProctCb func(*ProctCmd)

+ type ProctCmd struct

+ C *exec.Cmd

+ E error

type Syncer

+ func (syncer *Syncer) Ctx() context.Context

Dec 24, 2021

Changes in this version

+ const DirsOfDay

+ const FilesOfDay

+ const SYNCER_WAIT_MODE_ANY

+ const SYNCER_WAIT_MODE_CANCEL

+ const SYNCER_WAIT_MODE_IDLE

+ func ContextErr(ctx context.Context) gilix.RET

+ func CreateSyncerGroup(ctx context.Context, syncers ...**Syncer)

+ func TickWorker(ctx context.Context, d time.Duration, fworker func() (quit bool), ...)

+ func WaitReleaseSyncerGroup(act SYNCER_WAIT_MODE, syncers ...*Syncer)

+ type SYNCER_WAIT_MODE int

+ type Syncer struct

+ func CreateSyncer(ctx context.Context) *Syncer

+ func CreateSyncerWithSig(ctx context.Context) *Syncer

+ func (syncer *Syncer) Async(fSync func(), fBreak func())

+ func (syncer *Syncer) DeriveSyncer() *Syncer

+ func (syncer *Syncer) Sync(fSync func(), fBreak func())

+ func (syncer *Syncer) WaitRelease(act SYNCER_WAIT_MODE)

+ type Sysrw struct

+ func CreateSysrw(cnn net.Conn, rcap int) *Sysrw

+ func (sys *Sysrw) Read() (string, []byte, error)

+ func (sys *Sysrw) Write(fun string, data []byte) error

+ type Task struct

+ func CreateTask(w Worker) *Task

+ func CreateTaskStart(w Worker) *Task

+ func (task *Task) Put(data interface{}, ctx interface{})

+ func (task *Task) Start()

+ func (task *Task) Stop()

+ type Worker func(data interface{}, ctx interface{})

+ type Zapt struct

+ func CreateZapt(path string, mod string, file string, xday ZaptDayMode, purge int, ...) *Zapt

+ func (zapt *Zapt) DPanicf(template string, args ...interface{})

+ func (zapt *Zapt) Debugf(template string, args ...interface{})

+ func (zapt *Zapt) Errorf(template string, args ...interface{})

+ func (zapt *Zapt) Fatalf(template string, args ...interface{})

+ func (zapt *Zapt) Infof(template string, args ...interface{})

+ func (zapt *Zapt) Panicf(template string, args ...interface{})

+ func (zapt *Zapt) Warnf(template string, args ...interface{})

+ type ZaptDayMode int