Back to godoc.org
go.uber.org/yarpc

Package yarpc

v1.47.2
Latest Go to latest

The latest major version is .

Published: Sep 16, 2020 | License: MIT | Module: go.uber.org/yarpc
Path Synopsis
api/backoff
api/encoding Package encoding provides APIs for encoding authors.
api/middleware
api/middleware/middlewaretest Package middlewaretest is a generated GoMock package.
api/peer Package peer contains interfaces pertaining to peers, peer lists, peer list updaters, and generally how to choose a peer for an outbound request.
api/peer/peertest Package peertest is a generated GoMock package.
api/transport
api/transport/transporttest Package transporttest is a generated GoMock package.
api/x/introspection
api/x/restriction Package restriction is an experimental package for preventing unwanted transport-encoding pairs.
compressor/grpc Package yarpcgrpccompressor provides an adapter for YARPC compressors to gRPC compressors.
compressor/gzip Package yarpcgzip provides a YARPC binding for GZIP compression.
compressor/snappy Package yarpcsnappy provides a YARPC binding for snappy compression.
encoding/json Package json provides the JSON encoding for YARPC.
encoding/protobuf Package protobuf implements Protocol Buffers encoding support for YARPC.
encoding/protobuf/internal/testpb
encoding/protobuf/protoc-gen-yarpc-go Package main provides a protoc plugin that generates code for the protobuf encoding for YARPC.
encoding/protobuf/protoc-gen-yarpc-go/internal/lib Package lib contains the library code for protoc-gen-yarpc-go.
encoding/protobuf/reflection Package reflection exposes information about protobuf services required to implement the gRPC server reflection API and return information about the compatible registered yarpc services.
encoding/protobuf/testing
encoding/raw Package raw provides the raw encoding for YARPC.
encoding/thrift Package thrift implements Thrift encoding support for YARPC.
encoding/thrift/internal
encoding/thrift/internal/observabilitytest/test
encoding/thrift/internal/observabilitytest/test/testserviceclient
encoding/thrift/internal/observabilitytest/test/testservicefx Package testservicefx provides better integration for Fx for services implementing or calling TestService.
encoding/thrift/internal/observabilitytest/test/testserviceserver
encoding/thrift/internal/observabilitytest/test/testservicetest
encoding/thrift/thriftrw-plugin-yarpc thriftrw-plugin-yarpc implements a plugin for ThriftRW that generates code compatible with YARPC.
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/NOSERVICES
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/atomic
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/atomic/readonlystoreclient
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/atomic/readonlystorefx Package readonlystorefx provides better integration for Fx for services implementing or calling ReadOnlyStore.
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/atomic/readonlystoreserver
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/atomic/readonlystoretest
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/atomic/storeclient
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/atomic/storefx Package storefx provides better integration for Fx for services implementing or calling Store.
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/atomic/storeserver
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/atomic/storetest
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/common
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/common/baseserviceclient
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/common/baseservicefx Package baseservicefx provides better integration for Fx for services implementing or calling BaseService.
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/common/baseserviceserver
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/common/baseservicetest
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/common/emptyserviceclient
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/common/emptyservicefx Package emptyservicefx provides better integration for Fx for services implementing or calling EmptyService.
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/common/emptyserviceserver
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/common/emptyservicetest
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/common/extendemptyclient
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/common/extendemptyfx Package extendemptyfx provides better integration for Fx for services implementing or calling ExtendEmpty.
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/common/extendemptyserver
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/common/extendemptytest
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/common/extendonlyclient
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/common/extendonlyfx Package extendonlyfx provides better integration for Fx for services implementing or calling ExtendOnly.
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/common/extendonlyserver
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/common/extendonlytest
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/extends
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/extends/barclient
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/extends/barfx Package barfx provides better integration for Fx for services implementing or calling Bar.
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/extends/barserver
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/extends/bartest
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/extends/fooclient
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/extends/foofx Package foofx provides better integration for Fx for services implementing or calling Foo.
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/extends/fooserver
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/extends/footest
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/extends/nameclient
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/extends/namefx Package namefx provides better integration for Fx for services implementing or calling Name.
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/extends/nameserver
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/extends/nametest
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/weather
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/weather/weatherclient
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/weather/weatherfx Package weatherfx provides better integration for Fx for services implementing or calling Weather.
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/weather/weatherserver
encoding/thrift/thriftrw-plugin-yarpc/internal/tests/weather/weathertest
internal
internal/backoff
internal/bufferpool Package bufferpool maintains a pool of bytes.Buffers for use in encoding and transport implementations.
internal/clientconfig
internal/config
internal/cover cover is a tool that runs `go test` with cross-package coverage on this repository, ignoring any packages that opt out of coverage with .nocover files.
internal/digester
internal/errorsync
internal/firstoutboundmiddleware Package firstoutboundmiddleware annotates every outbound request with metadata like the request transport protocol.
internal/grpcctx Package grpcctx contains helper functionality for testing with grpc-go.
internal/grpcerrorcodes
internal/humanize
internal/inboundcall
internal/inboundmiddleware
internal/integrationtest
internal/interpolate Package interpolate provides a generic mechanism to interpolate variables into strings.
internal/introspection
internal/iopool
internal/net
internal/observability Package observability provides logging and metrics collection middleware for YARPC.
internal/outboundmiddleware
internal/protoplugin Package protoplugin provides utilities for protoc plugins.
internal/prototest/example
internal/prototest/examplepb
internal/prototest/exampleutil
internal/request
internal/routertest
internal/service-test
internal/shard
internal/stresstest Package main runs a stress test on each peer list implementation, concurrently adding, removing, connecting, disconnecting, and choosing peers.
internal/testtime Package testtime provides ways to scale time for tests running on CPU starved systems.
internal/testutils
internal/whitespace
internal/yarpcerrors
internal/yarpctest
peer Package peer contains components for managing peers.
peer/abstractlist Package abstractlist provides a utility for managing peer availability with a separate implementation of peer selection from just among available peers.
peer/abstractpeer
peer/direct
peer/hashring32
peer/hashring32/internal/farmhashring Package farmhashring provides a Farmhash shard function.
peer/hashring32/internal/hashring32
peer/hashring32/internal/radixsort32
peer/hostport
peer/peerlist Package peerlist is deprecated in favor of `go.uber.org/yarpc/peer/peerlist/v2` which can additionally convey peer list identifiers to the peerlist.Implementation without a wrapper type, allowing a peer list updater to communicate shard information for example.
peer/peerlist/v2 Package peerlist provides a utility for managing peer availability with a separate implementation of peer selection from just among available peers.
peer/pendingheap Package pendingheap provides an implementation of a peer list that sends traffic to the peer with the fewest pending requests, but degenerates to round robin when all peers have equal pending requests, using a heap.
peer/randpeer
peer/roundrobin
peer/tworandomchoices Package tworandomchoices provides a load balancer implementation that picks two peers at random and chooses the one with fewer pending requests.
peer/x Package x contains experimental components.
peer/x/peerheap
peer/x/roundrobin
pkg/encoding Package encoding contains helper functionality for encoding implementations.
pkg/errors Package errors contains helper functions for working with YARPC errors for encoding and transport implementations.
pkg/lifecycle Package lifecycle provides a helper for objects that have a synchronized lifecycle from idle, through running, to stopped or errored, executing start and stop transitions exactly once.
pkg/lifecycletest
pkg/procedure Package procedure contains utilities for handling procedure name mappings.
serialize
serialize/internal
transport Package transport implements the low level concerns of sending and receiving bytes.
transport/grpc Package grpc implements a YARPC transport based on the gRPC protocol.
transport/http Package http implements a YARPC transport based on the HTTP/1.1 protocol.
transport/tchannel Package tchannel implements a YARPC transport based on the TChannel protocol.
transport/tchannel/internal
x Package x contains experimental components.
x/debug
x/yarpctest
x/yarpctest/api Package api is for all interfaces and patterns that need to be implemented to interact with the yarpctest api, but not the explicit types we'll use to make requests, or the types that we'll use directly in tests.
x/yarpctest/types Package types are for objects in the yarpctest API that implement multiple interfaces.
yarpcconfig Package yarpcconfig implements a generic configuration system that may be used to build YARPC Dispatchers from configurations specified in different markup formats.
yarpcerrors
yarpctest Package yarpctest provides utilities to test YARPC services and clients.
yarpctest/recorder Package recorder records & replay yarpc requests on the client side.
MODULE go.uber.org/yarpc/internal/crossdock
MODULE go.uber.org/yarpc/internal/examples