Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for readKeyEtcd (0.05 sec)

  1. cmd/etcd.go

    	timeoutCtx, cancel := context.WithTimeout(ctx, defaultContextTimeout)
    	defer cancel()
    
    	_, err := client.Delete(timeoutCtx, key)
    	etcdLogIf(ctx, err)
    	return etcdErrToErr(err, client.Endpoints())
    }
    
    func readKeyEtcd(ctx context.Context, client *etcd.Client, key string) ([]byte, error) {
    	timeoutCtx, cancel := context.WithTimeout(ctx, defaultContextTimeout)
    	defer cancel()
    	resp, err := client.Get(timeoutCtx, key)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  2. cmd/iam-etcd-store.go

    func (ies *IAMEtcdStore) loadIAMConfig(ctx context.Context, item interface{}, path string) error {
    	data, err := readKeyEtcd(ctx, ies.client, path)
    	if err != nil {
    		return err
    	}
    	return getIAMConfig(item, data, path)
    }
    
    func (ies *IAMEtcdStore) loadIAMConfigBytes(ctx context.Context, path string) ([]byte, error) {
    	data, err := readKeyEtcd(ctx, ies.client, path)
    	if err != nil {
    		return nil, err
    	}
    	return decryptData(data, path)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 01:29:20 UTC 2024
    - 14K bytes
    - Viewed (0)
Back to top