requester

package

v0.0.3 Latest Latest Go to latest Published: Mar 7, 2022 License: Apache-2.0 Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

HTTPRequester performs an HTTP request to the requester service at the configured host.

func NewHTTPRequester(deliveryKind *resource.DeliveryKind) *HTTPRequester

func (r *HTTPRequester) Request(input map[string]interface{}) (map[string]interface{}, error)

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

LogRequester logs the input and output values. It is typically used during development when the actual message delivery is not important.

func NewLogRequester(deliveryKind *resource.DeliveryKind) *LogRequester

func (r *LogRequester) Request(input map[string]interface{}) (map[string]interface{}, error)

type NoopRequester struct{}

NoopRequester does nothing. It is typically used when a message should not be delivered, eg. when testing or debugging.

func NewNoopRequester() *NoopRequester

func (r *NoopRequester) Request(_ map[string]interface{}) (map[string]interface{}, error)

type Requester interface {
	Request(map[string]interface{}) (map[string]interface{}, error)
}

Requester defines a request to deliver a message.

func New(deliveryKind *resource.DeliveryKind) Requester

New creates a new requester for the specified delivery kind. Most requesters are callable by HTTP, but there are some built-in requesters.