Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 4691 - 4700 of 6,347 for AN (0.03 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. internal/event/target/kafka.go

    		}
    		_, err := target.store.Put(eventData)
    		return err
    	}
    	if err := target.init(); err != nil {
    		return err
    	}
    	return target.send(eventData)
    }
    
    // send - sends an event to the kafka.
    func (target *KafkaTarget) send(eventData event.Event) error {
    	if target.producer == nil {
    		return store.ErrNotConnected
    	}
    	msg, err := target.toProducerMessage(eventData)
    	if err != nil {
    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)
  2. src/test/java/org/codelibs/core/exception/SQLRuntimeExceptionTest.java

     * You may obtain a copy of the License at
     *
     *     http://www.apache.org/licenses/LICENSE-2.0
     *
     * Unless required by applicable law or agreed to in writing, software
     * distributed under the License is distributed on an "AS IS" BASIS,
     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
     * either express or implied. See the License for the specific language
     * governing permissions and limitations under the License.
     */
    Created: Sat Dec 20 08:55:33 GMT 2025
    - Last Modified: Sat May 10 01:32:17 GMT 2025
    - 3.2K bytes
    - Click Count (0)
  3. src/test/java/org/codelibs/core/lang/ObjectUtilTest.java

     * You may obtain a copy of the License at
     *
     *     http://www.apache.org/licenses/LICENSE-2.0
     *
     * Unless required by applicable law or agreed to in writing, software
     * distributed under the License is distributed on an "AS IS" BASIS,
     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
     * either express or implied. See the License for the specific language
     * governing permissions and limitations under the License.
     */
    Created: Sat Dec 20 08:55:33 GMT 2025
    - Last Modified: Sat May 10 01:32:17 GMT 2025
    - 2.9K bytes
    - Click Count (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/crawler/container/CrawlerContainer.java

     * You may obtain a copy of the License at
     *
     *     http://www.apache.org/licenses/LICENSE-2.0
     *
     * Unless required by applicable law or agreed to in writing, software
     * distributed under the License is distributed on an "AS IS" BASIS,
     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
     * either express or implied. See the License for the specific language
     * governing permissions and limitations under the License.
     */
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Sat Mar 15 06:52:00 GMT 2025
    - 2.6K bytes
    - Click Count (0)
  5. src/test/java/org/codelibs/core/misc/DisposableUtilTest.java

     * You may obtain a copy of the License at
     *
     *     http://www.apache.org/licenses/LICENSE-2.0
     *
     * Unless required by applicable law or agreed to in writing, software
     * distributed under the License is distributed on an "AS IS" BASIS,
     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
     * either express or implied. See the License for the specific language
     * governing permissions and limitations under the License.
     */
    Created: Sat Dec 20 08:55:33 GMT 2025
    - Last Modified: Sat May 10 01:32:17 GMT 2025
    - 3.3K bytes
    - Click Count (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/CompressionInterceptor.kt

     * You may obtain a copy of the License at
     *
     *      http://www.apache.org/licenses/LICENSE-2.0
     *
     * Unless required by applicable law or agreed to in writing, software
     * distributed under the License is distributed on an "AS IS" BASIS,
     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp3
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Oct 07 15:15:28 GMT 2025
    - 2.9K bytes
    - Click Count (1)
  7. okhttp-testing-support/src/main/kotlin/okhttp3/FakeSSLSession.kt

     * You may obtain a copy of the License at
     *
     * http://www.apache.org/licenses/LICENSE-2.0
     *
     * Unless required by applicable law or agreed to in writing, software
     * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
     * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
     * License for the specific language governing permissions and limitations under
     * the License.
     */
    package okhttp3
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 3.1K bytes
    - Click Count (0)
  8. src/test/java/org/codelibs/fess/suggest/SuggesterBuilderTest.java

     * You may obtain a copy of the License at
     *
     *     http://www.apache.org/licenses/LICENSE-2.0
     *
     * Unless required by applicable law or agreed to in writing, software
     * distributed under the License is distributed on an "AS IS" BASIS,
     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
     * either express or implied. See the License for the specific language
     * governing permissions and limitations under the License.
     */
    Created: Sat Dec 20 13:04:59 GMT 2025
    - Last Modified: Sat Nov 01 13:29:47 GMT 2025
    - 3.6K bytes
    - Click Count (0)
  9. samples/compare/src/test/kotlin/okhttp3/compare/JavaHttpClientTest.kt

     * You may obtain a copy of the License at
     *
     *      http://www.apache.org/licenses/LICENSE-2.0
     *
     * Unless required by applicable law or agreed to in writing, software
     * distributed under the License is distributed on an "AS IS" BASIS,
     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp3.compare
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Jun 18 12:28:21 GMT 2025
    - 2.8K bytes
    - Click Count (0)
  10. android/guava-testlib/src/com/google/common/collect/testing/testers/QueueRemoveTester.java

     * You may obtain a copy of the License at
     *
     * http://www.apache.org/licenses/LICENSE-2.0
     *
     * Unless required by applicable law or agreed to in writing, software
     * distributed under the License is distributed on an "AS IS" BASIS,
     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Nov 14 23:40:07 GMT 2024
    - 2.6K bytes
    - Click Count (0)
Back to Top