wrpendpoint

Mar 15, 2019

Changes in this version

+ func New(s Service) endpoint.Endpoint

+ type Note interface

+ Destination func() string

+ Encode func(output io.Writer, format wrp.Format) error

+ EncodeBytes func(format wrp.Format) ([]byte, error)

+ Message func() *wrp.Message

+ TransactionID func() string

+ type Request interface

+ Logger func() log.Logger

+ WithLogger func(log.Logger) Request

+ func DecodeRequest(logger log.Logger, source io.Reader, format wrp.Format) (Request, error)

+ func DecodeRequestBytes(logger log.Logger, contents []byte, format wrp.Format) (Request, error)

+ func WrapAsRequest(logger log.Logger, m *wrp.Message) Request

+ type Response interface

+ func DecodeResponse(source io.Reader, format wrp.Format) (Response, error)

+ func DecodeResponseBytes(contents []byte, format wrp.Format) (Response, error)

+ func WrapAsResponse(m *wrp.Message) Response

+ type Service interface

+ ServeWRP func(context.Context, Request) (Response, error)

+ func Wrap(e endpoint.Endpoint) Service

+ type ServiceFunc func(context.Context, Request) (Response, error)

+ func (sf ServiceFunc) ServeWRP(ctx context.Context, r Request) (Response, error)