transport

Documentation

Index

• type HTTPTransporter
  • func NewHTTP(timeout time.Duration) *HTTPTransporter
  • func (tp *HTTPTransporter) Get(ctx context.Context, addr string, header map[string][]string) ([]byte, error)
  • func (tp *HTTPTransporter) Post(ctx context.Context, addr string, header map[string][]string, body io.Reader) ([]byte, error)

Types

type HTTPTransporter

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

HTTPTransport is a centralized mean for downstream request. It takes care of request timeouts an traceID propagation.

func NewHTTP

func NewHTTP(timeout time.Duration) *HTTPTransporter

func (*HTTPTransporter) Get

func (tp *HTTPTransporter) Get(ctx context.Context, addr string, header map[string][]string) ([]byte, error)

Get exectutes an http post request.

func (*HTTPTransporter) Post

func (tp *HTTPTransporter) Post(ctx context.Context, addr string, header map[string][]string, body io.Reader) ([]byte, error)

Post exectutes an http post request.