Home
last modified time | relevance | path

Searched refs:Pipelined (Results 1 – 25 of 403) sorted by relevance

12345678910>>...17

/dports/sysutils/sensu-go/sensu-go-5.11.1/backend/pipelined/
H A Dpipelined.go24 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 Dmutate.go21 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 Dhandle_test.go67 p := &Pipelined{}
196 p := &Pipelined{store: store}
206 p := &Pipelined{}
226 p := &Pipelined{}
282 p := &Pipelined{}
337 p := &Pipelined{
H A Dhandle.go36 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 Dtx_test.go36 _, 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 Dtx.go94 func (c *Tx) Pipelined(fn func(Pipeliner) error) ([]Cmder, error) { func
95 return c.Pipeline().Pipelined(fn)
99 return c.Pipelined(fn)
H A Dredis.go100 _, 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 Dcapability.rs27 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 Dcapability.rs27 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 Dcapability.rs35 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 Dtx.go122 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 Dtx.go123 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 Dtx.go122 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 Dtx.go133 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 Dtx.go122 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 Dtx.go125 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 Dtx.go125 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 Dtx.go123 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 Dtx.go133 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 Dtx.go122 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 Dtx.go122 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 Dtx.go125 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 Dredis.go92 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 Dredis.go92 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 Dfloat04.s21 # Pipelined, without dual bit
39 # Pipelined, with dual bit

12345678910>>...17