stage

Mar 13, 2024

Changes in this version

type IStage

+ GetMetrics func() map[string]string

type Stage

+ func (s *Stage[In, Out]) GetMetrics() map[string]string

Mar 12, 2024

Changes in this version

type IStage

+ GetCreatedAt func() time.Time

+ GetDuration func() *expvar.Int

+ GetProgress func() *expvar.Int

+ GetProgressPercent func() *expvar.String

+ SetProgressPercent func()

type Stage

+ CreatedAt time.Time

+ Duration *expvar.Int

+ ProgressPercent *expvar.String

+ func (s *Stage[In, Out]) GetCreatedAt() time.Time

+ func (s *Stage[In, Out]) GetDuration() *expvar.Int

+ func (s *Stage[In, Out]) GetProgress() *expvar.Int

+ func (s *Stage[In, Out]) GetProgressPercent() *expvar.String

+ func (s *Stage[In, Out]) SetProgressPercent()

Mar 6, 2024

Changes in this version

+ const Type

+ type Func func(p IStage[In, Out]) IStage[In, Out]

+ func WithOnFinished[In, Out any](onFinished OnFinished[In, Out]) Func[In, Out]

+ type IStage interface

+ GetOnFinished func() OnFinished[In, Out]

+ Run func(ctx context.Context, in []In) (out []Out, err error)

+ SetOnFinished func(onFinished OnFinished[In, Out])

+ func New[In, Out any](name string, conversor concurrentloop.MapFunc[In, Out], ...) (IStage[In, Out], error)

+ type OnFinished func(ctx context.Context, p IStage[In, Out], in []In, processedOut []Out)

+ type Stage struct

+ Conversor concurrentloop.MapFunc[In, Out]

+ CounterCreated *expvar.Int

+ CounterDone *expvar.Int

+ CounterFailed *expvar.Int

+ CounterRunning *expvar.Int

+ Description string

+ Logger sypl.ISypl

+ Name string

+ OnFinished OnFinished[In, Out]

+ Processors []processor.IProcessor[In]

+ Progress int

+ Status *expvar.String

+ func (s *Stage[In, Out]) GetCounterCreated() *expvar.Int

+ func (s *Stage[In, Out]) GetCounterDone() *expvar.Int

+ func (s *Stage[In, Out]) GetCounterFailed() *expvar.Int

+ func (s *Stage[In, Out]) GetCounterRunning() *expvar.Int

+ func (s *Stage[In, Out]) GetDescription() string

+ func (s *Stage[In, Out]) GetLogger() sypl.ISypl

+ func (s *Stage[In, Out]) GetName() string

+ func (s *Stage[In, Out]) GetOnFinished() OnFinished[In, Out]

+ func (s *Stage[In, Out]) GetStatus() *expvar.String

+ func (s *Stage[In, Out]) GetType() string

+ func (s *Stage[In, Out]) Run(ctx context.Context, in []In) ([]Out, error)

+ func (s *Stage[In, Out]) SetOnFinished(onFinished OnFinished[In, Out])