bda

May 2, 2023

Changes in this version

type Orchestrator

+ Context context.Context

type Queue

+ func DefaultQueueWithCapacity(name string, ctx context.Context, capacity int) Queue[T]

type Worker

+ Context context.Context

type WorkerPool

+ Context context.Context

Apr 26, 2023

Changes in this version

type Error

+ func HandleErrors(runtime Runtime, logOperation LogOperation, errs SafeArray[Error]) Error

type SafeArray

+ func DefaultSafeArrayWithSize(size int) SafeArray[T]

Apr 26, 2023

Changes in this version

+ type Leaser interface

+ GetLease func(id string) (time.Time, error)

+ ResetLease func(id string, allegedLeaseTime time.Time) (time.Time, error)

+ type LeaserBuilder interface

+ Build func() Leaser

+ func NewInMemoryLeaserBuilder() LeaserBuilder

type Queue

+ Receiver func() chan T

+ Sender func() chan T

+ type SafeArray interface

+ Append func(item T)

+ Get func(i int) (T, bool)

+ Length func() int

+ Set func(i int, item T) bool

+ Slice func(start, end int, stepInterval ...int) SafeArray[T]

+ func DefaultSafeArray() SafeArray[T]

Apr 25, 2023

Changes in this version

type Set

+ TrySet func(key T) bool

Apr 25, 2023

Changes in this version

+ type Logger struct

+ Mutex *sync.Mutex

Apr 25, 2023

Changes in this version

+ func RuntimeLogger(runtime Runtime, operation LogOperation) *zap.Logger

Apr 25, 2023

Changes in this version

type Orchestrator

+ LoggerFunc func() *logrus.Logger

+ func (o *Orchestrator) GetLoggerFunc() func() *logrus.Logger

type Runtime

+ GetLoggerFunc func() func() *logrus.Logger

type Worker

+ LoggerFunc func() *logrus.Logger

+ func (w *Worker) GetLoggerFunc() func() *logrus.Logger

type WorkerPool

+ LoggerFunc func() *logrus.Logger

+ func (p *WorkerPool) GetLoggerFunc() func() *logrus.Logger

Apr 25, 2023

Changes in this version

+ const LogStatusProgress

Apr 24, 2023

Changes in this version

+ const LogOperationHandleError

+ const LogOperationInit

+ const LogOperationRun

+ const LogOperationStop

+ const LogStatusFailed

+ const LogStatusStart

+ const LogStatusSuccess

+ func DefaultLogger() *logrus.Logger

+ func LogDebug(entry *logrus.Entry, status LogStatus)

+ func LogDebugf(entry *logrus.Entry, status LogStatus, format string, args ...any)

+ func LogError(entry *logrus.Entry, status LogStatus)

+ func LogErrorf(entry *logrus.Entry, status LogStatus, format string, args ...any)

+ func LogFatal(entry *logrus.Entry, status LogStatus)

+ func LogFatalf(entry *logrus.Entry, status LogStatus, format string, args ...any)

+ func LogInfo(entry *logrus.Entry, status LogStatus)

+ func LogInfof(entry *logrus.Entry, status LogStatus, format string, args ...any)

+ func LogPanic(entry *logrus.Entry, status LogStatus)

+ func LogPanicf(entry *logrus.Entry, status LogStatus, format string, args ...any)

+ func LogTrace(entry *logrus.Entry, status LogStatus)

+ func LogTracef(entry *logrus.Entry, status LogStatus, format string, args ...any)

+ func LogWarn(entry *logrus.Entry, status LogStatus)

+ func LogWarnf(entry *logrus.Entry, status LogStatus, format string, args ...any)

+ func NewLogEntry(runtime Runtime, operation LogOperation) *logrus.Entry

+ func WorkerPoolStrategyRunLoop(p *WorkerPool, i int, wg *sync.WaitGroup, errs Queue[Error])

+ func WorkerPoolStrategyRunOnce(p *WorkerPool, i int, wg *sync.WaitGroup, errs Queue[Error])

type Error

+ func HandleErrorQueue(logEntry *logrus.Entry, errs Queue[Error]) Error

+ type ErrorSeverity int

+ const DebugLevel

+ const FatalLevel

+ const InfoLevel

+ const PanicLevel

+ const TraceLevel

+ const WarnLevel

type ErrorStruct

+ Severity ErrorSeverity

+ type LogOperation string

+ type LogStatus string

type Orchestrator

+ Logger *logrus.Logger

+ Name string

+ func (o *Orchestrator) GetLogger() *logrus.Logger

+ func (o *Orchestrator) GetName() string

+ func (o *Orchestrator) GetType() string

type Runtime

+ GetLogger func() *logrus.Logger

+ GetName func() string

+ GetType func() string

type Worker

+ Logger *logrus.Logger

+ Name string

+ func (w *Worker) GetLogger() *logrus.Logger

+ func (w *Worker) GetName() string

+ func (w *Worker) GetType() string

type WorkerFactory

+ WorkerStrategy Strategy

type WorkerPool

+ Name string

+ StrategyFunc WorkerPoolStrategyFunc

+ func (p *WorkerPool) GetLogger() *logrus.Logger

+ func (p *WorkerPool) GetName() string

+ func (p *WorkerPool) GetType() string

+ type WorkerPoolStrategyFunc func(p *WorkerPool, i int, wg *sync.WaitGroup, errors Queue[Error])

Apr 24, 2023

Changes in this version

+ type Builder interface

+ Spawn func() (T, Error)

+ type Error *ErrorStruct

+ func NewError(errorType ErrorType, msg string, subErrors []Error) Error

+ type ErrorLevel int

+ const Fatal

+ const Warning

+ type ErrorStruct struct

+ Level ErrorLevel

+ Message string

+ SubErrors []Error

+ Type ErrorType

+ type ErrorType string

+ type Map interface

+ Get func(key T) (I, bool)

+ Set func(key T, value I) (T, I)

+ func DefaultMap() Map[T, I]

+ type Orchestrator struct

+ Strategy Strategy

+ WorkerPools []*WorkerPool

+ func (o *Orchestrator) HandleError(e Error) Error

+ func (o *Orchestrator) Init() Error

+ func (o *Orchestrator) Run() Error

+ func (o *Orchestrator) Stop() Error

+ type Queue interface

+ Length func() int

+ Pull func() (T, bool)

+ Push func(item T)

+ func DefaultQueue() Queue[T]

+ type Runtime interface

+ HandleError func(Error) Error

+ Init func() Error

+ Run func() Error

+ Stop func() Error

+ type Set interface

+ Exist func(element T) bool

+ Set func(element T)

+ func DefaultSet() Set[T]

+ type Strategy interface

+ HandleError func(Runtime, Error) Error

+ Init func(Runtime) Error

+ Run func(Runtime) Error

+ Stop func(Runtime) Error

+ func DefaultStrategy() Strategy

+ type Worker struct

+ Receptor Runtime

+ Strategy Strategy

+ func (w *Worker) HandleError(e Error) Error

+ func (w *Worker) Init() Error

+ func (w *Worker) Run() Error

+ func (w *Worker) Stop() Error

+ type WorkerFactory struct

+ ReceptorFactory Builder[Runtime]

+ Strategy Strategy

+ func (wf *WorkerFactory) Spawn() (*Worker, Error)

+ type WorkerPool struct

+ Logger log.Logger

+ Replicas int

+ WorkerFactory WorkerFactory

+ Workers []*Worker

+ func (p *WorkerPool) HandleError(err Error) Error

+ func (p *WorkerPool) Init() Error

+ func (p *WorkerPool) Run() Error

+ func (p *WorkerPool) Stop() Error