/dports/sysutils/sensu-go/sensu-go-5.11.1/backend/pipelined/ |
H A D | pipelined.go | 24 type Pipelined struct { struct 50 type Option func(*Pipelined) error 53 func New(c Config, options ...Option) (*Pipelined, error) { 61 p := &Pipelined{ 83 func (p *Pipelined) Receiver() chan<- interface{} { argument 89 func (p *Pipelined) Start() error { argument 102 func (p *Pipelined) Stop() error { argument 114 func (p *Pipelined) Err() <-chan error { argument 119 func (p *Pipelined) Name() string { argument 126 func (p *Pipelined) createPipelines(count int, channel chan interface{}) { argument
|
H A D | mutate.go | 21 func (p *Pipelined) mutateEvent(handler *types.Handler, event *types.Event) ([]byte, error) { 90 func (p *Pipelined) jsonMutator(event *types.Event) ([]byte, error) { 105 func (p *Pipelined) onlyCheckOutputMutator(event *types.Event) []byte { 116 func (p *Pipelined) pipeMutator(mutator *types.Mutator, event *types.Event) ([]byte, error) {
|
H A D | handle_test.go | 67 p := &Pipelined{} 196 p := &Pipelined{store: store} 206 p := &Pipelined{} 226 p := &Pipelined{} 282 p := &Pipelined{} 337 p := &Pipelined{
|
H A D | handle.go | 36 func (p *Pipelined) handleEvent(event *types.Event) error { 106 func (p *Pipelined) expandHandlers(ctx context.Context, handlers []string, level int) (map[string]h… 186 func (p *Pipelined) pipeHandler(handler *types.Handler, eventData []byte) (*command.ExecutionRespon… 233 func (p *Pipelined) socketHandler(handler *types.Handler, eventData []byte) (conn net.Conn, err err… 279 func (p *Pipelined) grpcHandler(ext *types.Extension, evt *types.Event, mutated []byte) (rpc.Handle…
|
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/go-redis/redis/ |
H A D | tx_test.go | 36 _, err = tx.Pipelined(func(pipe redis.Pipeliner) error { 68 cmds, err := tx.Pipelined(func(pipe redis.Pipeliner) error { 91 _, err := tx.Pipelined(func(redis.Pipeliner) error { return nil }) 105 cmds, err := tx.Pipelined(func(pipe redis.Pipeliner) error { 136 _, err := tx.Pipelined(func(pipe redis.Pipeliner) error {
|
H A D | tx.go | 94 func (c *Tx) Pipelined(fn func(Pipeliner) error) ([]Cmder, error) { func 95 return c.Pipeline().Pipelined(fn) 99 return c.Pipelined(fn)
|
H A D | redis.go | 100 _, err := conn.Pipelined(func(pipe Pipeliner) error { 400 func (c *Client) Pipelined(fn func(Pipeliner) error) ([]Cmder, error) { func 401 return c.Pipeline().Pipelined(fn) 413 return c.TxPipeline().Pipelined(fn) 476 func (c *Conn) Pipelined(fn func(Pipeliner) error) ([]Cmder, error) { func 477 return c.Pipeline().Pipelined(fn) 489 return c.TxPipeline().Pipelined(fn)
|
/dports/security/sequoia/sequoia-383133f6be990237044900a4df676488bf8dd71e/cargo-crates/capnp-0.10.3/src/ |
H A D | capability.rs | 27 use crate::traits::{Pipelined, Owned}; 112 pub struct RemotePromise<Results> where Results: Pipelined + for<'a> Owned<'a> + 'static { 124 where Results: Pipelined + for<'a> Owned<'a> 158 where Results: Pipelined + for<'a> Owned<'a> + 'static, 159 <Results as Pipelined>::Pipeline: FromTypelessPipeline
|
/dports/sysutils/flowgger/flowgger-0.2.10/cargo-crates/capnp-0.10.3/src/ |
H A D | capability.rs | 27 use crate::traits::{Pipelined, Owned}; 112 pub struct RemotePromise<Results> where Results: Pipelined + for<'a> Owned<'a> + 'static { 124 where Results: Pipelined + for<'a> Owned<'a> 158 where Results: Pipelined + for<'a> Owned<'a> + 'static, 159 <Results as Pipelined>::Pipeline: FromTypelessPipeline
|
/dports/lang/gleam/gleam-0.18.2/cargo-crates/capnp-0.14.4/src/ |
H A D | capability.rs | 35 use crate::traits::{Pipelined, Owned}; 107 pub struct RemotePromise<Results> where Results: Pipelined + for<'a> Owned<'a> + 'static { 119 where Results: Pipelined + for<'a> Owned<'a> 152 where Results: Pipelined + for<'a> Owned<'a> + 'static + Unpin, 153 <Results as Pipelined>::Pipeline: FromTypelessPipeline
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/go-redis/redis/v8/ |
H A D | tx.go | 122 func (c *Tx) Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) { func 123 return c.Pipeline().Pipelined(ctx, fn) 135 return c.TxPipeline().Pipelined(ctx, fn)
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/vendor/github.com/go-redis/redis/v8/ |
H A D | tx.go | 123 func (c *Tx) Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) { func 124 return c.Pipeline().Pipelined(ctx, fn) 136 return c.TxPipeline().Pipelined(ctx, fn)
|
/dports/net/storj/storj-1.45.3/vendor/github.com/go-redis/redis/v8/ |
H A D | tx.go | 122 func (c *Tx) Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) { func 123 return c.Pipeline().Pipelined(ctx, fn) 135 return c.TxPipeline().Pipelined(ctx, fn)
|
/dports/multimedia/livego/livego-0.0.15/vendor/github.com/go-redis/redis/v7/ |
H A D | tx.go | 133 func (c *Tx) Pipelined(fn func(Pipeliner) error) ([]Cmder, error) { func 134 return c.Pipeline().Pipelined(fn) 146 return c.TxPipeline().Pipelined(fn)
|
/dports/games/automuteus/automuteus-6.15.2/vendor/github.com/go-redis/redis/v8/ |
H A D | tx.go | 122 func (c *Tx) Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) { func 123 return c.Pipeline().Pipelined(ctx, fn) 135 return c.TxPipeline().Pipelined(ctx, fn)
|
/dports/security/vuls/vuls-0.13.7/vendor/github.com/go-redis/redis/v8/ |
H A D | tx.go | 125 func (c *Tx) Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) { func 126 return c.Pipeline().Pipelined(ctx, fn) 138 return c.TxPipeline().Pipelined(ctx, fn)
|
/dports/security/go-cve-dictionary/go-cve-dictionary-0.5.5/vendor/github.com/go-redis/redis/v8/ |
H A D | tx.go | 125 func (c *Tx) Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) { func 126 return c.Pipeline().Pipelined(ctx, fn) 138 return c.TxPipeline().Pipelined(ctx, fn)
|
/dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/go-redis/redis/v8/ |
H A D | tx.go | 123 func (c *Tx) Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) { func 124 return c.Pipeline().Pipelined(ctx, fn) 136 return c.TxPipeline().Pipelined(ctx, fn)
|
/dports/www/pomerium/pomerium-0.8.3/vendor/github.com/go-redis/redis/v7/ |
H A D | tx.go | 133 func (c *Tx) Pipelined(fn func(Pipeliner) error) ([]Cmder, error) { func 134 return c.Pipeline().Pipelined(fn) 146 return c.TxPipeline().Pipelined(fn)
|
/dports/www/gitea/gitea-1.16.5/vendor/github.com/go-redis/redis/v8/ |
H A D | tx.go | 122 func (c *Tx) Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) { func 123 return c.Pipeline().Pipelined(ctx, fn) 135 return c.TxPipeline().Pipelined(ctx, fn)
|
/dports/www/mattermost-server/mattermost-server-6.0.2/vendor/github.com/go-redis/redis/v8/ |
H A D | tx.go | 122 func (c *Tx) Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) { func 123 return c.Pipeline().Pipelined(ctx, fn) 135 return c.TxPipeline().Pipelined(ctx, fn)
|
/dports/www/oauth2-proxy/oauth2-proxy-7.2.0/vendor/github.com/go-redis/redis/v8/ |
H A D | tx.go | 125 func (c *Tx) Pipelined(ctx context.Context, fn func(Pipeliner) error) ([]Cmder, error) { func 126 return c.Pipeline().Pipelined(ctx, fn) 138 return c.TxPipeline().Pipelined(ctx, fn)
|
/dports/www/gitlab-workhorse/gitlab-foss-0a901d60f8ae4a60c04ae82e6e9c3a03e9321417/workhorse/vendor/gopkg.in/DataDog/dd-trace-go.v1/contrib/go-redis/redis/ |
H A D | redis.go | 92 func (c *Client) Pipelined(fn func(redis.Pipeliner) error) ([]redis.Cmder, error) { func 93 return c.Pipeline().Pipelined(fn) 98 return c.TxPipeline().Pipelined(fn) 154 func (c *Pipeliner) Pipelined(fn func(redis.Pipeliner) error) ([]redis.Cmder, error) { func
|
/dports/devel/gitlab-shell/gitlab-shell-65b8ec55bebd0aea64ac52b9878bafcc2ad992d3/vendor/gopkg.in/DataDog/dd-trace-go.v1/contrib/go-redis/redis/ |
H A D | redis.go | 92 func (c *Client) Pipelined(fn func(redis.Pipeliner) error) ([]redis.Cmder, error) { func 93 return c.Pipeline().Pipelined(fn) 98 return c.TxPipeline().Pipelined(fn) 154 func (c *Pipeliner) Pipelined(fn func(redis.Pipeliner) error) ([]redis.Cmder, error) { func
|
/dports/lang/gnatdroid-binutils-x86/binutils-2.27/gas/testsuite/gas/i860/ |
H A D | float04.s | 21 # Pipelined, without dual bit 39 # Pipelined, with dual bit
|