server

Documentation

Index

• func HTTPRequest(r *http.Request) (*httpgrpc.HTTPRequest, error)
• func ParseURL(unparsed string) (string, error)
• func WriteError(w http.ResponseWriter, err error)
• func WriteResponse(w http.ResponseWriter, resp *httpgrpc.HTTPResponse) error
• type Client
  • func NewClient(address string) (*Client, error)
  • func (c *Client) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type Server
  • func NewServer(handler http.Handler) *Server
  • func (s Server) Handle(ctx context.Context, r *httpgrpc.HTTPRequest) (*httpgrpc.HTTPResponse, error)

Functions

func HTTPRequest

func HTTPRequest(r *http.Request) (*httpgrpc.HTTPRequest, error)

HTTPRequest wraps an ordinary HTTPRequest with a gRPC one

func ParseURL

func ParseURL(unparsed string) (string, error)

ParseURL deals with direct:// style URLs, as well as kubernetes:// urls. For backwards compatibility it treats URLs without schems as kubernetes://.

func WriteError

func WriteError(w http.ResponseWriter, err error)

WriteError converts an httpgrpc error to an HTTP one

func WriteResponse

func WriteResponse(w http.ResponseWriter, resp *httpgrpc.HTTPResponse) error

WriteResponse converts an httpgrpc response to an HTTP one

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

Client is a http.Handler that forwards the request over gRPC.

func NewClient

func NewClient(address string) (*Client, error)

NewClient makes a new Client, given a kubernetes service address.

func (*Client) ServeHTTP

func (c *Client) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP implements http.Handler

type Server

type Server struct {
	// contains filtered or unexported fields
}

Server implements HTTPServer. HTTPServer is a generated interface that gRPC servers must implement.

func NewServer

func NewServer(handler http.Handler) *Server

NewServer makes a new Server.

func (Server) Handle

func (s Server) Handle(ctx context.Context, r *httpgrpc.HTTPRequest) (*httpgrpc.HTTPResponse, error)

Handle implements HTTPServer.