Documentation
¶
Overview ¶
Package transport contains helpers applicable to all supported transports.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ErrorHandler ¶
ErrorHandler receives a transport error to be processed for diagnostic purposes. Usually this means logging the error.
type ErrorHandlerFunc ¶ added in v0.11.0
The ErrorHandlerFunc type is an adapter to allow the use of ordinary function as ErrorHandler. If f is a function with the appropriate signature, ErrorHandlerFunc(f) is a ErrorHandler that calls f.
type LogErrorHandler ¶
type LogErrorHandler struct {
// contains filtered or unexported fields
}
LogErrorHandler is a transport error handler implementation which logs an error.
func NewLogErrorHandler ¶
func NewLogErrorHandler(logger log.Logger) *LogErrorHandler
Source Files
Directories
¶
| Path | Synopsis |
|---|---|
|
Package amqp implements an AMQP transport.
|
Package amqp implements an AMQP transport. |
|
Package awslambda provides an AWS Lambda transport layer.
|
Package awslambda provides an AWS Lambda transport layer. |
|
Package grpc provides a gRPC binding for endpoints.
|
Package grpc provides a gRPC binding for endpoints. |
|
Package http provides a general purpose HTTP binding for endpoints.
|
Package http provides a general purpose HTTP binding for endpoints. |
|
jsonrpc
Package jsonrpc provides a JSON RPC (v2.0) binding for endpoints.
|
Package jsonrpc provides a JSON RPC (v2.0) binding for endpoints. |
|
Package httprp provides an HTTP reverse-proxy transport.
|
Package httprp provides an HTTP reverse-proxy transport. |
|
Package kafka implements an KAFKA transport.
|
Package kafka implements an KAFKA transport. |
|
Package nats provides a NATS transport.
|
Package nats provides a NATS transport. |
Click to show internal directories.
Click to hide internal directories.