Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

reqreply

package

Go to main page

Versions in this module

v0

v0.12.0

Jul 29, 2026

Changes in this version

+ type ErrorPatternOpt struct

+ func ErrorPattern[E error, B any](codec codex.Codec[B], mapFn ...func(E) (B, error)) ErrorPatternOpt[E, B]

+ func (o ErrorPatternOpt[E, B]) WithChannelAddress(addr string) ErrorPatternOpt[E, B]

+ func (o ErrorPatternOpt[E, B]) WithCode(code string) ErrorPatternOpt[E, B]

+ func (o ErrorPatternOpt[E, B]) WithDescription(desc string) ErrorPatternOpt[E, B]

+ func (o ErrorPatternOpt[E, B]) WithOperationID(id string) ErrorPatternOpt[E, B]

+ func (o ErrorPatternOpt[E, B]) WithSchemaName(name string) ErrorPatternOpt[E, B]

+ type ErrorPatternResponse struct

+ Body []byte

+ Value any

+ type ErrorReplyMeta struct

+ ChannelAddress string

+ Code string

+ Description string

+ OperationID string

+ Schema schema.Schema

+ SchemaName string

+ type FormatOptError struct

+ Direction string

+ Err error

+ func (e FormatOptError) Error() string

+ func (e FormatOptError) LogValue() slog.Value

+ func (e FormatOptError) Unwrap() error

+ type MergeFieldTypeError struct

+ Err error

+ func (e MergeFieldTypeError) Error() string

+ func (e MergeFieldTypeError) LogValue() slog.Value

+ func (e MergeFieldTypeError) Unwrap() error

+ type MergedTopicParam struct

+ func NewTopicParam[Req any](name string, codec codex.Codec[string], get func(Req) string, ...) MergedTopicParam[Req]

+ func (p MergedTopicParam[Req]) WithDescription(desc string) MergedTopicParam[Req]

type RouteHandle

+ func (h *RouteHandle[Req, Resp]) DecodeMerged(payload []byte, topicVars map[string]string) (Req, error)

+ func (h *RouteHandle[Req, Resp]) ErrorResponseFor(err error) (ErrorPatternResponse, bool, error)

+ func (h *RouteHandle[Req, Resp]) MergeFields() []codex.FieldCodec[Req]

type RouteOpt

+ func Formats[Resp any](fmts ...format.Format[Resp]) RouteOpt

+ func RequestFormats[Req any](fmts ...format.Format[Req]) RouteOpt

v0.11.0

Jul 15, 2026

Changes in this version

+ type Builder struct

+ func NewBuilder(info Info) *Builder

+ func (b *Builder) AddServer(name string, s Server) *Builder

+ func (b *Builder) AppendTo(db *asyncapi.DocumentBuilder) error

+ func (b *Builder) AsyncAPISpec() (asyncapi.Document, error)

+ type DuplicateRouteError struct

+ Topic string

+ func (e DuplicateRouteError) Error() string

+ func (e DuplicateRouteError) LogValue() slog.Value

+ type Info = asyncapi.Info

+ type MissingRouteParamError struct

+ Name string

+ func (e MissingRouteParamError) Error() string

+ func (e MissingRouteParamError) LogValue() slog.Value

+ type Route struct

+ func NewRoute[Req, Resp any](topic string, reqCodec codex.Codec[Req], respCodec codex.Codec[Resp], ...) Route[Req, Resp]

+ func (r Route[Req, Resp]) ClientHandle() *RouteHandle[Req, Resp]

+ func (r Route[Req, Resp]) Register(b *Builder) (*RouteHandle[Req, Resp], error)

+ type RouteHandle struct

+ Decode func(payload []byte) (Req, error)

+ DecodeResponse func(payload []byte) (Resp, error)

+ Encode func(resp Resp) ([]byte, error)

+ EncodeRequest func(req Req) ([]byte, error)

+ Formats []format.Format[Resp]

+ RequestFormats []format.Format[Req]

+ Topic string

+ func (h *RouteHandle[Req, Resp]) BuildTopic(vars map[string]string) (string, error)

+ func (h *RouteHandle[Req, Resp]) ValidateTopicVars(vars map[string]string) error

+ func (h *RouteHandle[Req, Resp]) WithFormats(fmts ...format.Format[Resp]) *RouteHandle[Req, Resp]

+ func (h *RouteHandle[Req, Resp]) WithRequestFormats(fmts ...format.Format[Req]) *RouteHandle[Req, Resp]

+ type RouteMeta struct

+ Description string

+ OperationID string

+ ReqSchemaName string

+ RespSchemaName string

+ Summary string

+ Tags []string

+ type RouteOpt interface

+ type RouteParamError struct

+ Err error

+ Name string

+ Value string

+ func (e RouteParamError) Error() string

+ func (e RouteParamError) LogValue() slog.Value

+ func (e RouteParamError) Unwrap() error

+ type Server = asyncapi.Server

+ type TopicParam struct

+ Codec *codex.Codec[string]

+ Description string

+ Name string

+ func (p TopicParam) WithCodec(c codex.Codec[string]) TopicParam