remilia

README

Remilia

Description

WIP

License

This project is licensed under the MIT License. See the LICENSE file for details.

Documentation

Index

• func WithBackoffOptions(opts ...exponentialBackoffOptionFunc) remiliaOption
• func WithBaseURL(url string) clientOptionFunc
• func WithClientOptions(opts ...clientOptionFunc) remiliaOption
• func WithConcurrency(concurrency uint) stageOptionFunc
• func WithHeaders(headers map[string]string) clientOptionFunc
• func WithInputBufferSize(size uint) stageOptionFunc
• func WithLinearAttempt(a uint8) exponentialBackoffOptionFunc
• func WithLogger(logger Logger) remiliaOption
• func WithMaxAttempt(a uint8) exponentialBackoffOptionFunc
• func WithMaxDelay(d time.Duration) exponentialBackoffOptionFunc
• func WithMinDelay(d time.Duration) exponentialBackoffOptionFunc
• func WithMultiplier(m float64) exponentialBackoffOptionFunc
• func WithPostResponseHooks(hooks ...responseHook) clientOptionFunc
• func WithPreRequestHooks(hooks ...requestHook) clientOptionFunc
• func WithStageOptions(opts ...stageOptionFunc) remiliaOption
• func WithTimeout(timeout time.Duration) clientOptionFunc
• func WithTransformer(transformer transform.Transformer) clientOptionFunc
• type Get
• type Logger
• type Put
• type Remilia
  • func New(opts ...remiliaOption) (*Remilia, error)
  • func (r *Remilia) Do(producerDef processorDef[*Request], stageDefs ...stageDef[*Request]) error
  • func (r *Remilia) Just(urlStr string) processorDef[*Request]
  • func (r *Remilia) Unit(fn UnitFunc, opts ...stageOptionFunc) stageDef[*Request]
• type Request
• type Response
• type UnitFunc

Functions

func WithBackoffOptions

func WithBackoffOptions(opts ...exponentialBackoffOptionFunc) remiliaOption

func WithBaseURL

func WithBaseURL(url string) clientOptionFunc

func WithClientOptions

func WithClientOptions(opts ...clientOptionFunc) remiliaOption

func WithConcurrency

func WithConcurrency(concurrency uint) stageOptionFunc

func WithHeaders

func WithHeaders(headers map[string]string) clientOptionFunc

func WithInputBufferSize

func WithInputBufferSize(size uint) stageOptionFunc

func WithLinearAttempt

func WithLinearAttempt(a uint8) exponentialBackoffOptionFunc

func WithLogger

func WithLogger(logger Logger) remiliaOption

func WithMaxAttempt

func WithMaxAttempt(a uint8) exponentialBackoffOptionFunc

func WithMaxDelay

func WithMaxDelay(d time.Duration) exponentialBackoffOptionFunc

func WithMinDelay

func WithMinDelay(d time.Duration) exponentialBackoffOptionFunc

func WithMultiplier

func WithMultiplier(m float64) exponentialBackoffOptionFunc

func WithPostResponseHooks

func WithPostResponseHooks(hooks ...responseHook) clientOptionFunc

func WithPreRequestHooks

func WithPreRequestHooks(hooks ...requestHook) clientOptionFunc

func WithStageOptions

func WithStageOptions(opts ...stageOptionFunc) remiliaOption

func WithTimeout

func WithTimeout(timeout time.Duration) clientOptionFunc

func WithTransformer

func WithTransformer(transformer transform.Transformer) clientOptionFunc

Types

type Get

type Get[T any] func() (T, bool)

type Logger

type Logger interface {
	Debug(msg string, context ...logContext)
	Info(msg string, context ...logContext)
	Warn(msg string, context ...logContext)
	Error(msg string, context ...logContext)
	Panic(msg string, context ...logContext)
}

type Put

type Put[T any] func(T)

type Remilia

type Remilia struct {
	ID   string
	Name string
	// contains filtered or unexported fields
}

func New

func New(opts ...remiliaOption) (*Remilia, error)

func (*Remilia) Do

func (r *Remilia) Do(producerDef processorDef[*Request], stageDefs ...stageDef[*Request]) error

func (*Remilia) Just

func (r *Remilia) Just(urlStr string) processorDef[*Request]

func (*Remilia) Unit

func (r *Remilia) Unit(fn UnitFunc, opts ...stageOptionFunc) stageDef[*Request]

type Request

type Request struct {
	Method      string
	URL         string
	Headers     map[string]string
	Body        []byte
	QueryParams map[string]string
}

type Response

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

type UnitFunc

type UnitFunc func(in *goquery.Document, put Put[string])