- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 24 for GetResponse (0.32 sec)
-
fess-crawler-es/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java
import org.opensearch.action.bulk.BulkRequestBuilder; import org.opensearch.action.bulk.BulkResponse; import org.opensearch.action.delete.DeleteResponse; import org.opensearch.action.get.GetResponse; import org.opensearch.action.index.IndexResponse; import org.opensearch.action.search.SearchRequestBuilder; import org.opensearch.action.search.SearchResponse; import org.opensearch.action.support.WriteRequest.RefreshPolicy;
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Apr 04 09:58:36 UTC 2024 - 23.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go
clientv3.OpGet(key), ).Commit() metrics.RecordEtcdRequest("delete", s.groupResourceString, err, startTime) if err != nil { return err } if !txnResp.Succeeded { getResp := (*clientv3.GetResponse)(txnResp.Responses[0].GetResponseRange()) klog.V(4).Infof("deletion of %s failed because of a conflict, going to retry", key) origState, err = s.getState(ctx, getResp, key, v, false) if err != nil { return err
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 35.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/sso/oic/OpenIdConnectAuthenticator.java
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 11.1K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/proxy/upgradeaware.go
h.Responder.Error(w, req, err) return true } defer backendConn.Close() // determine the http response code from the backend by reading from rawResponse+backendConn backendHTTPResponse, headerBytes, err := getResponse(io.MultiReader(bytes.NewReader(rawResponse), backendConn)) if err != nil { klog.V(6).Infof("Proxy connection error: %v", err) h.Responder.Error(w, req, err) return true }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:10:30 UTC 2024 - 19.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher_test.go
return &etcdClientKVWrapper{ KV: kv, getCallCounter: 0, } } func (ecw *etcdClientKVWrapper) Get(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.GetResponse, error) { resp, err := ecw.KV.Get(ctx, key, opts...) ecw.getCallCounter++ if err != nil { return nil, err } if len(ecw.getReactors) > 0 { reactor := ecw.getReactors[0]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 12.3K bytes - Viewed (1) -
src/net/rpc/server.go
// contains an error when it is used. var invalidRequest = struct{}{} func (server *Server) sendResponse(sending *sync.Mutex, req *Request, reply any, codec ServerCodec, errmsg string) { resp := server.getResponse() // Encode the response header resp.ServiceMethod = req.ServiceMethod if errmsg != "" { resp.Error = errmsg reply = invalidRequest } resp.Seq = req.Seq sending.Lock()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 21.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/taglib/FessFunctions.java
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 16.9K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb1/AndXServerMessageBlock.java
dstIndex += writeAndXWireFormat(dst, dstIndex); this.length = dstIndex - start; if ( this.digest != null ) { this.digest.sign(dst, this.headerStart, this.length, this, this.getResponse()); } return this.length; } /* * We overload this because we want readAndXWireFormat to * read the parameter words and bytes. This is so when
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Mon Nov 28 10:56:27 UTC 2022 - 14.3K bytes - Viewed (0) -
mockwebserver/api/mockwebserver3.api
public final fun getHeaders ()Lokhttp3/Headers; public final fun getMethod ()Ljava/lang/String; public final fun getPath ()Ljava/lang/String; public final fun getResponse ()Lmockwebserver3/MockResponse; } public class mockwebserver3/QueueDispatcher : mockwebserver3/Dispatcher { public static final field Companion Lmockwebserver3/QueueDispatcher$Companion; public fun <init> ()V
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Tue Jan 03 21:59:45 UTC 2023 - 12.7K bytes - Viewed (0) -
platforms/core-runtime/daemon-protocol/src/main/java/org/gradle/launcher/daemon/protocol/DaemonMessageSerializer.java
private static class UserResponseSerializer implements Serializer<UserResponse> { @Override public void write(Encoder encoder, UserResponse message) throws Exception { encoder.writeString(message.getResponse()); } @Override public UserResponse read(Decoder decoder) throws Exception { return new UserResponse(decoder.readString()); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:54:56 UTC 2024 - 18.8K bytes - Viewed (0)