| /dports/security/vault/vault-1.8.2/vendor/github.com/aerospike/aerospike-client-go/ |
| H A D | node_test.go | 60 clientPolicy := as.NewClientPolicy()
62 clientPolicy.ConnectionQueueSize = 4
63 clientPolicy.User = *user
64 clientPolicy.Password = *password
91 clientPolicy.User = *user
92 clientPolicy.Password = *password
137 clientPolicy.User = *user
138 clientPolicy.Password = *password
228 clientPolicy.User = *user
229 clientPolicy.Password = *password
[all …]
|
| H A D | node_validator.go | 148 clientPolicy := cluster.clientPolicy
149 clientPolicy.Timeout /= 2
151 conn, err := NewConnection(&clientPolicy, alias)
157 if clientPolicy.RequiresAuthentication() {
160 err = acmd.login(&clientPolicy, conn, cluster.Password())
178 hasClusterName := len(clientPolicy.ClusterName) > 0
185 addressCommand := clientPolicy.serviceString()
217 if len(id) == 0 || id != clientPolicy.ClusterName {
256 hconn, err := NewConnection(&clientPolicy, h)
262 if clientPolicy.RequiresAuthentication() {
[all …]
|
| H A D | aerospike_suite_test.go | 44 clientPolicy *as.ClientPolicy var
58 clientPolicy = as.NewClientPolicy()
60 clientPolicy.User = *user
61 clientPolicy.Password = *password
70 clientPolicy.AuthMode = as.AuthModeExternal
73 client, err = as.NewClientWithPolicy(clientPolicy, *host, *port)
|
| H A D | node.go | 82 …connections: *newConnectionHeap(cluster.clientPolicy.MinConnectionsPerNode, cluster.client…
130 if nd.cluster.clientPolicy.RackAware {
156 if nd.cluster.clientPolicy.RackAware {
211 …if !nd.cluster.clientPolicy.RequiresAuthentication() || nd.cluster.clientPolicy.AuthMode != AuthMo…
246 if !nd.cluster.clientPolicy.RackAware {
378 if len(nd.cluster.clientPolicy.IpMap) > 0 {
539 …if nd.cluster.clientPolicy.LimitConnectionsToQueueSize && cc > nd.cluster.clientPolicy.ConnectionQ…
549 if ct > nd.cluster.clientPolicy.OpeningConnectionThreshold {
560 conn, err := NewConnection(&nd.cluster.clientPolicy, nd.host)
578 conn.setIdleTimeout(nd.cluster.clientPolicy.IdleTimeout)
[all …]
|
| H A D | cluster.go | 56 clientPolicy ClientPolicy member
104 clientPolicy: *policy,
151 go newCluster.clusterBoss(&newCluster.clientPolicy)
175 go clstr.clusterBoss(&clstr.clientPolicy)
201 if tendDuration := time.Since(tm); tendDuration > clstr.clientPolicy.TendInterval {
509 case <-time.After(clstr.clientPolicy.Timeout):
510 if clstr.clientPolicy.FailIfNotConnected {
515 if err != nil && clstr.clientPolicy.FailIfNotConnected {
611 case <-time.After(clstr.clientPolicy.Timeout):
980 clstr.clientPolicy.Password = password
[all …]
|
| H A D | aerospike_bench_test.go | 64 client, err := NewClientWithPolicy(clientPolicy, *host, *port)
99 client, err := NewClientWithPolicy(clientPolicy, *host, *port)
|
| H A D | query_validate.go | 31 result, err := node.requestInfo(node.cluster.clientPolicy.Timeout, cmd)
|
| H A D | client_test.go | 43 client, err := as.NewClientWithPolicy(clientPolicy, *host, *port)
76 cpolicy := *clientPolicy
89 cpolicy := *clientPolicy
106 cpolicy := *clientPolicy
122 cpolicy := *clientPolicy
135 cpolicy := *clientPolicy
147 cpolicy = *clientPolicy
|
| H A D | aerospike_bench_reflect_test.go | 44 client, err := NewClientWithPolicy(clientPolicy, *host, *port)
|
| H A D | peers_parser.go | 29 cmd := cluster.clientPolicy.peersString()
|
| H A D | partition.go | 215 if node.hasRack(ptn.Namespace, cluster.clientPolicy.RackId) {
|
| H A D | security_test.go | 41 client, err = as.NewClientWithPolicy(clientPolicy, *host, *port)
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/aerospike/aerospike-client-go/tools/asinfo/ |
| H A D | asinfo.go | 34 clientPolicy *as.ClientPolicy var
42 clientPolicy = as.NewClientPolicy()
44 clientPolicy.User = *user
45 clientPolicy.Password = *password
50 client, err := as.NewClientWithPolicy(clientPolicy, *host, *port)
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/aerospike/aerospike-client-go/examples/ |
| H A D | tls_secure_connection.go | 61 clientPolicy := as.NewClientPolicy()
73 clientPolicy.TlsConfig = tlsConfig
76 client, err := as.NewClientWithPolicy(clientPolicy, *Host, *Port)
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/aerospike/aerospike-client-go/tools/benchmark/ |
| H A D | benchmark.go | 135 clientPolicy := as.NewClientPolicy()
137 clientPolicy.AuthMode = as.AuthModeExternal
140 clientPolicy.ConnectionQueueSize = *connQueueSize
141 clientPolicy.User = *user
142 clientPolicy.Password = *password
143 clientPolicy.Timeout = 10 * time.Second
144 clientPolicy.OpeningConnectionThreshold = *openingConnectionThreshold
145 client, err := as.NewClientWithPolicy(clientPolicy, *host, *port)
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/aerospike/aerospike-client-go/docs/ |
| H A D | client.md | 14 clientPolicy := as.NewClientPolicy()
15 clientPolicy.ConnectionQueueSize = 64
16 clientPolicy.LimitConnectionsToQueueSize = true
17 clientPolicy.Timeout = 50 * time.Millisecond
19 client, err := as.NewClientWithPolicy(clientPolicy, "127.0.0.1", 3000)
|
| /dports/net/keycloak/keycloak-15.1.1/themes/keycloak.v2/admin/resources/ |
| H A D | index.js.map | 4 …clientPolicy) => {\n return /* @__PURE__ */ React.createElement(Controller, {\n name: clie…
|