Versions in this module Expand all Collapse all v2 v2.6.0 Apr 26, 2021 Changes in this version + type ChanResponderResponse struct + Message binding.Message + Result protocol.Result + type Receiver <-chan binding.Message + func (r Receiver) Receive(ctx context.Context) (binding.Message, error) + type Requester struct + Ch chan<- binding.Message + Reply func(message binding.Message) (binding.Message, error) + func (s *Requester) Close(ctx context.Context) (err error) + func (s *Requester) Request(ctx context.Context, m binding.Message, transformers ...binding.Transformer) (res binding.Message, err error) + func (s *Requester) Send(ctx context.Context, m binding.Message, transformers ...binding.Transformer) (err error) + type Responder struct + In <-chan binding.Message + Out chan<- ChanResponderResponse + func (r *Responder) Respond(ctx context.Context) (binding.Message, protocol.ResponseFn, error) + type SendReceiver struct + func New() *SendReceiver + func (sr *SendReceiver) Receive(ctx context.Context) (binding.Message, error) + func (sr *SendReceiver) Send(ctx context.Context, in binding.Message, transformers ...binding.Transformer) (err error) + type Sender chan<- binding.Message + func (s Sender) Close(ctx context.Context) (err error) + func (s Sender) Send(ctx context.Context, m binding.Message, transformers ...binding.Transformer) (err error)
Go to main page