- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 208 for liven (0.18 sec)
-
internal/config/lambda/event/targetidset.go
func (set TargetIDSet) add(targetID TargetID) { set[targetID] = struct{}{} } // Union - returns union with given set as new set. func (set TargetIDSet) Union(sset TargetIDSet) TargetIDSet { nset := set.Clone() for k := range sset { nset.add(k) } return nset } // Difference - returns difference with given set as new set. func (set TargetIDSet) Difference(sset TargetIDSet) TargetIDSet { nset := NewTargetIDSet()
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 1.9K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/proxyconfig.go
Use: "rootca-compare [pod/]<name-1>[.<namespace-1>] [pod/]<name-2>[.<namespace-2>]", Short: "Compare ROOTCA values for the two given pods", Long: `Compare ROOTCA values for given 2 pods to check the connectivity between them.`, Example: ` # Compare ROOTCA values for given 2 pods to check the connectivity between them. istioctl proxy-config rootca-compare <pod-name-1[.namespace]> <pod-name-2[.namespace]>`,
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Tue Apr 16 03:28:36 GMT 2024 - 48K bytes - Viewed (0) -
internal/kms/kes.go
// given key ID. // // If the a key with the same keyID already exists then // CreateKey returns kes.ErrKeyExists. func (c *kesClient) CreateKey(ctx context.Context, keyID string) error { c.lock.RLock() defer c.lock.RUnlock() return c.client.CreateKey(ctx, keyID) } // DeleteKey deletes a key at the KMS with the given key ID. // Please note that is a dangerous operation.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Apr 16 15:43:39 GMT 2024 - 14.9K bytes - Viewed (0) -
cmd/sts-handlers.go
token := r.Form.Get(stsToken) if token == "" { token = r.Form.Get(stsWebIdentityToken) } accessToken := r.Form.Get(stsWebIdentityAccessToken) // RoleARN parameter processing: If a role ARN is given in the request, we // use that and validate the authentication request. If not, we assume this // is an STS request for a claim based IDP (if one is present) and set // roleArn = openid.DummyRoleARN. //
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 18:36:18 GMT 2024 - 34.7K bytes - Viewed (2) -
cmd/ftp-server.go
portRange = tokens[1] case "tls-private-key": tlsPrivateKey = tokens[1] case "tls-public-cert": tlsPublicCert = tokens[1] } } // Verify if only partial inputs are given for FTP(secure) { if tlsPrivateKey == "" && tlsPublicCert != "" { logger.Fatal(fmt.Errorf("invalid TLS arguments provided missing private key --ftp=\"tls-private-key=path/to/private.key\""), "unable to start FTP server")
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Mar 09 03:07:08 GMT 2024 - 4.8K bytes - Viewed (2) -
internal/config/config.go
cp[subSys] = make(map[string]KVS) for tgt, kv := range tgtKV { cp[subSys][tgt] = append(cp[subSys][tgt], kv...) } } return cp } // GetSubSys - extracts subssystem info from given config string func GetSubSys(s string) (subSys string, inputs []string, tgt string, e error) { tgt = Default if len(s) == 0 { return subSys, inputs, tgt, Errorf("input arguments cannot be empty") }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Mar 02 05:11:03 GMT 2024 - 37.3K bytes - Viewed (0) -
internal/bucket/lifecycle/lifecycle.go
for i := range lc.Rules { if lc.Rules[i].ID == "" { lc.Rules[i].ID = uuid.New().String() } } return &lc, nil } // ParseLifecycleConfig - parses data in given reader to Lifecycle. func ParseLifecycleConfig(reader io.Reader) (*Lifecycle, error) { var lc Lifecycle if err := xml.NewDecoder(reader).Decode(&lc); err != nil { return nil, err } return &lc, nil }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Mar 09 06:41:22 GMT 2024 - 17K bytes - Viewed (0) -
istioctl/pkg/authz/analyzer.go
) // Analyzer that can be used to check authorization policy. type Analyzer struct { listenerDump *envoy_admin.ListenersConfigDump } // NewAnalyzer creates a new analyzer for a given pod based on its envoy config. func NewAnalyzer(envoyConfig *configdump.Wrapper) (*Analyzer, error) { listeners, err := envoyConfig.GetDynamicListenerDump(true) if err != nil {
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Wed Jul 13 01:59:17 GMT 2022 - 2.1K bytes - Viewed (0) -
cmd/healthcheck-router.go
package cmd import ( "net/http" "github.com/minio/mux" ) const ( healthCheckPath = "/health" healthCheckLivenessPath = "/live" healthCheckReadinessPath = "/ready" healthCheckClusterPath = "/cluster" healthCheckClusterReadPath = "/cluster/read" healthCheckPathPrefix = minioReservedBucketPath + healthCheckPath )
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Jan 23 11:12:47 GMT 2023 - 2.3K bytes - Viewed (0) -
cmd/metacache-walk.go
// ReportNotFound will return errFileNotFound if all disks reports the BaseDir cannot be found. ReportNotFound bool // FilterPrefix will only return results with given prefix within folder. // Should never contain a slash. FilterPrefix string // ForwardTo will forward to the given object path. ForwardTo string // Limit the number of returned objects if > 0. Limit int // DiskID contains the disk ID of the disk.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 12.4K bytes - Viewed (0)