| /dports/net-mgmt/thanos/thanos-0.11.0/vendor/go.mongodb.org/mongo-driver/mongo/options/ |
| H A D | clientoptions_test.go | 168 baseClient := func() *ClientOptions {
228 baseClient().SetAuth(Credential{
248 baseClient().SetAuth(Credential{
256 baseClient().SetDirect(true),
261 baseClient().SetConnectTimeout(5 * time.Second),
296 baseClient().SetMaxPoolSize(256),
321 baseClient().SetRetryWrites(true),
326 baseClient().SetReplicaSet("rs01"),
336 baseClient().SetSocketTimeout(15 * time.Second),
361 baseClient().SetAuth(Credential{
[all …]
|
| /dports/net-mgmt/semaphore/semaphore-2.6.8/vendor/go.mongodb.org/mongo-driver/mongo/options/ |
| H A D | clientoptions_test.go | 172 baseClient := func() *ClientOptions {
232 baseClient().SetAuth(Credential{
259 baseClient().SetAuth(Credential{
267 baseClient().SetDirect(true),
272 baseClient().SetConnectTimeout(5 * time.Second),
282 baseClient(),
312 baseClient().SetMaxPoolSize(256),
337 baseClient().SetRetryWrites(true),
342 baseClient().SetReplicaSet("rs01"),
377 baseClient().SetAuth(Credential{
[all …]
|
| /dports/security/vault/vault-1.8.2/vendor/go.mongodb.org/mongo-driver/mongo/options/ |
| H A D | clientoptions_test.go | 179 baseClient := func() *ClientOptions {
239 baseClient().SetAuth(Credential{
267 baseClient().SetAuth(Credential{
275 baseClient().SetAuth(Credential{
283 baseClient().SetDirect(true),
298 baseClient(),
328 baseClient().SetMaxPoolSize(256),
353 baseClient().SetRetryWrites(true),
395 baseClient().SetAuth(Credential{
423 baseClient().SetZlibLevel(4),
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/go.mongodb.org/mongo-driver/mongo/options/ |
| H A D | clientoptions_test.go | 179 baseClient := func() *ClientOptions {
239 baseClient().SetAuth(Credential{
267 baseClient().SetAuth(Credential{
275 baseClient().SetAuth(Credential{
283 baseClient().SetDirect(true),
298 baseClient(),
328 baseClient().SetMaxPoolSize(256),
353 baseClient().SetRetryWrites(true),
395 baseClient().SetAuth(Credential{
423 baseClient().SetZlibLevel(4),
[all …]
|
| /dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/go.mongodb.org/mongo-driver/mongo/options/ |
| H A D | clientoptions_test.go | 179 baseClient := func() *ClientOptions {
239 baseClient().SetAuth(Credential{
267 baseClient().SetAuth(Credential{
275 baseClient().SetAuth(Credential{
283 baseClient().SetDirect(true),
298 baseClient(),
328 baseClient().SetMaxPoolSize(256),
353 baseClient().SetRetryWrites(true),
395 baseClient().SetAuth(Credential{
423 baseClient().SetZlibLevel(4),
[all …]
|
| /dports/sysutils/istio/istio-1.6.7/vendor/github.com/go-redis/redis/ |
| H A D | redis.go | 26 type baseClient struct { struct
37 func (c *baseClient) init() { argument
43 func (c *baseClient) String() string { argument
188 func (c *baseClient) Close() error { argument
201 func (c *baseClient) getAddr() string { argument
339 baseClient anonMember
350 baseClient: baseClient{
355 c.baseClient.init()
460 baseClient anonMember
466 baseClient: baseClient{
[all …]
|
| /dports/multimedia/livego/livego-0.0.15/vendor/github.com/go-redis/redis/v7/ |
| H A D | redis.go | 140 type baseClient struct { struct
148 return &baseClient{
154 func (c *baseClient) clone() *baseClient { argument
159 func (c *baseClient) withTimeout(timeout time.Duration) *baseClient { argument
170 func (c *baseClient) String() string { argument
279 func (c *baseClient) withConn( argument
355 func (c *baseClient) Close() error { argument
519 *baseClient anonMember
547 clone.baseClient = c.baseClient.withTimeout(timeout)
695 baseClient anonMember
[all …]
|
| H A D | tx.go | 18 baseClient anonMember
27 baseClient: baseClient{
63 return c.hooks.process(ctx, cmd, c.baseClient.process)
91 return c.baseClient.Close()
124 return c.hooks.processPipeline(ctx, cmds, c.baseClient.processPipeline)
154 return c.hooks.processTxPipeline(ctx, cmds, c.baseClient.processTxPipeline)
|
| /dports/www/pomerium/pomerium-0.8.3/vendor/github.com/go-redis/redis/v7/ |
| H A D | redis.go | 140 type baseClient struct { struct
148 return &baseClient{
154 func (c *baseClient) clone() *baseClient { argument
159 func (c *baseClient) withTimeout(timeout time.Duration) *baseClient { argument
170 func (c *baseClient) String() string { argument
279 func (c *baseClient) withConn( argument
355 func (c *baseClient) Close() error { argument
519 *baseClient anonMember
547 clone.baseClient = c.baseClient.withTimeout(timeout)
695 baseClient anonMember
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/go-redis/redis/v8/ |
| H A D | redis.go | 137 type baseClient struct { struct
145 return &baseClient{
151 func (c *baseClient) clone() *baseClient { argument
156 func (c *baseClient) withTimeout(timeout time.Duration) *baseClient { argument
167 func (c *baseClient) String() string { argument
283 func (c *baseClient) withConn( argument
386 func (c *baseClient) Close() error { argument
551 *baseClient anonMember
579 clone.baseClient = c.baseClient.withTimeout(timeout)
719 baseClient anonMember
[all …]
|
| H A D | tx.go | 18 baseClient anonMember
27 baseClient: baseClient{
59 return c.hooks.process(ctx, cmd, c.baseClient.process)
80 return c.baseClient.Close()
113 return c.hooks.processPipeline(ctx, cmds, c.baseClient.processPipeline)
143 return c.hooks.processTxPipeline(ctx, cmds, c.baseClient.processTxPipeline)
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/vendor/github.com/go-redis/redis/v8/ |
| H A D | redis.go | 125 type baseClient struct { struct
133 return &baseClient{
139 func (c *baseClient) clone() *baseClient { argument
144 func (c *baseClient) withTimeout(timeout time.Duration) *baseClient { argument
155 func (c *baseClient) String() string { argument
271 func (c *baseClient) withConn( argument
374 func (c *baseClient) Close() error { argument
539 *baseClient anonMember
567 clone.baseClient = c.baseClient.withTimeout(timeout)
707 baseClient anonMember
[all …]
|
| H A D | tx.go | 19 baseClient anonMember
28 baseClient: baseClient{
60 return c.hooks.process(ctx, cmd, c.baseClient.process)
81 return c.baseClient.Close()
114 return c.hooks.processPipeline(ctx, cmds, c.baseClient.processPipeline)
144 return c.hooks.processTxPipeline(ctx, cmds, c.baseClient.processTxPipeline)
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/go-redis/redis/v8/ |
| H A D | redis.go | 125 type baseClient struct { struct
133 return &baseClient{
139 func (c *baseClient) clone() *baseClient { argument
144 func (c *baseClient) withTimeout(timeout time.Duration) *baseClient { argument
155 func (c *baseClient) String() string { argument
271 func (c *baseClient) withConn( argument
374 func (c *baseClient) Close() error { argument
539 *baseClient anonMember
567 clone.baseClient = c.baseClient.withTimeout(timeout)
707 baseClient anonMember
[all …]
|
| /dports/games/automuteus/automuteus-6.15.2/vendor/github.com/go-redis/redis/v8/ |
| H A D | redis.go | 138 type baseClient struct { struct
146 return &baseClient{
152 func (c *baseClient) clone() *baseClient { argument
157 func (c *baseClient) withTimeout(timeout time.Duration) *baseClient { argument
168 func (c *baseClient) String() string { argument
287 func (c *baseClient) withConn( argument
399 func (c *baseClient) Close() error { argument
564 *baseClient anonMember
592 clone.baseClient = c.baseClient.withTimeout(timeout)
732 baseClient anonMember
[all …]
|
| H A D | tx.go | 18 baseClient anonMember
27 baseClient: baseClient{
59 return c.hooks.process(ctx, cmd, c.baseClient.process)
80 return c.baseClient.Close()
113 return c.hooks.processPipeline(ctx, cmds, c.baseClient.processPipeline)
143 return c.hooks.processTxPipeline(ctx, cmds, c.baseClient.processTxPipeline)
|
| /dports/www/gitea/gitea-1.16.5/vendor/github.com/go-redis/redis/v8/ |
| H A D | redis.go | 137 type baseClient struct { struct
145 return &baseClient{
151 func (c *baseClient) clone() *baseClient { argument
156 func (c *baseClient) withTimeout(timeout time.Duration) *baseClient { argument
167 func (c *baseClient) String() string { argument
283 func (c *baseClient) withConn( argument
386 func (c *baseClient) Close() error { argument
551 *baseClient anonMember
579 clone.baseClient = c.baseClient.withTimeout(timeout)
719 baseClient anonMember
[all …]
|
| /dports/www/mattermost-server/mattermost-server-6.0.2/vendor/github.com/go-redis/redis/v8/ |
| H A D | redis.go | 137 type baseClient struct { struct
145 return &baseClient{
151 func (c *baseClient) clone() *baseClient { argument
156 func (c *baseClient) withTimeout(timeout time.Duration) *baseClient { argument
167 func (c *baseClient) String() string { argument
283 func (c *baseClient) withConn( argument
386 func (c *baseClient) Close() error { argument
551 *baseClient anonMember
579 clone.baseClient = c.baseClient.withTimeout(timeout)
719 baseClient anonMember
[all …]
|
| /dports/security/vuls/vuls-0.13.7/vendor/github.com/go-redis/redis/v8/ |
| H A D | redis.go | 151 type baseClient struct { struct
159 return &baseClient{
165 func (c *baseClient) clone() *baseClient { argument
170 func (c *baseClient) withTimeout(timeout time.Duration) *baseClient { argument
181 func (c *baseClient) String() string { argument
300 func (c *baseClient) withConn( argument
387 func (c *baseClient) Close() error { argument
552 *baseClient anonMember
580 clone.baseClient = c.baseClient.withTimeout(timeout)
720 baseClient anonMember
[all …]
|
| /dports/net/storj/storj-1.45.3/vendor/github.com/go-redis/redis/v8/ |
| H A D | redis.go | 139 type baseClient struct { struct
147 return &baseClient{
153 func (c *baseClient) clone() *baseClient { argument
158 func (c *baseClient) withTimeout(timeout time.Duration) *baseClient { argument
169 func (c *baseClient) String() string { argument
288 func (c *baseClient) withConn( argument
395 func (c *baseClient) Close() error { argument
560 *baseClient anonMember
588 clone.baseClient = c.baseClient.withTimeout(timeout)
728 baseClient anonMember
[all …]
|
| H A D | tx.go | 18 baseClient anonMember
27 baseClient: baseClient{
59 return c.hooks.process(ctx, cmd, c.baseClient.process)
80 return c.baseClient.Close()
113 return c.hooks.processPipeline(ctx, cmds, c.baseClient.processPipeline)
143 return c.hooks.processTxPipeline(ctx, cmds, c.baseClient.processTxPipeline)
|
| /dports/security/go-cve-dictionary/go-cve-dictionary-0.5.5/vendor/github.com/go-redis/redis/v8/ |
| H A D | redis.go | 151 type baseClient struct { struct
159 return &baseClient{
165 func (c *baseClient) clone() *baseClient { argument
170 func (c *baseClient) withTimeout(timeout time.Duration) *baseClient { argument
181 func (c *baseClient) String() string { argument
300 func (c *baseClient) withConn( argument
387 func (c *baseClient) Close() error { argument
552 *baseClient anonMember
580 clone.baseClient = c.baseClient.withTimeout(timeout)
720 baseClient anonMember
[all …]
|
| /dports/www/oauth2-proxy/oauth2-proxy-7.2.0/vendor/github.com/go-redis/redis/v8/ |
| H A D | redis.go | 150 type baseClient struct { struct
158 return &baseClient{
164 func (c *baseClient) clone() *baseClient { argument
169 func (c *baseClient) withTimeout(timeout time.Duration) *baseClient { argument
180 func (c *baseClient) String() string { argument
299 func (c *baseClient) withConn( argument
386 func (c *baseClient) Close() error { argument
551 *baseClient anonMember
579 clone.baseClient = c.baseClient.withTimeout(timeout)
719 baseClient anonMember
[all …]
|
| /dports/net/traefik/traefik-2.6.1/vendor/gopkg.in/redis.v5/ |
| H A D | redis.go | 20 func (c *baseClient) String() string {
24 func (c *baseClient) conn() (*pool.Conn, bool, error) {
48 func (c *baseClient) initConn(cn *pool.Conn) error {
75 func (c *baseClient) Process(cmd Cmder) error {
90 func (c *baseClient) defaultProcess(cmd Cmder) error {
121 func (c *baseClient) cmdTimeout(cmd Cmder) time.Duration {
133 func (c *baseClient) Close() error {
146 func (c *baseClient) getAddr() string {
279 baseClient anonMember
285 baseClient: baseClient{
[all …]
|
| /dports/security/lego/lego-4.5.3/vendor/github.com/oracle/oci-go-sdk/functions/ |
| H A D | functions_functionsinvoke_client.go | 28 baseClient, err := common.NewClientWithConfig(configProvider)
33 return newFunctionsInvokeClientFromBaseClient(baseClient, configProvider, endpoint)
40 baseClient, err := common.NewClientWithOboToken(configProvider, oboToken)
45 return newFunctionsInvokeClientFromBaseClient(baseClient, configProvider, endpoint)
48 func newFunctionsInvokeClientFromBaseClient(baseClient common.BaseClient, configProvider common.Con…
49 client = FunctionsInvokeClient{BaseClient: baseClient}
|