Home
last modified time | relevance | path

Searched refs:pipelineProcessor (Results 1 – 15 of 15) sorted by relevance

/dports/www/grafana8/grafana-8.3.6/vendor/go.opentelemetry.io/collector/service/internal/builder/
H A Dreceivers_builder.go145 pipelineProcessor := rb.builtPipelines[pipelineCfg]
146 if pipelineProcessor == nil {
159 append(pipelinesToAttach[pipelineCfg.InputType], pipelineProcessor)
/dports/net/traefik/traefik-2.6.1/vendor/gopkg.in/redis.v5/
H A Dredis.go150 type pipelineProcessor func(*pool.Conn, []Cmder) (bool, error) type
152 func (c *baseClient) pipelineExecer(p pipelineProcessor) pipelineExecer { argument
/dports/multimedia/livego/livego-0.0.15/vendor/github.com/go-redis/redis/v7/
H A Dredis.go380 type pipelineProcessor func(context.Context, *pool.Conn, []Cmder) (bool, error) type
383 ctx context.Context, cmds []Cmder, p pipelineProcessor,
394 ctx context.Context, cmds []Cmder, p pipelineProcessor,
/dports/www/pomerium/pomerium-0.8.3/vendor/github.com/go-redis/redis/v7/
H A Dredis.go380 type pipelineProcessor func(context.Context, *pool.Conn, []Cmder) (bool, error) type
383 ctx context.Context, cmds []Cmder, p pipelineProcessor,
394 ctx context.Context, cmds []Cmder, p pipelineProcessor,
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/go-redis/redis/
H A Dredis.go220 type pipelineProcessor func(*pool.Conn, []Cmder) (bool, error) type
222 func (c *baseClient) generalProcessPipeline(cmds []Cmder, p pipelineProcessor) error {
/dports/security/vuls/vuls-0.13.7/vendor/github.com/go-redis/redis/v8/
H A Dredis.go412 type pipelineProcessor func(context.Context, *pool.Conn, []Cmder) (bool, error) type
415 ctx context.Context, cmds []Cmder, p pipelineProcessor,
426 ctx context.Context, cmds []Cmder, p pipelineProcessor,
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/go-redis/redis/v8/
H A Dredis.go411 type pipelineProcessor func(context.Context, *pool.Conn, []Cmder) (bool, error) type
414 ctx context.Context, cmds []Cmder, p pipelineProcessor,
425 ctx context.Context, cmds []Cmder, p pipelineProcessor,
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/vendor/github.com/go-redis/redis/v8/
H A Dredis.go399 type pipelineProcessor func(context.Context, *pool.Conn, []Cmder) (bool, error) type
402 ctx context.Context, cmds []Cmder, p pipelineProcessor,
413 ctx context.Context, cmds []Cmder, p pipelineProcessor,
/dports/net/storj/storj-1.45.3/vendor/github.com/go-redis/redis/v8/
H A Dredis.go420 type pipelineProcessor func(context.Context, *pool.Conn, []Cmder) (bool, error) type
423 ctx context.Context, cmds []Cmder, p pipelineProcessor,
434 ctx context.Context, cmds []Cmder, p pipelineProcessor,
/dports/security/go-cve-dictionary/go-cve-dictionary-0.5.5/vendor/github.com/go-redis/redis/v8/
H A Dredis.go412 type pipelineProcessor func(context.Context, *pool.Conn, []Cmder) (bool, error) type
415 ctx context.Context, cmds []Cmder, p pipelineProcessor,
426 ctx context.Context, cmds []Cmder, p pipelineProcessor,
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/go-redis/redis/v8/
H A Dredis.go399 type pipelineProcessor func(context.Context, *pool.Conn, []Cmder) (bool, error) type
402 ctx context.Context, cmds []Cmder, p pipelineProcessor,
413 ctx context.Context, cmds []Cmder, p pipelineProcessor,
/dports/www/oauth2-proxy/oauth2-proxy-7.2.0/vendor/github.com/go-redis/redis/v8/
H A Dredis.go411 type pipelineProcessor func(context.Context, *pool.Conn, []Cmder) (bool, error) type
414 ctx context.Context, cmds []Cmder, p pipelineProcessor,
425 ctx context.Context, cmds []Cmder, p pipelineProcessor,
/dports/games/automuteus/automuteus-6.15.2/vendor/github.com/go-redis/redis/v8/
H A Dredis.go424 type pipelineProcessor func(context.Context, *pool.Conn, []Cmder) (bool, error) type
427 ctx context.Context, cmds []Cmder, p pipelineProcessor,
438 ctx context.Context, cmds []Cmder, p pipelineProcessor,
/dports/www/gitea/gitea-1.16.5/vendor/github.com/go-redis/redis/v8/
H A Dredis.go411 type pipelineProcessor func(context.Context, *pool.Conn, []Cmder) (bool, error) type
414 ctx context.Context, cmds []Cmder, p pipelineProcessor,
425 ctx context.Context, cmds []Cmder, p pipelineProcessor,
/dports/www/mattermost-server/mattermost-server-6.0.2/vendor/github.com/go-redis/redis/v8/
H A Dredis.go411 type pipelineProcessor func(context.Context, *pool.Conn, []Cmder) (bool, error) type
414 ctx context.Context, cmds []Cmder, p pipelineProcessor,
425 ctx context.Context, cmds []Cmder, p pipelineProcessor,