- Sort Score
- Num 10 results
- Language All
Results 21 - 30 of 1,787 for targetID (0.06 seconds)
-
internal/event/rules.go
pattern = strings.ReplaceAll(pattern, "**", "*") return pattern } // Rules - event rules type Rules map[string]TargetIDSet // Add - adds pattern and target ID. func (rules Rules) Add(pattern string, targetID TargetID) { rules[pattern] = NewTargetIDSet(targetID).Union(rules[pattern]) } // MatchSimple - returns true one of the matching object name in rules. func (rules Rules) MatchSimple(objectName string) bool {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri May 24 23:05:23 GMT 2024 - 2.7K 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) -
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/config/lambda/target/webhook.go
} // ID - returns target ID. func (target *WebhookTarget) ID() event.TargetID { return target.id } // IsActive - Return true if target is up and active func (target *WebhookTarget) IsActive() (bool, error) { if err := target.init(); err != nil { return false, err } return target.isActive() } // errNotConnected - indicates that the target connection is not active.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Jul 08 21:39:49 GMT 2024 - 6.7K bytes - Click Count (0) -
cmd/event-notification.go
return arns } region := globalSite.Region() for targetID := range evnot.targetList.TargetMap() { // httpclient target is part of ListenNotification // which doesn't need to be listed as part of the ARN list // This list is only meant for external targets, filter // this out pro-actively. if !strings.HasPrefix(targetID.ID, "httpclient+") { arns = append(arns, targetID.ToARN(region).String()) } } return arns }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Jun 21 22:22:24 GMT 2024 - 7.7K bytes - Click Count (0) -
internal/event/target/redis.go
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 } return target.isActive()
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/target/mqtt.go
func (target *MQTTTarget) Name() string { return target.ID().String() } // Store returns any underlying store if set. func (target *MQTTTarget) Store() event.TargetStore { return target.store } // IsActive - Return true if target is up and active func (target *MQTTTarget) 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: Fri Sep 06 23:06:30 GMT 2024 - 8.2K bytes - Click Count (0) -
internal/event/target/webhook.go
} // ID - returns target ID. func (target *WebhookTarget) ID() event.TargetID { return target.id } // Name - returns the Name of the target. func (target *WebhookTarget) Name() string { return target.ID().String() } // IsActive - Return true if target is up and active func (target *WebhookTarget) IsActive() (bool, error) { if err := target.init(); err != nil { return false, err }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Sep 06 23:06:30 GMT 2024 - 8.8K bytes - Click Count (0) -
internal/event/config.go
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 8.4K bytes - Click Count (0) -
internal/event/target/mysql.go
quitCh chan struct{} } // ID - returns target ID. func (target *MySQLTarget) ID() event.TargetID { return target.id } // Name - returns the Name of the target. func (target *MySQLTarget) Name() string { return target.ID().String() } // Store returns any underlying store if set. func (target *MySQLTarget) Store() event.TargetStore { return target.store }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Mar 30 00:56:02 GMT 2025 - 11.6K bytes - Click Count (0)