Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var EventMessageTypeHeader = eventstream.Header{ Name: eventstreamapi.MessageTypeHeader, Value: eventstream.StringValue(eventstreamapi.EventMessageType), }
EventMessageTypeHeader is a event message type header for marking an message as being the event type.
Functions ¶
func MarshalEventPayload ¶
func MarshalEventPayload( payloadMarshaler protocol.PayloadMarshaler, v interface{}, ) []byte
MarshalEventPayload marshals a SDK API shape into its associated wire protocol payload.
func SetupEventStreamSession ¶
func SetupEventStreamSession( t *testing.T, handler http.Handler, h2 bool, ) (sess *session.Session, cleanupFn func(), err error)
SetupEventStreamSession creates a HTTP server SDK session for communicating with that server to be used for EventStream APIs. If HTTP/2 is enabled the server/client will only attempt to use HTTP/2.
Types ¶
type ServeEventStream ¶
type ServeEventStream struct {
T *testing.T
Events []eventstream.Message
}
ServeEventStream provides serving EventStream messages from a HTTP server to the client. The events are sent sequentially to the client without delay.
func (ServeEventStream) ServeHTTP ¶
func (s ServeEventStream) ServeHTTP(w http.ResponseWriter, r *http.Request)
Source Files
Click to show internal directories.
Click to hide internal directories.