http

Documentation

Index

• func MakeNetHTTPEndpointConsumer[T any](stream runtime.TypedInputStream[T], handler NetHTTPEndpointHandler[T]) runtime.Consumer[T]
• type HandlerData
• type NetHTTPDataSource
  • func (ds *NetHTTPDataSource) AddHandler(pattern string, handler http.Handler)
  • func (ds *NetHTTPDataSource) Start(ctx context.Context) error
  • func (ds *NetHTTPDataSource) Stop(ctx context.Context)
• type NetHTTPEndpoint
  • func (ep *NetHTTPEndpoint) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (ep *NetHTTPEndpoint) Start(ctx context.Context) error
  • func (ep *NetHTTPEndpoint) Stop(ctx context.Context)
• type NetHTTPEndpointConsumer
• type NetHTTPEndpointCustomConsumer
  • func (ec *NetHTTPEndpointCustomConsumer[T]) EndpointRequest(requestData NetHTTPEndpointRequestData) error
  • func (ec *NetHTTPEndpointCustomConsumer[T]) Out(value T)
  • func (ec *NetHTTPEndpointCustomConsumer[T]) Start(ctx context.Context) error
  • func (ec *NetHTTPEndpointCustomConsumer[T]) Stop(ctx context.Context)
• type NetHTTPEndpointFormConsumer
  • func (ec *NetHTTPEndpointFormConsumer[T]) EndpointRequest(requestData NetHTTPEndpointRequestData) error
  • func (ec *NetHTTPEndpointFormConsumer[T]) Start(ctx context.Context) error
  • func (ec *NetHTTPEndpointFormConsumer[T]) Stop(ctx context.Context)
• type NetHTTPEndpointHandler
• type NetHTTPEndpointJsonConsumer
  • func (ec *NetHTTPEndpointJsonConsumer[T]) DeserializeJson(data string) (T, error)
  • func (ec *NetHTTPEndpointJsonConsumer[T]) DeserializeJsonBody(reader io.Reader) (T, error)
  • func (ec *NetHTTPEndpointJsonConsumer[T]) EndpointRequest(requestData NetHTTPEndpointRequestData) error
  • func (ec *NetHTTPEndpointJsonConsumer[T]) Start(ctx context.Context) error
  • func (ec *NetHTTPEndpointJsonConsumer[T]) Stop(ctx context.Context)
• type NetHTTPEndpointRequestData
• type NetHTTPEndpointTypedConsumer
• type NetHTTPInputDataSource
• type NetHTTPInputEndpoint

Functions

func MakeNetHTTPEndpointConsumer

func MakeNetHTTPEndpointConsumer[T any](stream runtime.TypedInputStream[T], handler NetHTTPEndpointHandler[T]) runtime.Consumer[T]

Types

type HandlerData

type HandlerData struct {
	Writer  http.ResponseWriter
	Request *http.Request
}

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) Start

func (ds *NetHTTPDataSource) Start(ctx context.Context) error

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)

func (*NetHTTPEndpoint) Start

func (ep *NetHTTPEndpoint) Start(ctx context.Context) error

func (*NetHTTPEndpoint) Stop

func (ep *NetHTTPEndpoint) Stop(ctx context.Context)

type NetHTTPEndpointConsumer

type NetHTTPEndpointConsumer interface {
	runtime.InputEndpointConsumer
	EndpointRequest(requestData NetHTTPEndpointRequestData) error
	Start(context.Context) error
	Stop(context.Context)
}

type NetHTTPEndpointCustomConsumer

type NetHTTPEndpointCustomConsumer[T any] struct {
	NetHTTPEndpointTypedConsumer[T]
	// contains filtered or unexported fields
}

func (*NetHTTPEndpointCustomConsumer[T]) EndpointRequest

func (ec *NetHTTPEndpointCustomConsumer[T]) EndpointRequest(requestData NetHTTPEndpointRequestData) error

func (*NetHTTPEndpointCustomConsumer[T]) Out

func (ec *NetHTTPEndpointCustomConsumer[T]) Out(value T)

func (*NetHTTPEndpointCustomConsumer[T]) Start

func (ec *NetHTTPEndpointCustomConsumer[T]) Start(ctx context.Context) error

func (*NetHTTPEndpointCustomConsumer[T]) Stop

func (ec *NetHTTPEndpointCustomConsumer[T]) Stop(ctx context.Context)

type NetHTTPEndpointFormConsumer

type NetHTTPEndpointFormConsumer[T any] struct {
	NetHTTPEndpointTypedConsumer[T]
	// contains filtered or unexported fields
}

func (*NetHTTPEndpointFormConsumer[T]) EndpointRequest

func (ec *NetHTTPEndpointFormConsumer[T]) EndpointRequest(requestData NetHTTPEndpointRequestData) error

func (*NetHTTPEndpointFormConsumer[T]) Start

func (ec *NetHTTPEndpointFormConsumer[T]) Start(ctx context.Context) error

func (*NetHTTPEndpointFormConsumer[T]) Stop

func (ec *NetHTTPEndpointFormConsumer[T]) Stop(ctx context.Context)

type NetHTTPEndpointHandler

type NetHTTPEndpointHandler[T any] interface {
	Handler(*HandlerData, runtime.Collect[T])
}

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

func (*NetHTTPEndpointJsonConsumer[T]) Start

func (ec *NetHTTPEndpointJsonConsumer[T]) Start(ctx context.Context) error

func (*NetHTTPEndpointJsonConsumer[T]) Stop

func (ec *NetHTTPEndpointJsonConsumer[T]) Stop(ctx context.Context)

type NetHTTPEndpointRequestData

type NetHTTPEndpointRequestData interface {
	ResponseWriter() http.ResponseWriter
	Request() *http.Request
	GetBody() (io.ReadCloser, error)
	GetForm() (url.Values, error)
	GetQuery() url.Values
	GetMethod() string
}

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)
}

type NetHTTPInputEndpoint

type NetHTTPInputEndpoint interface {
	runtime.InputEndpoint
	Start(context.Context) error
	Stop(context.Context)
}