code-craft

0

聊聊tunny的workerWrapper

• codecraft   4月28日发布
• 收藏

workerWrapper包装了worker，定义了interruptChan、reqChan、closeChan、closedChan属性

1

聊聊golang的tunny

• codecraft   4月27日发布
• 1 收藏

closureWorker定义了processor属性，它实现了Worker接口的Process、BlockUntilReady、Interrupt、Terminate方法，其中Process方法委托给processor

0

聊聊xxl-job-executor-go的Task

• codecraft   4月26日发布
• 收藏

Run方法注册了defer在panic的时候执行callback和cancel，然后执行t.fn(t.Ext, t.Param)以及callback(200, msg)

0

聊聊xxl-job-executor-go

• codecraft   4月25日发布
• 收藏

序本文主要研究一下xxl-job-executor-goExecutor {代码...} Executor定义了Init、LogHandler、RegTask、RunTask、KillTask、TaskLog、Run方法executor {代码...} executor定义了opts、address、regList、runList...

0

聊聊dbsync的jobs

• codecraft   4月23日发布
• 收藏

Job方法定义了ID、Error、Status、Progress、Items、Chunked、mutex、StartTime、EndTime

0

聊聊dbsync的Schedulable

• codecraft   4月22日发布
• 收藏

Schedulable定义了URL、ID、*contract.Sync、Schedule、Status、status属性；NewSchedulableFromURL方法根据URL来创建Schedulable

0

聊聊dbsync的Criterion

• codecraft   4月21日发布
• 收藏

序本文主要研究一下dbsync的CriterionCriterion {代码...} Criterion是一个fmt.Stringer类型between {代码...} between定义from、to两个属性lessOrEqual {代码...} lessOrEqual定义了value属性，表达式为<=gre...

1

聊聊event-sourcing-cqrs的model

• codecraft   4月15日发布
• 1 收藏

Aggregate定义了id、baseVersion、newEvents属性；其applyNewEvent方法会执行apply(event)及newEvents.add(event)；apply方法通过反射执行event的apply方法

1

聊聊ddd-by-examples的DomainEvent

• codecraft   4月13日发布
• 1 收藏

JustForwardDomainEventPublisher实现了DomainEvents接口，其publish方法通过spring的ApplicationEventPublisher来发布

0

聊聊dddsample-core的model

• codecraft   4月12日发布
• 收藏

序本文主要研究一下dddsample-core的modelEntity {代码...} Entity接口定义了sameIdentityAs方法ValueObject {代码...} ValueObject接口定义了sameValueAs方法TrackingId {代码...} TrackingId实现了ValueObject...

1

聊聊dddsample-core的Specification

• codecraft   4月12日发布
• 1 收藏

AndSpecification继承了AbstractSpecification，它定义了spec1、spec2属性，其isSatisfiedBy返回的是spec1.isSatisfiedBy(t) && spec2.isSatisfiedBy(t)

0

聊聊go.cqrs的EventHandler

• codecraft   4月10日发布
• 收藏

EventMessage接口定义了AggregateID、GetHeaders、SetHeader、Event、EventType、Version方法

0

聊聊go.cqrs的Dispatcher

• codecraft   4月9日发布
• 收藏

InMemoryDispatcher定义了map[string]CommandHandler属性，其Dispatch方法根据command.CommandType()获取handler，然后执行handler.Handle(command)；其RegisterHandler方法遍历commands，然后获取command的type...

0

聊聊go.cqrs的DomainRepository

• codecraft   4月8日发布
• 收藏

GetEventStoreCommonDomainRepo定义了eventStore、eventBus、streamNameDelegate、aggregateFactory、eventFactory属性，其Load方法先通过r.aggregateFactory.GetAggregate获取aggregate，再通过r.streamNameDele...

0

聊聊go.cqrs的AggregateRoot

• codecraft   4月7日发布
• 收藏

AggregateRoot接口定义了AggregateID、OriginalVersion、CurrentVersion、IncrementVersion、Apply、TrackChange、GetChanges、ClearChanges方法

0

聊聊dkron的Scheduler

• codecraft   4月6日发布
• 收藏

Scheduler定义了Cron、Started、EntryJobMap属性；NewScheduler方法创建默认的Scheduler；Start方法遍历jobs，挨个设置job.Agent，然后添加到Scheduler中，之后执行Scheduler.Cron.Start()；Stop方法执行Schedule...

0

聊聊dkron的fsm

• codecraft   4月5日发布
• 收藏

MessageType可以分为SetJobType、DeleteJobType、SetExecutionType、DeleteExecutionsType、ExecutionDoneType

0

聊聊machinery的TaskProcessor

• codecraft   4月4日发布
• 收藏

Worker实现了TaskProcessor接口，其Process方法先通过worker.server.GetRegisteredTask获取taskFunc，然后通过signature更新state为RECEIVED，之后设置为STARTED，之后执行task.Call()，最后根据结果更新task为fa...

0

聊聊machinery的Lock

• codecraft   4月3日发布
• 收藏

Lock定义了rclient、retries、interval属性；New方法根据cnf、addrs、db、retries创建lock；LockWithRetries方法根据retries次数来尝试r.Lock(key, unixTsToExpireNs)，都没有成功则返回ErrRedisLockFailed；Lock...

0

聊聊machinery的TaskState

• codecraft   4月2日发布
• 收藏

TaskState定义了PENDING、RECEIVED、STARTED、RETRY、SUCCESS、FAILURE状态；TaskState定义了TaskUUID、TaskName、State、Results、Error、CreatedAt、TTL属性；它提供了NewPendingTaskState、NewReceivedTaskSta...