Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 63 for target_id (0.06 sec)

  1. 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{}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.8K bytes
    - Viewed (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);
    
        /**
    Registered: Sat Dec 20 08:55:33 UTC 2025
    - Last Modified: Thu Jun 19 09:12:22 UTC 2025
    - 2.1K bytes
    - Viewed (0)
  3. internal/event/target/redis.go

    type RedisTarget struct {
    	initOnce once.Init
    
    	id         event.TargetID
    	args       RedisArgs
    	pool       *redis.Pool
    	store      store.Store[event.Event]
    	firstPing  bool
    	loggerOnce logger.LogOnce
    	quitCh     chan struct{}
    }
    
    // ID - returns target ID.
    func (target *RedisTarget) ID() event.TargetID {
    	return target.id
    }
    
    // Name - returns the Name of the target.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 9.1K bytes
    - Viewed (0)
  4. 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
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  5. 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
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 13.3K bytes
    - Viewed (0)
  6. 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
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 11.6K bytes
    - Viewed (0)
  7. 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
            }
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sun May 20 08:20:11 UTC 2018
    - 2.2K bytes
    - Viewed (0)
  8. 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.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Apr 27 04:30:57 UTC 2025
    - 13.5K bytes
    - Viewed (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.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 15K bytes
    - Viewed (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.
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Nov 01 12:18:11 UTC 2025
    - 12.3K bytes
    - Viewed (0)
Back to top