http

Documentation

Index

• func Do(ctx context.Context, method Method, target string, opts ...ClientOptionFunc) ([]byte, error)
• func GetDefaultHttpClient() *http.Client
• func Serve(ctx context.Context, addr string, handle http.Handler, ...) error
• type ClientOptionFunc
  • func WithClient(client *http.Client) ClientOptionFunc
  • func WithClientBody(body []byte) ClientOptionFunc
  • func WithClientDelayFn(delayTypeFn retry.DelayTypeFunc) ClientOptionFunc
  • func WithClientHeader(header map[string]string) ClientOptionFunc
  • func WithClientLogger(logger log.Log) ClientOptionFunc
  • func WithClientQuery(query map[string]string) ClientOptionFunc
  • func WithClientRetry(retry int) ClientOptionFunc
  • func WithClientTrace(trace bool) ClientOptionFunc
• type IncomeInterceptor
• type Method
  • func (i Method) String() string
• type OutcomeInterceptor
• type ServerOptionFunc
  • func WithServerLogger(logger log.Log) ServerOptionFunc
• type WebsocketProxy
  • func (wp *WebsocketProxy) Init(addr string, opts ...WebsocketProxyOptionFunc) (*WebsocketProxy, error)
  • func (wp *WebsocketProxy) WebsocketProxyHandle(w http.ResponseWriter, r *http.Request, _ httprouter.Params)
• type WebsocketProxyOptionFunc
  • func WithWebsocketProxyIncomeInterceptor(incomeInterceptor IncomeInterceptor) WebsocketProxyOptionFunc
  • func WithWebsocketProxyLogger(logger log.Log) WebsocketProxyOptionFunc
  • func WithWebsocketProxyOutcomeInterceptor(outcomeInterceptor OutcomeInterceptor) WebsocketProxyOptionFunc

Functions

func Do

func Do(ctx context.Context, method Method, target string, opts ...ClientOptionFunc) ([]byte, error)

func GetDefaultHttpClient

func GetDefaultHttpClient() *http.Client

func Serve

func Serve(ctx context.Context, addr string, handle http.Handler, opts ...ServerOptionFunc) error

Types

type ClientOptionFunc

type ClientOptionFunc func(*clientConfig)

func WithClient

func WithClient(client *http.Client) ClientOptionFunc

func WithClientBody

func WithClientBody(body []byte) ClientOptionFunc

func WithClientDelayFn

func WithClientDelayFn(delayTypeFn retry.DelayTypeFunc) ClientOptionFunc

func WithClientHeader

func WithClientHeader(header map[string]string) ClientOptionFunc

func WithClientLogger

func WithClientLogger(logger log.Log) ClientOptionFunc

func WithClientQuery

func WithClientQuery(query map[string]string) ClientOptionFunc

func WithClientRetry

func WithClientRetry(retry int) ClientOptionFunc

func WithClientTrace

func WithClientTrace(trace bool) ClientOptionFunc

type IncomeInterceptor

type IncomeInterceptor func(int, []byte) (int, []byte)

type Method

type Method int64

const (
	GET Method = iota
	POST
)

func (Method) String

func (i Method) String() string

type OutcomeInterceptor

type OutcomeInterceptor func(int, []byte) (int, []byte)

type ServerOptionFunc

type ServerOptionFunc func(*serverConfig)

func WithServerLogger

func WithServerLogger(logger log.Log) ServerOptionFunc

type WebsocketProxy

type WebsocketProxy struct {
	Backend            *url.URL
	Upgrader           *websocket.Upgrader
	Dialer             *websocket.Dialer
	Logger             log.Log
	IncomeInterceptor  IncomeInterceptor
	OutcomeInterceptor OutcomeInterceptor
}

func (*WebsocketProxy) Init

func (wp *WebsocketProxy) Init(addr string, opts ...WebsocketProxyOptionFunc) (*WebsocketProxy, error)

func (*WebsocketProxy) WebsocketProxyHandle

func (wp *WebsocketProxy) WebsocketProxyHandle(w http.ResponseWriter, r *http.Request, _ httprouter.Params)

type WebsocketProxyOptionFunc

type WebsocketProxyOptionFunc func(*WebsocketProxy)

func WithWebsocketProxyIncomeInterceptor

func WithWebsocketProxyIncomeInterceptor(incomeInterceptor IncomeInterceptor) WebsocketProxyOptionFunc

func WithWebsocketProxyLogger

func WithWebsocketProxyLogger(logger log.Log) WebsocketProxyOptionFunc

func WithWebsocketProxyOutcomeInterceptor

func WithWebsocketProxyOutcomeInterceptor(outcomeInterceptor OutcomeInterceptor) WebsocketProxyOptionFunc