OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
refs:Balancer
(Results
1 - 9
of
9
) sorted by null
/external/syzkaller/vendor/google.golang.org/grpc/balancer/
balancer.go
19
// Package
balancer
defines APIs for load balancing in gRPC.
21
package
balancer
package
35
// m is a map from name to
balancer
builder.
39
// Register registers the
balancer
builder to the
balancer
map. b.Name
100
// NewSubConn is called by
balancer
to create a new SubConn.
108
// UpdateBalancerState is called by
balancer
to nofity gRPC that some internal
109
// state in
balancer
has changed.
115
// ResolveNow is called by
balancer
to notify gRPC to do a name resolving.
124
// DialCreds is the transport credential the
Balancer
implementation ca
[
all
...]
/external/syzkaller/vendor/google.golang.org/grpc/
balancer.go
36
// Deprecated: please use package
balancer
.
45
// BalancerConfig specifies the configurations for
Balancer
.
47
// Deprecated: please use package
balancer
.
49
// DialCreds is the transport credential the
Balancer
implementation can
50
// use to dial to a remote load
balancer
server. The
Balancer
implementations
53
// Dialer is the custom dialer the
Balancer
implementation can use to dial
54
// to a remote load
balancer
server. The
Balancer
implementations
55
// can ignore this if it doesn't need to talk to remote
balancer
[
all
...]
pickfirst.go
23
"google.golang.org/grpc/
balancer
"
29
// PickFirstBalancerName is the name of the pick_first
balancer
.
32
func newPickfirstBuilder()
balancer
.Builder {
38
func (*pickfirstBuilder) Build(cc
balancer
.ClientConn, opt
balancer
.BuildOptions)
balancer
.
Balancer
{
47
cc
balancer
.ClientConn
48
sc
balancer
.SubConn
57
b.sc, err = b.cc.NewSubConn(addrs,
balancer
.NewSubConnOptions{}
[
all
...]
balancer_v1_wrapper.go
26
"google.golang.org/grpc/
balancer
"
35
b
Balancer
// The v1
balancer
.
38
func (bwb *balancerWrapperBuilder) Build(cc
balancer
.ClientConn, opts
balancer
.BuildOptions)
balancer
.
Balancer
{
51
balancer
: bwb.b,
56
conns: make(map[resolver.Address]
balancer
.SubConn),
57
connSt: make(map[
balancer
.SubConn]*scState)
[
all
...]
balancer_conn_wrappers.go
25
"google.golang.org/grpc/
balancer
"
33
sc
balancer
.SubConn
93
// It implements
balancer
.ClientConn interface.
96
balancer
balancer
.
Balancer
105
func newCCBalancerWrapper(cc *ClientConn, b
balancer
.Builder, bopts
balancer
.BuildOptions) *ccBalancerWrapper {
114
ccb.
balancer
= b.Build(ccb, bopts)
118
// watcher
balancer
functions sequentially, so the balancer can be implemente
[
all
...]
clientconn.go
33
"google.golang.org/grpc/
balancer
"
34
_ "google.golang.org/grpc/
balancer
/roundrobin" // To register roundrobin.
71
// errBalancerClosed indicates that the
balancer
is closed.
72
errBalancerClosed = errors.New("grpc:
balancer
is closed")
111
// This is used by v1
balancer
dial option WithBalancer to support v1
112
//
balancer
, and also by WithBalancerName dial option.
113
balancerBuilder
balancer
.Builder
223
// WithBalancer returns a DialOption which sets a load
balancer
with the v1 API.
226
// Deprecated: use the new
balancer
APIs in
balancer
package and WithBalancerName
[
all
...]
/external/syzkaller/vendor/google.golang.org/grpc/balancer/base/
balancer.go
23
"google.golang.org/grpc/
balancer
"
34
func (bb *baseBuilder) Build(cc
balancer
.ClientConn, opt
balancer
.BuildOptions)
balancer
.
Balancer
{
39
subConns: make(map[resolver.Address]
balancer
.SubConn),
40
scStates: make(map[
balancer
.SubConn]connectivity.State),
45
picker: NewErrPicker(
balancer
.ErrNoSubConnAvailable),
54
cc
balancer
.ClientConn
60
subConns map[resolver.Address]
balancer
.SubCon
[
all
...]
/external/protobuf/java/core/src/main/java/com/google/protobuf/
RopeByteString.java
207
return new
Balancer
().balance(left, right);
564
private static class
Balancer
{
/external/kotlinc/lib/
kotlin-reflect.jar
Completed in 906 milliseconds