- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 641 for Capget (1.95 sec)
-
staging/src/k8s.io/api/autoscaling/v1/types.go
type ObjectMetricSource struct { // target is the described Kubernetes object. Target CrossVersionObjectReference `json:"target" protobuf:"bytes,1,name=target"` // metricName is the name of the metric in question. MetricName string `json:"metricName" protobuf:"bytes,2,name=metricName"` // targetValue is the target value of the metric (as a quantity).
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 23 17:42:49 UTC 2024 - 27.8K bytes - Viewed (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() }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 7.1K bytes - Viewed (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,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 10K bytes - Viewed (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 }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 9.1K bytes - Viewed (0) -
deps.xml
<copy file="${target.dir}/${jar.artifactId}-${file.version}.jar" todir="${thumbnail.dir}/lib"/> </target> <target name="install.plugin.jar"> <get dest="${target.dir}"> <url url="${repo.url}/${jar.groupId}/${jar.artifactId}/${jar.version}/${jar.artifactId}-${file.version}.jar" /> </get> <copy file="${target.dir}/${jar.artifactId}-${file.version}.jar" todir="${webinf.dir}/plugin"/> </target>
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Sun May 26 05:59:50 UTC 2024 - 3.1K bytes - Viewed (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 }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 9.2K bytes - Viewed (0) -
module.xml
</antcall> <antcall target="remove.jars" /> </target> <target name="install.module"> <get dest="${target.dir}"> <url url="${repo.url}/${module.groupId}/${module.name.prefix}${module.name}/${module.version}/${module.name.prefix}${module.name}-${module.zip.version}.zip" /> </get> <unzip dest="${modules.dir}/${module.name}" src="${target.dir}/${module.name.prefix}${module.name}-${module.zip.version}.zip">
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu May 16 07:10:50 UTC 2024 - 4.5K bytes - Viewed (0) -
internal/config/notify/parse.go
if err != nil { return err } for _, target := range targetList { defer target.Close() } tgts, ok := ctx.Value(config.ContextKeyForTargetFromConfig).(map[string]bool) if !ok { tgts = make(map[string]bool) } for _, target := range targetList { if tgts[target.ID().ID] { // When target set should be online yes, err := target.IsActive() if err == nil && !yes { err = ErrTargetsOffline
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 46.4K bytes - Viewed (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 }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 11.5K bytes - Viewed (0) -
internal/event/target/nats.go
} func (target *NATSTarget) isActive() (bool, error) { var connErr error if target.args.Streaming.Enable { if target.stanConn == nil || target.stanConn.NatsConn() == nil { target.stanConn, connErr = target.args.connectStan() } else if !target.stanConn.NatsConn().IsConnected() { return false, store.ErrNotConnected } } else { if target.natsConn == nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 12.8K bytes - Viewed (0)