- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 1,092 for TARGET (0.06 seconds)
-
internal/event/target/amqp.go
headers["minio-event"] = eventData.EventName.String() if err = ch.ExchangeDeclare(target.args.Exchange, target.args.ExchangeType, target.args.Durable, target.args.AutoDeleted, target.args.Internal, target.args.NoWait, nil); err != nil { return err } if err = ch.Publish(target.args.Exchange, target.args.RoutingKey, target.args.Mandatory, target.args.Immediate, amqp091.Publishing{ Headers: headers,
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Thu Aug 21 04:25:07 GMT 2025 - 10K bytes - Click Count (0) -
internal/event/target/redis.go
// Name - returns the Name of the target. func (target *RedisTarget) Name() string { return target.ID().String() } // Store returns any underlying store if set. func (target *RedisTarget) Store() event.TargetStore { return target.store } // IsActive - Return true if target is up and active func (target *RedisTarget) IsActive() (bool, error) { if err := target.init(); err != nil { return false, err }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 9.1K bytes - Click Count (0) -
internal/event/targetlist.go
targetSet TargetIDSet } // Add - adds unique target to target list. func (list *TargetList) Add(targets ...Target) error { list.Lock() defer list.Unlock() for _, target := range targets { if _, ok := list.targets[target.ID()]; ok { return fmt.Errorf("target %v already exists", target.ID()) } list.targets[target.ID()] = target } return nil }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 9.2K bytes - Click Count (0) -
README.md
---
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Thu Dec 25 11:01:37 GMT 2025 - 26.4K bytes - Click Count (0) -
internal/event/target/nsq.go
func (target *NSQTarget) Name() string { return target.ID().String() } // Store returns any underlying store if set. func (target *NSQTarget) Store() event.TargetStore { return target.store } // IsActive - Return true if target is up and active func (target *NSQTarget) IsActive() (bool, error) { if err := target.init(); err != nil { return false, err } return target.isActive() }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 7.1K bytes - Click Count (0) -
docs/es/docs/index.md
---
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Tue Dec 16 16:33:45 GMT 2025 - 24.3K bytes - Click Count (0) -
docs/pt/docs/index.md
---
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Tue Dec 16 20:32:40 GMT 2025 - 24.5K bytes - Click Count (0) -
docs/zh-hant/docs/index.md
---
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sat Oct 11 17:48:49 GMT 2025 - 18.8K bytes - Click Count (0) -
docs/fr/docs/index.md
---
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sat Oct 11 17:48:49 GMT 2025 - 22K bytes - Click Count (0) -
internal/rest/client_test.go
} //nolint:gocritic if tt.target == nil { var netErrInterface net.Error if errors.As(n, &netErrInterface) != tt.want { t.Errorf("errors.As(n, &tt.target) != tt.want, n: %#v, target: %#v, want:%v, got: %v", n, tt.target, tt.want, !tt.want) } } else { if errors.As(n, &tt.target) != tt.want { t.Errorf("errors.As(n, &tt.target) != tt.want, n: %#v, target: %#v, want:%v, got: %v", n, tt.target, tt.want, !tt.want)Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 1.9K bytes - Click Count (0)