http

Documentation

Index

• type AfterRequestPlugin
• type BeforeRequestPlugin
• type JaegerBeforePlugin
  • func (*JaegerBeforePlugin) Handle(ctx context.Context, req *http.Request) error
• type Option
  • func WithAfterPlugins(plugins ...AfterRequestPlugin) Option
  • func WithBeforePlugins(plugins ...BeforeRequestPlugin) Option
  • func WithCodec(c codec.Codec) Option
  • func WithLogger(logger *loggingRPC.RPCLogger) Option
• type RPC
  • func New(opts ...Option) *RPC
  • func (r *RPC) Send(ctx context.Context, serviceName, method, uri string, header http.Header, ...) (ret Response, err error)
• type Response

Types

type AfterRequestPlugin

type AfterRequestPlugin interface {
	Handle(ctx context.Context, req *http.Request, resp *http.Response) error
}

type BeforeRequestPlugin

type BeforeRequestPlugin interface {
	Handle(ctx context.Context, req *http.Request) error
}

type JaegerBeforePlugin

type JaegerBeforePlugin struct{}

func (*JaegerBeforePlugin) Handle

func (*JaegerBeforePlugin) Handle(ctx context.Context, req *http.Request) error

type Option

type Option func(r *RPC)

func WithAfterPlugins

func WithAfterPlugins(plugins ...AfterRequestPlugin) Option

func WithBeforePlugins

func WithBeforePlugins(plugins ...BeforeRequestPlugin) Option

func WithCodec

func WithCodec(c codec.Codec) Option

func WithLogger

func WithLogger(logger *loggingRPC.RPCLogger) Option

type RPC

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

func New

func New(opts ...Option) *RPC

func (*RPC) Send

func (r *RPC) Send(ctx context.Context, serviceName, method, uri string, header http.Header, timeout time.Duration, reqData interface{}, respData interface{}) (ret Response, err error)

Send is send HTTP request

type Response

type Response struct {
	HTTPCode int
	Response []byte
}