client

Documentation

Index

• Variables
• func New(baseURL string, opts ...option) (*client, error)
• func WithHTTPClient(h httpClient) option
• func WithIdentity(identity crypto.PrivKey) option
• func WithProviderInfo(peerID peer.ID, addrs []multiaddr.Multiaddr) option
• type HTTPError
  • func (e *HTTPError) Error() string
• type ResponseBodyLimitedTransport
  • func (r *ResponseBodyLimitedTransport) RoundTrip(req *http.Request) (*http.Response, error)

Variables

var (
	ViewLatency = &view.View{
		Measure:     measureLatency,
		Aggregation: distMS,
		TagKeys:     []tag.Key{keyOperation, keyHost, keyStatusCode, keyError},
	}
	ViewLength = &view.View{
		Measure:     measureLength,
		Aggregation: distLength,
		TagKeys:     []tag.Key{keyOperation, keyHost},
	}

	OpenCensusViews = []*view.View{
		ViewLatency,
		ViewLength,
	}
)

Functions

func New

func New(baseURL string, opts ...option) (*client, error)

New creates a content routing API client. The Provider and identity parameters are option. If they are nil, the `Provide` method will not function.

func WithHTTPClient

func WithHTTPClient(h httpClient) option

func WithIdentity

func WithIdentity(identity crypto.PrivKey) option

func WithProviderInfo

func WithProviderInfo(peerID peer.ID, addrs []multiaddr.Multiaddr) option

Types

type HTTPError

type HTTPError struct {
	StatusCode int
	Body       string
}

func (*HTTPError) Error

func (e *HTTPError) Error() string

type ResponseBodyLimitedTransport

type ResponseBodyLimitedTransport struct {
	http.RoundTripper
	LimitBytes int64
}

func (*ResponseBodyLimitedTransport) RoundTrip

func (r *ResponseBodyLimitedTransport) RoundTrip(req *http.Request) (*http.Response, error)