Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 68 for target_id (0.04 seconds)

  1. internal/event/target/mqtt.go

    // MQTTTarget - MQTT target.
    type MQTTTarget struct {
    	initOnce once.Init
    
    	id         event.TargetID
    	args       MQTTArgs
    	client     mqtt.Client
    	store      store.Store[event.Event]
    	quitCh     chan struct{}
    	loggerOnce logger.LogOnce
    }
    
    // ID - returns target ID.
    func (target *MQTTTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    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)
  2. src/main/java/org/codelibs/core/io/Traverser.java

        /**
         * Searches for classes handled by this instance and calls the handler for each class.
         * <p>
         * If a root package is specified at instance construction, only classes under the root package are targeted.
         * </p>
         *
         * @param handler the handler to process classes
         */
        void forEach(ClassHandler handler);
    
        /**
    Created: Sat Dec 20 08:55:33 GMT 2025
    - Last Modified: Thu Jun 19 09:12:22 GMT 2025
    - 2.1K bytes
    - Click Count (0)
  3. internal/event/target/webhook.go

    		return errors.New("cert and key must be specified as a pair")
    	}
    	return nil
    }
    
    // WebhookTarget - Webhook target.
    type WebhookTarget struct {
    	initOnce once.Init
    
    	id         event.TargetID
    	args       WebhookArgs
    	transport  *http.Transport
    	httpClient *http.Client
    	store      store.Store[event.Event]
    	loggerOnce logger.LogOnce
    	cancel     context.CancelFunc
    	cancelCh   <-chan struct{}
    
    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)
  4. internal/event/target/mysql.go

    	initOnce once.Init
    
    	id         event.TargetID
    	args       MySQLArgs
    	updateStmt *sql.Stmt
    	deleteStmt *sql.Stmt
    	insertStmt *sql.Stmt
    	db         *sql.DB
    	store      store.Store[event.Event]
    	firstPing  bool
    	loggerOnce logger.LogOnce
    
    	quitCh chan struct{}
    }
    
    // ID - returns target ID.
    func (target *MySQLTarget) ID() event.TargetID {
    	return target.id
    }
    
    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)
  5. internal/event/target/kafka.go

    	initOnce once.Init
    
    	id         event.TargetID
    	args       KafkaArgs
    	client     sarama.Client
    	producer   sarama.SyncProducer
    	config     *sarama.Config
    	store      store.Store[event.Event]
    	batch      *store.Batch[event.Event]
    	loggerOnce logger.LogOnce
    	quitCh     chan struct{}
    }
    
    // ID - returns target ID.
    func (target *KafkaTarget) ID() event.TargetID {
    	return target.id
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Sep 06 23:06:30 GMT 2024
    - 13.6K bytes
    - Click Count (0)
  6. internal/event/target/postgresql.go

    	initOnce once.Init
    
    	id         event.TargetID
    	args       PostgreSQLArgs
    	updateStmt *sql.Stmt
    	deleteStmt *sql.Stmt
    	insertStmt *sql.Stmt
    	db         *sql.DB
    	store      store.Store[event.Event]
    	firstPing  bool
    	connString string
    	loggerOnce logger.LogOnce
    	quitCh     chan struct{}
    }
    
    // ID - returns target ID.
    func (target *PostgreSQLTarget) ID() event.TargetID {
    	return target.id
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 13.3K bytes
    - Click Count (0)
  7. internal/event/target/nats.go

    type NATSTarget struct {
    	initOnce once.Init
    
    	id         event.TargetID
    	args       NATSArgs
    	natsConn   *nats.Conn
    	stanConn   stan.Conn
    	jstream    nats.JetStream
    	store      store.Store[event.Event]
    	loggerOnce logger.LogOnce
    	quitCh     chan struct{}
    }
    
    // ID - returns target ID.
    func (target *NATSTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Apr 27 04:30:57 GMT 2025
    - 13.5K bytes
    - Click Count (0)
  8. dbflute_fess/dfprop/lastafluteMap.dfprop

            }
        }
    
        ; isUseDefaultConfigAtGeneration = true
        # you can override (several) default settings like this:
        #; overrideMap = map:{
        #    ; fess.freeGen.mail.targetDir = ./playsql/data/mail
        #}
    
        # you can adjust LastaDoc contents
        ; lastaDocContentsMap = map:{
            ; headerMap = map:{
                #; isSuppressSchemaHtmlLink = true
            }
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Sun May 20 08:20:11 GMT 2018
    - 2.2K bytes
    - Click Count (0)
  9. internal/event/target/elasticsearch.go

    type ElasticsearchTarget struct {
    	initOnce once.Init
    
    	id         event.TargetID
    	args       ElasticsearchArgs
    	client     esClient
    	store      store.Store[event.Event]
    	loggerOnce logger.LogOnce
    	quitCh     chan struct{}
    }
    
    // ID - returns target ID.
    func (target *ElasticsearchTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15K bytes
    - Click Count (0)
  10. okhttp/build.gradle.kts

        }
    
        else -> {
          logger.info("Module-info checking is disabled")
        }
      }
      // Set the task outputs and destination dir
      outputs.dir(targetDir)
      destinationDirectory.set(targetDir)
    
      // Configure JVM compatibility
      sourceCompatibility = JavaVersion.VERSION_1_9.toString()
      targetCompatibility = JavaVersion.VERSION_1_9.toString()
    
      // Set the Java release version.
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sat Nov 01 12:18:11 GMT 2025
    - 12.3K bytes
    - Click Count (0)
Back to Top