gochan

Documentation

Overview

Package gochan implements the CloudEvent transport implementation using go chan.

Index

• type ChanResponderResponse
• type Receiver
  • func (r Receiver) Receive(ctx context.Context) (binding.Message, error)
• type Requester
  • 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
  • func (r *Responder) Respond(ctx context.Context) (binding.Message, protocol.ResponseFn, error)
• type SendReceiver
  • func New() *SendReceiver
  • func (sr *SendReceiver) Receive(ctx context.Context) (binding.Message, error)
  • func (sr *SendReceiver) Send(ctx context.Context, in binding.Message) (err error)
• type Sender
  • func (s Sender) Close(ctx context.Context) (err error)
  • func (s Sender) Send(ctx context.Context, m binding.Message, transformers ...binding.Transformer) (err error)

Types

type ChanResponderResponse

type ChanResponderResponse struct {
	Message binding.Message
	Result  protocol.Result
}

type Receiver

type Receiver <-chan binding.Message

Receiver implements Receiver by receiving Messages from a channel.

func (Receiver) Receive

func (r Receiver) Receive(ctx context.Context) (binding.Message, error)

type Requester

type Requester struct {
	Ch    chan<- binding.Message
	Reply func(message binding.Message) (binding.Message, error)
}

func (*Requester) Close

func (s *Requester) Close(ctx context.Context) (err error)

func (*Requester) Request

func (s *Requester) Request(ctx context.Context, m binding.Message, transformers ...binding.Transformer) (res binding.Message, err error)

func (*Requester) Send

func (s *Requester) Send(ctx context.Context, m binding.Message, transformers ...binding.Transformer) (err error)

type Responder

type Responder struct {
	In  <-chan binding.Message
	Out chan<- ChanResponderResponse
}

Responder implements Responder by receiving Messages from a channel and outputting the result in an output channel. All message received in the `Out` channel must be finished

func (*Responder) Respond

func (r *Responder) Respond(ctx context.Context) (binding.Message, protocol.ResponseFn, error)

type SendReceiver

type SendReceiver struct {
	// contains filtered or unexported fields
}

SendReceiver is a reference implementation for using the CloudEvents binding integration.

func New

func New() *SendReceiver

func (*SendReceiver) Receive

func (sr *SendReceiver) Receive(ctx context.Context) (binding.Message, error)

func (*SendReceiver) Send

func (sr *SendReceiver) Send(ctx context.Context, in binding.Message) (err error)

type Sender

type Sender chan<- binding.Message

Sender implements Sender by sending Messages on a channel.

func (Sender) Close

func (s Sender) Close(ctx context.Context) (err error)

func (Sender) Send

func (s Sender) Send(ctx context.Context, m binding.Message, transformers ...binding.Transformer) (err error)