Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  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
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

wrphttp

package

Go to main page

Versions in this module

v1

v1.3.1

Sep 4, 2019

v1.3.0

Aug 29, 2019

Changes in this version

+ const MetadataHeader

+ const PartnerIdHeader

v1.2.0

Jul 16, 2019

v1.1.0

Jul 15, 2019

v1.0.0

Mar 15, 2019

Changes in this version

+ const AcceptHeader

+ const DestinationHeader

+ const IncludeSpansHeader

+ const MessageTypeHeader

+ const PathHeader

+ const RequestDeliveryResponseHeader

+ const SourceHeader

+ const SpanHeader

+ const StatusHeader

+ const TransactionUuidHeader

+ func AddMessageHeaders(h http.Header, m *wrp.Message)

+ func DetermineFormat(defaultFormat wrp.Format, h http.Header, names ...string) (wrp.Format, error)

+ func NewHTTPHandler(h Handler, options ...Option) http.Handler

+ func NewMessageFromHeaders(h http.Header, p io.Reader) (message *wrp.Message, err error)

+ func ReadPayload(h http.Header, p io.Reader, m *wrp.Message) (int, error)

+ func SetMessageFromHeaders(h http.Header, m *wrp.Message) (err error)

+ func WritePayload(h http.Header, p io.Writer, m *wrp.Message) (int, error)

+ type Decoder func(context.Context, *http.Request) (*Entity, error)

+ func DecodeEntity(defaultFormat wrp.Format) Decoder

+ func DefaultDecoder() Decoder

+ type Entity struct

+ Format wrp.Format

+ Message wrp.Message

+ func DecodeRequestHeaders(ctx context.Context, original *http.Request) (*Entity, error)

+ type Handler interface

+ ServeWRP func(ResponseWriter, *Request)

+ type HandlerFunc func(ResponseWriter, *Request)

+ func (hf HandlerFunc) ServeWRP(w ResponseWriter, r *Request)

+ type MessageFunc func(context.Context, *wrp.Message) context.Context

+ type MockHandler struct

+ func (m *MockHandler) ServeWRP(response ResponseWriter, request *Request)

+ type Option func(*wrpHandler)

+ func WithBefore(funcs ...MessageFunc) Option

+ func WithDecoder(d Decoder) Option

+ func WithErrorEncoder(ee gokithttp.ErrorEncoder) Option

+ func WithNewResponseWriter(rwf ResponseWriterFunc) Option

+ type Request struct

+ Entity *Entity

+ Original *http.Request

+ func (r *Request) Context() context.Context

+ func (r *Request) WithContext(ctx context.Context) *Request

+ type ResponseWriter interface

+ WriteWRP func(interface{}) (int, error)

+ type ResponseWriterFunc func(http.ResponseWriter, *Request) (ResponseWriter, error)

+ func DefaultResponseWriterFunc() ResponseWriterFunc

+ func NewEntityResponseWriter(defaultFormat wrp.Format) ResponseWriterFunc