process

Documentation

Index

• Constants
• Variables
• type Http
  • func NewHttp(config HttpConfig) (*Http, error)
  • func (r *Http) Run(ctx context.Context, msg queue.Message, trans transform.TransformationFunc) error
• type HttpConfig
• type Processor
  • func New(config any) (Processor, error)

Constants

const (
	HttpDefaultMethod      = "POST"
	HttpDefaultTimeout     = 120
	HttpDefaultContentType = "text/plain"
)

Variables

var (
	ErrFail   = errors.New("process failed")
	ErrFatal  = errors.New("process failed with fatal error")
	ErrConfig = errors.New("configuration error")
)

Types

type Http

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

func NewHttp

func NewHttp(config HttpConfig) (*Http, error)

func (*Http) Run

func (r *Http) Run(ctx context.Context, msg queue.Message, trans transform.TransformationFunc) error

type HttpConfig

type HttpConfig struct {
	SubscriberUrl string `koanf:"subscriber_url"`
	Method        string `koanf:"method"`
	Timeout       int    `koanf:"timeout"`
	FatalCodes    []int  `koanf:"fatal_codes"`
	ContentType   string `koanf:"content_type"`
}

type Processor

type Processor interface {
	Run(ctx context.Context, msg queue.Message, f transform.TransformationFunc) error
}

func New

func New(config any) (Processor, error)