Documentation ¶
Index ¶
- func MakeNetHTTPEndpointConsumer[T any](stream runtime.TypedInputStream[T]) runtime.Consumer[T]
- type NetHTTPDataSource
- type NetHTTPEndpoint
- type NetHTTPEndpointConsumer
- type NetHTTPEndpointGorillaSchemaConsumer
- type NetHTTPEndpointJsonConsumer
- type NetHTTPEndpointRequestData
- type NetHTTPEndpointTypedConsumer
- type NetHTTPInputDataSource
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func MakeNetHTTPEndpointConsumer ¶
func MakeNetHTTPEndpointConsumer[T any](stream runtime.TypedInputStream[T]) runtime.Consumer[T]
Types ¶
type NetHTTPDataSource ¶
type NetHTTPDataSource struct { *runtime.InputDataSource // contains filtered or unexported fields }
func (*NetHTTPDataSource) AddHandler ¶
func (ds *NetHTTPDataSource) AddHandler(pattern string, handler http.Handler)
func (*NetHTTPDataSource) Stop ¶
func (ds *NetHTTPDataSource) Stop(ctx context.Context)
type NetHTTPEndpoint ¶
type NetHTTPEndpoint struct { *runtime.DataSourceEndpoint // contains filtered or unexported fields }
func (*NetHTTPEndpoint) ServeHTTP ¶
func (ep *NetHTTPEndpoint) ServeHTTP(w http.ResponseWriter, r *http.Request)
type NetHTTPEndpointConsumer ¶
type NetHTTPEndpointConsumer interface { runtime.InputEndpointConsumer EndpointRequest(requestData NetHTTPEndpointRequestData) error }
type NetHTTPEndpointGorillaSchemaConsumer ¶
type NetHTTPEndpointGorillaSchemaConsumer[T any] struct { NetHTTPEndpointTypedConsumer[T] // contains filtered or unexported fields }
func (*NetHTTPEndpointGorillaSchemaConsumer[T]) EndpointRequest ¶
func (ec *NetHTTPEndpointGorillaSchemaConsumer[T]) EndpointRequest(requestData NetHTTPEndpointRequestData) error
type NetHTTPEndpointJsonConsumer ¶
type NetHTTPEndpointJsonConsumer[T any] struct { NetHTTPEndpointTypedConsumer[T] // contains filtered or unexported fields }
func (*NetHTTPEndpointJsonConsumer[T]) DeserializeJson ¶
func (ec *NetHTTPEndpointJsonConsumer[T]) DeserializeJson(data string) (T, error)
func (*NetHTTPEndpointJsonConsumer[T]) DeserializeJsonBody ¶
func (ec *NetHTTPEndpointJsonConsumer[T]) DeserializeJsonBody(reader io.Reader) (T, error)
func (*NetHTTPEndpointJsonConsumer[T]) EndpointRequest ¶
func (ec *NetHTTPEndpointJsonConsumer[T]) EndpointRequest(requestData NetHTTPEndpointRequestData) error
type NetHTTPEndpointTypedConsumer ¶
type NetHTTPEndpointTypedConsumer[T any] struct { *runtime.DataSourceEndpointConsumer[T] // contains filtered or unexported fields }
type NetHTTPInputDataSource ¶
type NetHTTPInputDataSource interface { runtime.DataSource AddHandler(pattern string, handler http.Handler) }
Click to show internal directories.
Click to hide internal directories.