加载中
聊聊tunny的workerWrapper

序 本文主要研究一下tunny的workerWrapper workerWrapper type workerWrapper struct { worker Worker interruptChan chan struct{} // reqChan is NOT owned by this type, it is used to s...

04/28 22:57
107
聊聊golang的tunny

序 本文主要研究一下tunny Worker type Worker interface { // Process will synchronously perform a job and return the result. Process(interface{}) interface{} // BlockUntilReady i...

04/27 23:41
94
聊聊xxl-job-executor-go的Task

序 本文主要研究一下xxl-job-executor-go的Task Task //任务 type Task struct { Id int64 Name string Ext context.Context Param *RunReq fn TaskFunc Cancel context.C......

聊聊xxl-job-executor-go

序 本文主要研究一下xxl-job-executor-go Executor //执行器 type Executor interface { //初始化 Init(...Option) //日志查询 LogHandler(handler LogHandler) //注册任务 RegTask(pattern ...

聊聊dbsync的jobs

序 本文主要研究一下dbsync的jobs Job //Job represents db sync job type Job struct { ID string Error string Status string Progress Progress Items []*Transferable Chunked b......

04/23 22:27
0
聊聊dbsync的Schedulable

序 本文主要研究一下dbsync的Schedulable Schedulable //Schedulable represent an abstraction that can be schedule type Schedulable struct { URL string ID string *contract.Sync Sch...

04/22 23:13
0
聊聊dbsync的Criterion

序 本文主要研究一下dbsync的Criterion Criterion //Criterion represents criterion type Criterion fmt.Stringer Criterion是一个fmt.Stringer类型 between type between struct { from i...

04/21 23:20
0
聊聊event-sourcing-cqrs的model

序 本文主要研究一下event-sourcing-cqrs的model Event public abstract class Event { private final UUID aggregateId; private final ZonedDateTime timestamp; private final int versio...

04/15 23:20
136
聊聊ddd-by-examples的DomainEvent

序 本文主要研究一下ddd-by-examples的DomainEvent DomainEvent public interface DomainEvent { UUID getEventId(); UUID getAggregateId(); Instant getWhen(); } DomainEvent接口定义了...

聊聊dddsample-core的model

序 本文主要研究一下dddsample-core的model Entity public interface Entity<T> { /** Entities compare by identity, not by attributes. @param other The other entity. @return true......

04/12 23:16
114
聊聊dddsample-core的Specification

序 本文主要研究一下dddsample-core的Specification Specification public interface Specification<T> { /** Check if {@code t} is satisfied by the specification. @param t Object to ...

04/12 00:14
36
聊聊go.cqrs的EventHandler

序 本文主要研究一下go.cqrs的EventHandler EventHandler type EventHandler interface { Handle(EventMessage) } EventHandler定义了Handle方法 EventMessage // EventMessage is the inte...

聊聊go.cqrs的Dispatcher

序 本文主要研究一下go.cqrs的Dispatcher Dispatcher type Dispatcher interface { Dispatch(CommandMessage) error RegisterHandler(CommandHandler, ...interface{}) error } Dispatcher接...

聊聊go.cqrs的DomainRepository

序 本文主要研究一下go.cqrs的DomainRepository DomainRepository // DomainRepository is the interface that all domain repositories should implement. type DomainRepository interface...

04/08 23:22
68
聊聊go.cqrs的AggregateRoot

序 本文主要研究一下go.cqrs的AggregateRoot AggregateRoot //AggregateRoot is the interface that all aggregates should implement type AggregateRoot interface { AggregateID() string...

聊聊dkron的Scheduler

序 本文主要研究一下dkron的Scheduler Scheduler // Scheduler represents a dkron scheduler instance, it stores the cron engine // and the related parameters. type Scheduler struct ...

04/06 23:13
83
聊聊dkron的fsm

序 本文主要研究一下dkron的fsm MessageType // MessageType is the type to encode FSM commands. type MessageType uint8 const ( // SetJobType is the command used to store a job in t...

04/05 22:54
79
聊聊machinery的TaskProcessor

序 本文主要研究一下machinery的TaskProcessor TaskProcessor // TaskProcessor - can process a delivered task // This will probably always be a worker instance type TaskProcessor in...

04/04 22:02
85
聊聊machinery的Lock

序 本文主要研究一下machinery的Lock Lock type Lock interface { //Acquire the lock with retry //key: the name of the lock, //value: at the nanosecond timestamp that lock needs to ...

04/03 23:53
90
聊聊machinery的TaskState

序 本文主要研究一下machinery的TaskState TaskState const ( // StatePending - initial state of a task StatePending = "PENDING" // StateReceived - when task is received by a worker...

04/02 23:43
74

没有更多内容

加载失败,请刷新页面

返回顶部
顶部