| /dports/sysutils/munin-contrib/contrib-c31cb28/plugins/nginx/ |
| H A D | nginx_upstream_multi_ | 101 upstreams = {}
106 upstreams[upstream] = {
139 for upstream in upstreams.keys():
144 for upstream in upstreams.keys():
156 for upstream in upstreams.keys():
171 for upstream in upstreams.keys():
185 for upstream in upstreams.keys():
297 for upstream in upstreams.keys():
306 for upstream in upstreams.keys():
321 uTime = upstreams[upstream]["time"] / upstreams[upstream]["requests"]
[all …]
|
| /dports/net/rclone/rclone-1.57.0/backend/union/policy/ |
| H A D | epff.go | 23 for _, u := range upstreams {
35 for range upstreams {
49 if len(upstreams) == 0 {
52 upstreams = filterRO(upstreams)
53 if len(upstreams) == 0 {
56 u, err := p.epff(ctx, upstreams, path)
74 if len(upstreams) == 0 {
77 upstreams = filterNC(upstreams)
78 if len(upstreams) == 0 {
99 if len(upstreams) == 0 {
[all …]
|
| H A D | epall.go | 26 ufs := make([]*upstream.Fs, len(upstreams))
27 for i, u := range upstreams {
54 if len(upstreams) == 0 {
57 upstreams = filterRO(upstreams)
58 if len(upstreams) == 0 {
61 return p.epall(ctx, upstreams, path)
78 if len(upstreams) == 0 {
81 upstreams = filterNC(upstreams)
82 if len(upstreams) == 0 {
85 upstreams, err := p.epall(ctx, upstreams, path+"/..")
[all …]
|
| H A D | eprand.go | 21 func (p *EpRand) rand(upstreams []*upstream.Fs) *upstream.Fs {
22 return upstreams[rand.Intn(len(upstreams))]
30 func (p *EpRand) Action(ctx context.Context, upstreams []*upstream.Fs, path string) ([]*upstream.Fs…
31 upstreams, err := p.EpAll.Action(ctx, upstreams, path)
35 return []*upstream.Fs{p.rand(upstreams)}, nil
49 upstreams, err := p.EpAll.Create(ctx, upstreams, path)
53 return []*upstream.Fs{p.rand(upstreams)}, nil
66 func (p *EpRand) Search(ctx context.Context, upstreams []*upstream.Fs, path string) (*upstream.Fs, …
67 if len(upstreams) == 0 {
70 upstreams, err := p.epall(ctx, upstreams, path)
[all …]
|
| H A D | rand.go | 21 func (p *Rand) rand(upstreams []*upstream.Fs) *upstream.Fs {
22 return upstreams[rand.Intn(len(upstreams))]
30 func (p *Rand) Action(ctx context.Context, upstreams []*upstream.Fs, path string) ([]*upstream.Fs, …
31 upstreams, err := p.All.Action(ctx, upstreams, path)
35 return []*upstream.Fs{p.rand(upstreams)}, nil
49 upstreams, err := p.All.Create(ctx, upstreams, path)
53 return []*upstream.Fs{p.rand(upstreams)}, nil
66 func (p *Rand) Search(ctx context.Context, upstreams []*upstream.Fs, path string) (*upstream.Fs, er…
67 if len(upstreams) == 0 {
70 upstreams, err := p.epall(ctx, upstreams, path)
[all …]
|
| H A D | newest.go | 25 ufs := make([]*upstream.Fs, len(upstreams))
26 mtimes := make([]time.Time, len(upstreams))
27 for i, u := range upstreams {
85 if len(upstreams) == 0 {
88 upstreams = filterRO(upstreams)
89 if len(upstreams) == 0 {
111 if len(upstreams) == 0 {
114 upstreams = filterNC(upstreams)
115 if len(upstreams) == 0 {
137 if len(upstreams) == 0 {
[all …]
|
| H A D | eplfs.go | 21 func (p *EpLfs) lfs(upstreams []*upstream.Fs) (*upstream.Fs, error) {
24 for _, u := range upstreams {
59 func (p *EpLfs) Action(ctx context.Context, upstreams []*upstream.Fs, path string) ([]*upstream.Fs,…
60 upstreams, err := p.EpAll.Action(ctx, upstreams, path)
64 u, err := p.lfs(upstreams)
80 upstreams, err := p.EpAll.Create(ctx, upstreams, path)
84 u, err := p.lfs(upstreams)
99 func (p *EpLfs) Search(ctx context.Context, upstreams []*upstream.Fs, path string) (*upstream.Fs, e…
100 if len(upstreams) == 0 {
103 upstreams, err := p.epall(ctx, upstreams, path)
[all …]
|
| H A D | eplus.go | 21 func (p *EpLus) lus(upstreams []*upstream.Fs) (*upstream.Fs, error) {
24 for _, u := range upstreams {
59 func (p *EpLus) Action(ctx context.Context, upstreams []*upstream.Fs, path string) ([]*upstream.Fs,…
60 upstreams, err := p.EpAll.Action(ctx, upstreams, path)
64 u, err := p.lus(upstreams)
80 upstreams, err := p.EpAll.Create(ctx, upstreams, path)
84 u, err := p.lus(upstreams)
99 func (p *EpLus) Search(ctx context.Context, upstreams []*upstream.Fs, path string) (*upstream.Fs, e…
100 if len(upstreams) == 0 {
103 upstreams, err := p.epall(ctx, upstreams, path)
[all …]
|
| H A D | epmfs.go | 20 func (p *EpMfs) mfs(upstreams []*upstream.Fs) (*upstream.Fs, error) {
23 for _, u := range upstreams {
58 func (p *EpMfs) Action(ctx context.Context, upstreams []*upstream.Fs, path string) ([]*upstream.Fs,…
59 upstreams, err := p.EpAll.Action(ctx, upstreams, path)
63 u, err := p.mfs(upstreams)
79 upstreams, err := p.EpAll.Create(ctx, upstreams, path)
83 u, err := p.mfs(upstreams)
98 func (p *EpMfs) Search(ctx context.Context, upstreams []*upstream.Fs, path string) (*upstream.Fs, e…
99 if len(upstreams) == 0 {
102 upstreams, err := p.epall(ctx, upstreams, path)
[all …]
|
| H A D | eplno.go | 21 func (p *EpLno) lno(upstreams []*upstream.Fs) (*upstream.Fs, error) {
24 for _, u := range upstreams {
59 func (p *EpLno) Action(ctx context.Context, upstreams []*upstream.Fs, path string) ([]*upstream.Fs,…
60 upstreams, err := p.EpAll.Action(ctx, upstreams, path)
64 u, err := p.lno(upstreams)
80 upstreams, err := p.EpAll.Create(ctx, upstreams, path)
84 u, err := p.lno(upstreams)
99 func (p *EpLno) Search(ctx context.Context, upstreams []*upstream.Fs, path string) (*upstream.Fs, e…
100 if len(upstreams) == 0 {
103 upstreams, err := p.epall(ctx, upstreams, path)
[all …]
|
| H A D | ff.go | 23 func (p *FF) Create(ctx context.Context, upstreams []*upstream.Fs, path string) ([]*upstream.Fs, er…
24 if len(upstreams) == 0 {
27 upstreams = filterNC(upstreams)
28 if len(upstreams) == 0 {
29 return upstreams, fs.ErrorPermissionDenied
31 return upstreams[:1], nil
|
| H A D | lus.go | 23 func (p *Lus) Create(ctx context.Context, upstreams []*upstream.Fs, path string) ([]*upstream.Fs, e…
24 if len(upstreams) == 0 {
27 upstreams = filterNC(upstreams)
28 if len(upstreams) == 0 {
31 u, err := p.lus(upstreams)
|
| H A D | lfs.go | 23 func (p *Lfs) Create(ctx context.Context, upstreams []*upstream.Fs, path string) ([]*upstream.Fs, e…
24 if len(upstreams) == 0 {
27 upstreams = filterNC(upstreams)
28 if len(upstreams) == 0 {
31 u, err := p.lfs(upstreams)
|
| H A D | lno.go | 23 func (p *Lno) Create(ctx context.Context, upstreams []*upstream.Fs, path string) ([]*upstream.Fs, e…
24 if len(upstreams) == 0 {
27 upstreams = filterNC(upstreams)
28 if len(upstreams) == 0 {
31 u, err := p.lno(upstreams)
|
| /dports/devel/libunit/unit-1.26.1/src/ |
| H A D | nxt_upstream.c | 25 nxt_upstreams_t *upstreams; in nxt_upstreams_create() local
45 upstreams = nxt_mp_zalloc(mp, size); in nxt_upstreams_create()
50 upstreams->items = n; in nxt_upstreams_create()
68 tmcf->router_conf->upstreams = upstreams; in nxt_upstreams_create()
81 if (upstreams == NULL) { in nxt_upstream_find()
86 n = upstreams->items; in nxt_upstream_find()
107 nxt_upstreams_t *upstreams; in nxt_upstreams_joint_create() local
111 upstreams = router_conf->upstreams; in nxt_upstreams_joint_create()
113 if (upstreams == NULL) { in nxt_upstreams_joint_create()
118 n = upstreams->items; in nxt_upstreams_joint_create()
[all …]
|
| /dports/www/unit/unit-1.26.1/src/ |
| H A D | nxt_upstream.c | 25 nxt_upstreams_t *upstreams; in nxt_upstreams_create() local
45 upstreams = nxt_mp_zalloc(mp, size); in nxt_upstreams_create()
50 upstreams->items = n; in nxt_upstreams_create()
68 tmcf->router_conf->upstreams = upstreams; in nxt_upstreams_create()
81 if (upstreams == NULL) { in nxt_upstream_find()
86 n = upstreams->items; in nxt_upstream_find()
107 nxt_upstreams_t *upstreams; in nxt_upstreams_joint_create() local
111 upstreams = router_conf->upstreams; in nxt_upstreams_joint_create()
113 if (upstreams == NULL) { in nxt_upstreams_joint_create()
118 n = upstreams->items; in nxt_upstreams_joint_create()
[all …]
|
| /dports/www/unit-java/unit-1.26.1/src/ |
| H A D | nxt_upstream.c | 25 nxt_upstreams_t *upstreams; in nxt_upstreams_create() local
45 upstreams = nxt_mp_zalloc(mp, size); in nxt_upstreams_create()
50 upstreams->items = n; in nxt_upstreams_create()
68 tmcf->router_conf->upstreams = upstreams; in nxt_upstreams_create()
81 if (upstreams == NULL) { in nxt_upstream_find()
86 n = upstreams->items; in nxt_upstream_find()
107 nxt_upstreams_t *upstreams; in nxt_upstreams_joint_create() local
111 upstreams = router_conf->upstreams; in nxt_upstreams_joint_create()
113 if (upstreams == NULL) { in nxt_upstreams_joint_create()
118 n = upstreams->items; in nxt_upstreams_joint_create()
[all …]
|
| /dports/www/unit-perl/unit-1.26.1/src/ |
| H A D | nxt_upstream.c | 25 nxt_upstreams_t *upstreams; in nxt_upstreams_create() local
45 upstreams = nxt_mp_zalloc(mp, size); in nxt_upstreams_create()
50 upstreams->items = n; in nxt_upstreams_create()
68 tmcf->router_conf->upstreams = upstreams; in nxt_upstreams_create()
81 if (upstreams == NULL) { in nxt_upstream_find()
86 n = upstreams->items; in nxt_upstream_find()
107 nxt_upstreams_t *upstreams; in nxt_upstreams_joint_create() local
111 upstreams = router_conf->upstreams; in nxt_upstreams_joint_create()
113 if (upstreams == NULL) { in nxt_upstreams_joint_create()
118 n = upstreams->items; in nxt_upstreams_joint_create()
[all …]
|
| /dports/www/unit-php/unit-1.26.1/src/ |
| H A D | nxt_upstream.c | 25 nxt_upstreams_t *upstreams; in nxt_upstreams_create() local
45 upstreams = nxt_mp_zalloc(mp, size); in nxt_upstreams_create()
50 upstreams->items = n; in nxt_upstreams_create()
68 tmcf->router_conf->upstreams = upstreams; in nxt_upstreams_create()
81 if (upstreams == NULL) { in nxt_upstream_find()
86 n = upstreams->items; in nxt_upstream_find()
107 nxt_upstreams_t *upstreams; in nxt_upstreams_joint_create() local
111 upstreams = router_conf->upstreams; in nxt_upstreams_joint_create()
113 if (upstreams == NULL) { in nxt_upstreams_joint_create()
118 n = upstreams->items; in nxt_upstreams_joint_create()
[all …]
|
| /dports/www/unit-python/unit-1.26.1/src/ |
| H A D | nxt_upstream.c | 25 nxt_upstreams_t *upstreams; in nxt_upstreams_create() local
45 upstreams = nxt_mp_zalloc(mp, size); in nxt_upstreams_create()
50 upstreams->items = n; in nxt_upstreams_create()
68 tmcf->router_conf->upstreams = upstreams; in nxt_upstreams_create()
81 if (upstreams == NULL) { in nxt_upstream_find()
86 n = upstreams->items; in nxt_upstream_find()
107 nxt_upstreams_t *upstreams; in nxt_upstreams_joint_create() local
111 upstreams = router_conf->upstreams; in nxt_upstreams_joint_create()
113 if (upstreams == NULL) { in nxt_upstreams_joint_create()
118 n = upstreams->items; in nxt_upstreams_joint_create()
[all …]
|
| /dports/net/rclone/rclone-1.57.0/backend/union/ |
| H A D | union.go | 156 upstreams, err = f.upstreams, nil
340 su := upstreams[i]
451 if len(upstreams) == 1 {
452 u := upstreams[0]
471 u := upstreams[i]
593 u := f.upstreams[i]
641 u := f.upstreams[i]
688 u := f.upstreams[i]
777 u := f.upstreams[i]
834 usedUpstreams = upstreams
[all …]
|
| H A D | union_test.go | 32 upstreams := dirs[0] + " " + dirs[1] + " " + dirs[2]
38 {Name: name, Key: "upstreams", Value: upstreams},
54 upstreams := dirs[0] + " " + dirs[1] + ":ro " + dirs[2] + ":ro"
60 {Name: name, Key: "upstreams", Value: upstreams},
82 {Name: name, Key: "upstreams", Value: upstreams},
98 upstreams := dirs[0] + " " + dirs[1] + " " + dirs[2]
104 {Name: name, Key: "upstreams", Value: upstreams},
120 upstreams := dirs[0] + " " + dirs[1] + " " + dirs[2]
126 {Name: name, Key: "upstreams", Value: upstreams},
142 upstreams := dirs[0] + " " + dirs[1] + " " + dirs[2]
[all …]
|
| /dports/www/oauth2-proxy/oauth2-proxy-7.2.0/pkg/validation/ |
| H A D | upstreams_test.go | 14 upstreams options.UpstreamConfig
61 upstreams: options.UpstreamConfig{
71 upstreams: options.UpstreamConfig{
83 upstreams: options.UpstreamConfig{
95 upstreams: options.UpstreamConfig{
107 upstreams: options.UpstreamConfig{
119 upstreams: options.UpstreamConfig{
131 upstreams: options.UpstreamConfig{
143 upstreams: options.UpstreamConfig{
166 upstreams: options.UpstreamConfig{
[all …]
|
| /dports/dns/getdns/getdns-1.5.2/src/ |
| H A D | stub.c | 1889 return &upstreams->upstreams[i]; in upstream_select_stateful()
1902 upstream = &upstreams->upstreams[i]; in upstream_select_stateful()
1925 upstream = &upstreams->upstreams[i]; in upstream_select_stateful()
1943 upstream = &upstreams->upstreams[i]; in upstream_select_stateful()
1961 upstream = &upstreams->upstreams[i]; in upstream_select_stateful()
1989 upstreams->upstreams[i].to_retry++; in upstream_select()
1995 return &upstreams->upstreams[i]; in upstream_select()
2003 upstream = upstreams->upstreams; in upstream_select()
2006 upstream = &upstreams->upstreams[i]; in upstream_select()
2012 upstreams->upstreams[i].back_off = 2; in upstream_select()
[all …]
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/website/source/docs/job-specification/ |
| H A D | upstreams.html.md | 3 page_title: "upstreams Stanza - Job Specification"
4 sidebar_current: "docs-job-specification-upstreams"
6 The "upstreams" stanza allows specifying options for configuring
10 # `upstreams` Stanza
16 <code>job -> group -> service -> connect -> sidecar_service -> proxy -> **upstreams** </code>
21 The `upstreams` stanza allows configuring various options for managing upstream
50 upstreams {
75 ## `upstreams` Parameters
89 ## `upstreams` Examples
95 upstreams {
[all …]
|