Search Options

Results per page
Sort
Preferred Languages
Advance

Results 951 - 960 of 1,174 for dsync (0.17 sec)

  1. README.ja.md

        * 対応フィールド名
    
    2回目以降のインスタンス生成時には、作成済みの設定が再利用されます。
    
    ### Suggestリクエスト
    
    ```java
    SuggestResponse response = suggester.suggest().setQuery("kensaku").execute().getResponse();
    ```
    
    ### Suggest async widh lambda
    
    ```
    suggester.suggest().setQuery("kensaku").execute()
      .done(
        response -> {}
      ).error(
        t -> {}
      );
    ```
    
    ### サジェストドキュメントの登録
    
    ```java
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Mon Jul 27 10:00:55 UTC 2015
    - 2.2K bytes
    - Viewed (0)
  2. istioctl/pkg/admin/istiodconfig.go

    // limitations under the License.
    
    package admin
    
    import (
    	"bytes"
    	"context"
    	"encoding/json"
    	"errors"
    	"fmt"
    	"io"
    	"net/http"
    	"net/url"
    	"regexp"
    	"sort"
    	"strings"
    	"sync"
    	"text/tabwriter"
    
    	"github.com/spf13/cobra"
    	"sigs.k8s.io/yaml"
    
    	"istio.io/api/label"
    	"istio.io/istio/istioctl/pkg/cli"
    	"istio.io/istio/istioctl/pkg/clioptions"
    	"istio.io/istio/istioctl/pkg/completion"
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sat Apr 13 05:23:38 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  3. internal/s3select/select.go

    func init() {
    	parquetSupport = env.Get("MINIO_API_SELECT_PARQUET", config.EnableOff) == config.EnableOn
    }
    
    var bufPool = sync.Pool{
    	New: func() interface{} {
    		// make a buffer with a reasonable capacity.
    		return bytes.NewBuffer(make([]byte, 0, maxRecordSize))
    	},
    }
    
    var bufioWriterPool = sync.Pool{
    	New: func() interface{} {
    		// io.Discard is just used to create the writer. Actual destination
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 21.2K bytes
    - Viewed (0)
  4. internal/config/identity/plugin/config.go

    package plugin
    
    import (
    	"bytes"
    	"context"
    	"crypto/sha1"
    	"encoding/base64"
    	"encoding/json"
    	"fmt"
    	"io"
    	"net/http"
    	"net/url"
    	"regexp"
    	"sync"
    	"time"
    
    	"github.com/minio/minio/internal/arn"
    	"github.com/minio/minio/internal/config"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/pkg/v3/env"
    	xnet "github.com/minio/pkg/v3/net"
    )
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  5. tensorflow/c/eager/parallel_device/parallel_device_test.cc

      return TensorHandlePtr(result_handle);
    }
    
    void TestCollective(bool async) {
      std::unique_ptr<TF_Status, decltype(&TF_DeleteStatus)> status(
          TF_NewStatus(), TF_DeleteStatus);
      std::unique_ptr<TFE_ContextOptions, decltype(&TFE_DeleteContextOptions)> opts(
          TFE_NewContextOptions(), TFE_DeleteContextOptions);
      TFE_ContextOptionsSetAsync(opts.get(), async);
      std::unique_ptr<TF_Buffer, decltype(&TF_DeleteBuffer)> config(
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Tue Aug 06 23:56:17 UTC 2024
    - 29.4K bytes
    - Viewed (0)
  6. internal/kms/kes.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package kms
    
    import (
    	"context"
    	"errors"
    	"net/http"
    	"sync"
    	"time"
    
    	"github.com/minio/kms-go/kes"
    	"github.com/minio/madmin-go/v3"
    )
    
    type kesConn struct {
    	defaultKeyID string
    	client       *kes.Client
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Aug 18 06:43:03 UTC 2024
    - 7.3K bytes
    - Viewed (0)
  7. internal/rest/rpc-stats.go

    //
    // You should have received a copy of the GNU Affero General Public License
    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package rest
    
    import (
    	"net/http"
    	"net/http/httptrace"
    	"sync/atomic"
    	"time"
    )
    
    var globalStats = struct {
    	errs uint64
    
    	tcpDialErrs                 uint64
    	tcpDialCount                uint64
    	tcpDialTotalDur             uint64
    	tcpTimeForFirstByteTotalDur uint64
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 18:21:34 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  8. docs/metrics/v3.md

    |-----------------------------------------------|-------------------------------------------------------------------------------------------------------|----------|
    | `minio_notification_current_send_in_progress` | Number of concurrent async Send calls active to all targets. <br><br>Type: counter                    | `server` |
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 02 22:30:11 UTC 2024
    - 45.2K bytes
    - Viewed (0)
  9. fastapi/routing.py

        original_context: Lifespan[Any], nested_context: Lifespan[Any]
    ) -> Lifespan[Any]:
        @asynccontextmanager
        async def merged_lifespan(
            app: AppType,
        ) -> AsyncIterator[Optional[Mapping[str, Any]]]:
            async with original_context(app) as maybe_original_state:
                async with nested_context(app) as maybe_nested_state:
                    if maybe_nested_state is None and maybe_original_state is None:
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Oct 12 09:44:57 UTC 2024
    - 172.1K bytes
    - Viewed (0)
  10. docs/em/docs/tutorial/dependencies/sub-dependencies.md

    🏧 😐 🌐❔ 👆 💭 👆 💪 🔗 🤙 🔠 🔁 (🎲 💗 🕰) 🎏 📨 ↩️ ⚙️ "💾" 💲, 👆 💪 ⚒ 🔢 `use_cache=False` 🕐❔ ⚙️ `Depends`:
    
    ```Python hl_lines="1"
    async def needy_dependency(fresh_value: str = Depends(get_value, use_cache=False)):
        return {"fresh_value": fresh_value}
    ```
    
    ## 🌃
    
    ↖️ ⚪️➡️ 🌐 🎀 🔤 ⚙️ 📥, **🔗 💉** ⚙️ 🙅.
    
    🔢 👈 👀 🎏 *➡ 🛠️ 🔢*.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 3.3K bytes
    - Viewed (0)
Back to top