The highest tagged major version is
Documentation
¶
Index ¶
- func EventContextToBinaryEncoder(c cloudevents.EventContext, b binding.BinaryEncoder) (err error)
- func ToEvent(message binding.Message, factories ...binding.TransformerFactory) (e ce.Event, wasStructured bool, wasBinary bool, err error)
- type BindingTransport
- func (t *BindingTransport) HasConverter() bool
- func (t *BindingTransport) Send(ctx context.Context, e ce.Event) (context.Context, *ce.Event, error)
- func (t *BindingTransport) SetConverter(transport.Converter)
- func (t *BindingTransport) SetReceiver(r transport.Receiver)
- func (t *BindingTransport) StartReceiver(ctx context.Context) error
- type EventMessage
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func EventContextToBinaryEncoder ¶
func EventContextToBinaryEncoder(c cloudevents.EventContext, b binding.BinaryEncoder) (err error)
func ToEvent ¶
func ToEvent(message binding.Message, factories ...binding.TransformerFactory) (e ce.Event, wasStructured bool, wasBinary bool, err error)
Translates a Message with a valid Structured, Binary or Event representation to an Event Returns: * event, true, false, nil if message was structured and correctly translated to Event * event, false, true, nil if message was binary and correctly translated to Event * event, false, false, nil if message was event and correctly translated to Event * nil, true, false, err if message was structured but error happened during translation * nil, false, true, err if message was binary but error happened during translation * nil, false, false, err if message was event but error happened during translation * nil, false, false, err in other cases
Types ¶
type BindingTransport ¶
type BindingTransport struct {
Sender binding.Sender
Receiver binding.Receiver
// contains filtered or unexported fields
}
BindingTransport implements transport.Transport using a Sender and Receiver.
func NewTransportAdapter ¶
func NewTransportAdapter(s binding.Sender, r binding.Receiver) *BindingTransport
func (*BindingTransport) HasConverter ¶
func (t *BindingTransport) HasConverter() bool
func (*BindingTransport) SetConverter ¶
func (t *BindingTransport) SetConverter(transport.Converter)
func (*BindingTransport) SetReceiver ¶
func (t *BindingTransport) SetReceiver(r transport.Receiver)
func (*BindingTransport) StartReceiver ¶
func (t *BindingTransport) StartReceiver(ctx context.Context) error
type EventMessage ¶
EventMessage type-converts a cloudevents.Event object to implement Message. This allows local cloudevents.Event objects to be sent directly via Sender.Send()
s.Send(ctx, binding.EventMessage(e))
func (EventMessage) Binary ¶
func (m EventMessage) Binary(b binding.BinaryEncoder) (err error)
func (EventMessage) Event ¶
func (m EventMessage) Event(builder binding.EventEncoder) error
func (EventMessage) Finish ¶
func (EventMessage) Finish(error) error
func (EventMessage) Structured ¶
func (m EventMessage) Structured(binding.StructuredEncoder) error
Source Files