README
¶
forkjoin
The library implements a fork(fanout) and join(fanin) pattern using goroutines
Fork Join Design
- Multiplexer spawns N goroutines for N worker added through addWorker method on the Multiplexer
- Multiplexer's model is request/response, it return only one response form the worker
- Each worker needs to
- Implement Worker interface and return on result channel. Heartbeat is managed for the worker
- Exit its work on a signal from Manager on the done channel
- Worker only need to implement the actual work
- The worker (goroutine) is considered unhealthy if the heartbeat is delayed by more than two seconds and is restarted
Using fork join
Documentation
¶
Index ¶
- func SendPulse(ctx context.Context, pulseStream chan Heartbeat, pulseInterval time.Duration)
- type BaseWorker
- type EventCode
- type FJError
- type Heartbeat
- type LogEvent
- type Multiplexer
- type Result
- type StandardLogger
- func (l *StandardLogger) LogAbortedRequest(requestID, messageID, message string)
- func (l *StandardLogger) LogAuthenticationError(requestID, messageID, message string)
- func (l *StandardLogger) LogHeartBeatMsg(requestID, messageID, message string)
- func (l *StandardLogger) LogInfo(requestID, message string)
- func (l *StandardLogger) LogInvalidRequest(requestID, messageID, message string)
- func (l *StandardLogger) LogRequestDispatchError(requestID, messageID, message string)
- func (l *StandardLogger) LogRequestInfo(requestID, message string)
- func (l *StandardLogger) LogResponseError(requestID, messageID, message string)
- type Worker
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type BaseWorker ¶
type BaseWorker struct {
ActiveDealine int32
}
type FJError ¶
type FJError struct {
Code EventCode
Inner error
Message string
StackTrace string
Misc map[string]interface{}
}
FJError error reported by ForkJoin
type LogEvent ¶
type LogEvent struct {
// contains filtered or unexported fields
}
LogEvent stores log message
type Multiplexer ¶
type Multiplexer struct {
// contains filtered or unexported fields
}
Multiplexer starts N goroutine for N dispatchers
func NewMultiplexer ¶
func NewMultiplexer() Multiplexer
NewMultiplexer creates new basic multiplexer
func (*Multiplexer) AddWorker ¶
func (m *Multiplexer) AddWorker(w Worker)
AddWorker adds workers to multiplex on N worker
type StandardLogger ¶
StandardLogger enforces specific log message formats
func NewLogger ¶
func NewLogger() *StandardLogger
func (*StandardLogger) LogAbortedRequest ¶
func (l *StandardLogger) LogAbortedRequest(requestID, messageID, message string)
func (*StandardLogger) LogAuthenticationError ¶
func (l *StandardLogger) LogAuthenticationError(requestID, messageID, message string)
func (*StandardLogger) LogHeartBeatMsg ¶
func (l *StandardLogger) LogHeartBeatMsg(requestID, messageID, message string)
func (*StandardLogger) LogInfo ¶
func (l *StandardLogger) LogInfo(requestID, message string)
func (*StandardLogger) LogInvalidRequest ¶
func (l *StandardLogger) LogInvalidRequest(requestID, messageID, message string)
func (*StandardLogger) LogRequestDispatchError ¶
func (l *StandardLogger) LogRequestDispatchError(requestID, messageID, message string)
func (*StandardLogger) LogRequestInfo ¶
func (l *StandardLogger) LogRequestInfo(requestID, message string)
TODO: have one info or request and one generic
func (*StandardLogger) LogResponseError ¶
func (l *StandardLogger) LogResponseError(requestID, messageID, message string)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.