- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 188 for fcclient (0.12 sec)
-
src/main/java/org/codelibs/fess/es/config/exentity/CrawlingConfig.java
import org.codelibs.core.lang.StringUtil; import org.codelibs.fess.Constants; import org.codelibs.fess.crawler.client.CrawlerClientFactory; import org.codelibs.fess.crawler.client.ftp.FtpClient; import org.codelibs.fess.crawler.client.http.HcHttpClient; import org.codelibs.fess.crawler.client.smb.SmbClient; import org.codelibs.fess.mylasta.direction.FessConfig; import org.codelibs.fess.util.ComponentUtil;
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 5.5K bytes - Viewed (0) -
security/tools/generate_cert/main.go
signerCertFile = flag.String("signer-cert", "", "Signer certificate file (PEM encoded).") signerPrivFile = flag.String("signer-priv", "", "Signer private key file (PEM encoded).") isClient = flag.Bool("client", false, "Whether this certificate is for a client.") org = flag.String("organization", "Juju org", "Organization for the cert.") outCert = flag.String("out-cert", "cert.pem", "Output certificate file.")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 28 16:21:30 UTC 2023 - 5.7K bytes - Viewed (0) -
security/pkg/nodeagent/cache/secretcache.go
func NewSecretManagerClient(caClient security.Client, options *security.Options) (*SecretManagerClient, error) { watcher, err := fsnotify.NewWatcher() if err != nil { return nil, err } ret := &SecretManagerClient{ queue: queue.NewDelayed(queue.DelayQueueBuffer(0)), caClient: caClient, configOptions: options,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 04 08:29:46 UTC 2024 - 28.2K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/mod/sumdb/client.go
var ErrSecurity = errors.New("security error: misbehaving server") // A Client is a client connection to a checksum database. // All the methods are safe for simultaneous use by multiple goroutines. type Client struct { ops ClientOps // access to operations in the external world didLookup uint32 // one-time initialized data initOnce sync.Once
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Feb 08 17:50:49 UTC 2024 - 19.1K bytes - Viewed (0) -
src/net/rpc/client.go
Close() error } func (client *Client) send(call *Call) { client.reqMutex.Lock() defer client.reqMutex.Unlock() // Register this call. client.mutex.Lock() if client.shutdown || client.closing { client.mutex.Unlock() call.Error = ErrShutdown call.done() return } seq := client.seq client.seq++ client.pending[seq] = call client.mutex.Unlock() // Encode and send the request.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 9K bytes - Viewed (0) -
src/net/rpc/jsonrpc/client.go
return c.c.Close() } // NewClient returns a new [rpc.Client] to handle requests to the // set of services at the other end of the connection. func NewClient(conn io.ReadWriteCloser) *rpc.Client { return rpc.NewClientWithCodec(NewClientCodec(conn)) } // Dial connects to a JSON-RPC server at the specified network address. func Dial(network, address string) (*rpc.Client, error) { conn, err := net.Dial(network, address)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 3K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/resource/client.go
limitations under the License. */ package resource import ( "k8s.io/apimachinery/pkg/runtime" "k8s.io/apimachinery/pkg/runtime/schema" "k8s.io/client-go/rest" ) // TODO require negotiatedSerializer. leaving it optional lets us plumb current behavior and deal with the difference after major plumbing is complete
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 15 13:01:18 UTC 2021 - 2.1K bytes - Viewed (0) -
pkg/kubelet/apis/podresources/client.go
"google.golang.org/grpc/credentials/insecure" "k8s.io/cri-client/pkg/util" "k8s.io/kubelet/pkg/apis/podresources/v1" "k8s.io/kubelet/pkg/apis/podresources/v1alpha1" ) // Note: Consumers of the pod resources API should not be importing this package. // They should copy paste the function in their project. // GetV1alpha1Client returns a client for the PodResourcesLister grpc service // Note: This is deprecated
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 08:58:18 UTC 2024 - 2.5K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/plugin/v1beta1/client.go
func NewPluginClient(r string, socketPath string, h ClientHandler) Client { return &client{ resource: r, socket: socketPath, handler: h, } } // Connect is for establishing a gRPC connection between device manager and device plugin. func (c *client) Connect() error { client, conn, err := dial(c.socket) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 21:35:13 UTC 2023 - 3.8K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client.go
} var _ model.ConfigStoreController = &Client{} func New(client kube.Client, opts Option) *Client { schemas := collections.Pilot if features.EnableGatewayAPI { schemas = collections.PilotGatewayAPI() } return NewForSchemas(client, opts, schemas) } func NewForSchemas(client kube.Client, opts Option, schemas collection.Schemas) *Client { schemasByCRDName := map[string]resource.Schema{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 00:12:28 UTC 2024 - 13.7K bytes - Viewed (0)