Versions in this module Expand all Collapse all v1 v1.0.1 Jul 4, 2024 v1.0.0 Jul 4, 2024 Changes in this version + const ChunkSignatureHeader + const DateHeader + const ErrorCodeHeader + const ErrorMessageHeader + const ErrorMessageType + const EventMessageType + const EventTypeHeader + const ExceptionMessageType + const ExceptionTypeHeader + const InputWriterCloseErrorCode + const MessageTypeHeader + func ApplyHTTPTransportFixes(r *request.Request) + func GetHeaderString(msg eventstream.Message, headerName string) (string, error) + type BufferEncoder struct + func NewBufferEncoder() *BufferEncoder + func (e *BufferEncoder) Encode(msg eventstream.Message) ([]byte, error) + type Encoder interface + Encode func(eventstream.Message) error + type EventReader struct + func NewEventReader(decoder *eventstream.Decoder, payloadUnmarshaler protocol.PayloadUnmarshaler, ...) *EventReader + func (r *EventReader) ReadEvent() (event interface{}, err error) + type EventWriter struct + func NewEventWriter(encoder Encoder, pm protocol.PayloadMarshaler, ...) *EventWriter + func (w *EventWriter) WriteEvent(event Marshaler) error + type Marshaler interface + MarshalEvent func(protocol.PayloadMarshaler) (eventstream.Message, error) + type OnceError struct + func NewOnceError() *OnceError + func (e *OnceError) Err() error + func (e *OnceError) ErrorSet() <-chan struct{} + func (e *OnceError) SetError(err error) + type SignEncoder struct + func NewSignEncoder(signer StreamSigner, encoder Encoder) *SignEncoder + func (s *SignEncoder) Close() error + func (s *SignEncoder) Encode(msg eventstream.Message) error + type StreamSigner interface + GetSignature func(headers, payload []byte, date time.Time) ([]byte, error) + type StreamWriter struct + func NewStreamWriter(eventWriter *EventWriter, streamCloser io.Closer) *StreamWriter + func (w *StreamWriter) Close() error + func (w *StreamWriter) Err() error + func (w *StreamWriter) ErrorSet() <-chan struct{} + func (w *StreamWriter) Send(ctx aws.Context, event Marshaler) error + type UnknownMessageTypeError struct + Message eventstream.Message + Type string + func (e *UnknownMessageTypeError) Error() string + type Unmarshaler interface + UnmarshalEvent func(protocol.PayloadUnmarshaler, eventstream.Message) error