job

type BaseJobExecutor struct {
	LocalLogger  *logrus.Entry
	RemoteLogger *logrus.Entry
	// contains filtered or unexported fields
}

type BaseMapJobExecutor struct {
	BaseJobExecutor
	// contains filtered or unexported fields
}

type BaseMapReduceJobExecutor struct {
	BaseMapJobExecutor
	// contains filtered or unexported fields
}

type DefaultFormatter struct {
	ForceColors bool
}

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

type HookLogService struct {
	Wg         sync.WaitGroup
	LogEntryCh chan *dto.JobLogTask
	// contains filtered or unexported fields
}

type IJobExecutor interface {
	JobExecute(context dto.JobContext)
}

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

type JobStrategy interface {
	DoJobExecute(dto.IJobArgs) dto.ExecuteResult
	// contains filtered or unexported methods
}

type LoggerFactory interface {
	GetRemoteLogger(name string, ctx context.Context) *logrus.Entry
	GetLocalLogger(name string) *logrus.Entry
	GetLogRus() *logrus.Logger
	Init(hls *HookLogService)
}

type LoggerHook struct {
	Hls *HookLogService
}

type MapExecute interface {
	DoJobMapExecute(args *dto.MapArgs) dto.ExecuteResult
	// contains filtered or unexported methods
}

type MapReduceExecute interface {
	DoReduceExecute(args *dto.ReduceArgs) dto.ExecuteResult
	DoMergeReduceExecute(args *dto.MergeReduceArgs) dto.ExecuteResult
	BindMapReduceExecute(child MapReduceExecute)
}

type NewJobExecutor func() IJobExecutor

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

type Server struct {
	rpc.UnimplementedUnaryRequestServer
	// contains filtered or unexported fields
}

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