httpsender

package

v0.0.0-...-3c94f92 Latest Latest Go to latest Published: Mar 12, 2024 License: LGPL-3.0 Imports: 9 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/davidredborder/rbforwarder

Links

Open Source Insights

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	Workers  int
	Logger   *logrus.Entry
	Debug    bool
	URL      string
	Insecure bool
}

Config exposes the configuration for an HTTP Sender

type HTTPSender ¶

type HTTPSender struct {
	Client *http.Client

	Config
	// contains filtered or unexported fields
}

HTTPSender is a component for the rbforwarder pipeline that sends messages to an HTTP endpoint. It's a final component, so it will call Done() instead of Next() and further components shuld not be added after this component.

func (*HTTPSender) OnMessage ¶

func (httpsender *HTTPSender) OnMessage(m *utils.Message, done utils.Done)

OnMessage is called when a new message should be sent via HTTP

func (*HTTPSender) Spawn ¶

func (httpsender *HTTPSender) Spawn(id int) utils.Composer

Spawn initializes the HTTP component

func (*HTTPSender) Workers ¶

func (httpsender *HTTPSender) Workers() int

Workers returns the number of workers

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL