converter

Mar 19, 2024

Changes in this version

type IConverter

+ func Default[In, Out any](fn Convert[In, Out], opts ...Func[In, Out]) (IConverter[In, Out], error)

+ func MustDefault[In, Out any](fn Convert[In, Out], opts ...Func[In, Out]) IConverter[In, Out]

Mar 19, 2024

Changes in this version

+ type Convert func(ctx context.Context, in In) (out Out, err error)

type Converter

+ CreatedAt time.Time

+ Duration *expvar.Int

+ Func Convert[In, Out]

+ func (c *Converter[In, Out]) GetCreatedAt() time.Time

+ func (c *Converter[In, Out]) GetDuration() *expvar.Int

+ func (c *Converter[In, Out]) GetMetrics() map[string]string

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

Mar 6, 2024

Changes in this version

+ const Type

+ type Converter struct

+ CounterCreated *expvar.Int

+ CounterDone *expvar.Int

+ CounterFailed *expvar.Int

+ CounterRunning *expvar.Int

+ Description string

+ Logger sypl.ISypl

+ Name string

+ OnFinished OnFinished[T]

+ Status *expvar.String

+ func New[T any](name, description string) (*Converter[T], error)

+ func (c *Converter[T]) GetCounterCreated() *expvar.Int

+ func (c *Converter[T]) GetCounterDone() *expvar.Int

+ func (c *Converter[T]) GetCounterFailed() *expvar.Int

+ func (c *Converter[T]) GetCounterRunning() *expvar.Int

+ func (c *Converter[T]) GetDescription() string

+ func (c *Converter[T]) GetLogger() sypl.ISypl

+ func (c *Converter[T]) GetName() string

+ func (c *Converter[T]) GetOnFinished() OnFinished[T]

+ func (c *Converter[T]) GetStatus() *expvar.String

+ func (c *Converter[T]) GetType() string

+ func (c *Converter[T]) SetOnFinished(onFinished OnFinished[T])

+ type Func func(p IConverter[T]) IConverter[T]

+ func WithOnFinished[T any](onFinished OnFinished[T]) Func[T]

+ type IConverter interface

+ GetOnFinished func() OnFinished[T]

+ Run func(ctx context.Context, r io.Reader) (T, error)

+ SetOnFinished func(onFinished OnFinished[T])

+ type OnFinished func(ctx context.Context, c IConverter[T], r io.Reader, processed []T)