Documentation
¶
Overview ¶
Package response contains implementations of types.Response.
Index ¶
Constants ¶
This section is empty.
Variables ¶
var (
ErrNoAck = errors.New("message failed to reach a target destination")
)
Errors for response types.
Functions ¶
This section is empty.
Types ¶
type Ack ¶
type Ack struct{}
Ack is a response type that indicates the message has reached a destination and can be acknowledged upstream.
type Error ¶
type Error struct {
// contains filtered or unexported fields
}
Error is a response type that wraps an error, this error will be interpreted as a failed message signal if the error is non-nil, a nil error indicates the message has successfully ended up somewhere and can be acknowledged upstream.
type Noack ¶
type Noack struct{}
Noack is a response type that indicates the message has failed to reach a destination.
type Unack ¶
type Unack struct{}
Unack is a response type that indicates the message has reached a destination but should not yet be acknowledged, if possible. Some input types will be able to continue sending messages, and once an acknowledgement has been received will propagate the acknowledgement for all unacknowledged messages.
It is considered correct for certain inputs to acknowledge based on an Unack response if they are locked in a request/response loop. For example, the HTTP input might return a 200 code from this response.
TODO: V4 Remove this once batch processor is removed.
Source Files