- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 521 for etcd (0.02 sec)
-
internal/config/etcd/etcd.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package etcd import ( "crypto/tls" "crypto/x509" "strings" "time" "github.com/minio/minio/internal/config" "github.com/minio/minio/internal/fips" "github.com/minio/pkg/v3/env" xnet "github.com/minio/pkg/v3/net" clientv3 "go.etcd.io/etcd/client/v3" "go.etcd.io/etcd/client/v3/namespace" "go.uber.org/zap" ) const (
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 28 23:17:22 UTC 2024 - 5.2K bytes - Viewed (0) -
cmd/etcd.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "errors" "fmt" etcd "go.etcd.io/etcd/client/v3" ) var errEtcdUnreachable = errors.New("etcd is unreachable, please check your endpoints") func etcdErrToErr(err error, etcdEndpoints []string) error { if err == nil { return nil } switch err {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Apr 04 12:04:40 UTC 2024 - 2.9K bytes - Viewed (0) -
cmd/iam-etcd-store.go
jsoniter "github.com/json-iterator/go" "github.com/minio/minio-go/v7/pkg/set" "github.com/minio/minio/internal/config" "github.com/minio/minio/internal/kms" "github.com/puzpuzpuz/xsync/v3" "go.etcd.io/etcd/api/v3/mvccpb" etcd "go.etcd.io/etcd/client/v3" ) var defaultContextTimeout = 30 * time.Second func etcdKvsToSet(prefix string, kvs []*mvccpb.KeyValue) set.StringSet { users := set.NewStringSet() for _, kv := range kvs {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 01:29:20 UTC 2024 - 14K bytes - Viewed (0) -
.github/workflows/iam-integrations.yaml
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 17 16:45:46 UTC 2024 - 5.3K bytes - Viewed (0) -
docs/config/README.md
``` ~ mc admin config set myminio/ <key> ``` e.g: `mc admin config set myminio/ etcd` returns available `etcd` config args ``` ~ mc admin config set play/ etcd KEY: etcd federate multiple clusters for IAM and Bucket DNS ARGS: endpoints* (csv) comma separated list of etcd endpoints e.g. "http://localhost:2379"
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Aug 16 08:43:49 UTC 2024 - 17.9K bytes - Viewed (0) -
cmd/config-current.go
} } etcdCfg, err := etcd.LookupConfig(s[config.EtcdSubSys][config.Default], globalRootCAs) if err != nil { configLogIf(ctx, fmt.Errorf("Unable to initialize etcd config: %w", err)) } if etcdCfg.Enabled { bootstrapTraceMsg("initialize etcd store") globalEtcdClient, err = etcd.New(etcdCfg) if err != nil { configLogIf(ctx, fmt.Errorf("Unable to initialize etcd config: %w", err)) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 03 18:23:41 UTC 2024 - 30.1K bytes - Viewed (0) -
internal/config/dns/etcd_dns.go
package dns import ( "context" "encoding/json" "errors" "fmt" "net" "sort" "strings" "time" "github.com/minio/minio-go/v7/pkg/set" clientv3 "go.etcd.io/etcd/client/v3" ) // ErrNoEntriesFound - Indicates no entries were found for the given key (directory) var ErrNoEntriesFound = errors.New("No entries found for this key") // ErrDomainMissing - Indicates domain is missing
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 26 15:03:08 UTC 2024 - 8K bytes - Viewed (0) -
helm/minio/templates/secrets.yaml
rootPassword: {{ include "minio.root.password" . | b64enc | quote }} {{- if .Values.etcd.clientCert }} etcd_client.crt: {{ .Values.etcd.clientCert | toString | b64enc | quote }} {{- end }} {{- if .Values.etcd.clientCertKey }} etcd_client.key: {{ .Values.etcd.clientCertKey | toString | b64enc | quote }} {{- end }}
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Apr 12 04:09:29 UTC 2023 - 706 bytes - Viewed (0) -
helm/minio/templates/deployment.yaml
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 10 15:48:31 UTC 2024 - 8.6K bytes - Viewed (0) -
cmd/healthcheck-handler.go
return } } if globalEtcdClient != nil { // Borrowed from // https://github.com/etcd-io/etcd/blob/main/etcdctl/ctlv3/command/ep_command.go#L118 ctx, cancel := context.WithTimeout(r.Context(), defaultContextTimeout) defer cancel() if _, err := globalEtcdClient.Get(ctx, "health"); err != nil { // etcd unreachable throw an error.. switch r.Method { case http.MethodHead:
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jun 26 07:44:34 UTC 2024 - 6.9K bytes - Viewed (0)