Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for getEncryptionConfigHash (0.2 sec)

  1. staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/controller/controller.go

    			workqueue.DefaultTypedControllerRateLimiter[string](),
    			workqueue.TypedRateLimitingQueueConfig[string]{Name: name},
    		),
    		apiServerID: apiServerID,
    		getEncryptionConfigHash: func(_ context.Context, filepath string) (string, error) {
    			return encryptionconfig.GetEncryptionConfigHash(filepath)
    		},
    		loadEncryptionConfig: encryptionconfig.LoadEncryptionConfig,
    	}
    }
    
    // Run starts the controller and blocks until ctx is canceled.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/controller/controller_test.go

    				loadCalls++
    				queue.ctx = ctx
    				return test.mockLoadEncryptionConfig(ctx, filepath, reload, apiServerID)
    			}
    			d.getEncryptionConfigHash = func(ctx context.Context, filepath string) (string, error) {
    				hashCalls++
    				queue.ctx = ctx
    				return test.mockGetEncryptionConfigHash(ctx, filepath)
    			}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/config_test.go

    		tt := tt
    		t.Run(tt.name, func(t *testing.T) {
    			t.Parallel()
    
    			got, err := GetEncryptionConfigHash(tt.filepath)
    			if errString(err) != tt.wantErr {
    				t.Errorf("GetEncryptionConfigHash() error = %v, wantErr %v", err, tt.wantErr)
    				return
    			}
    			if got != tt.wantHash {
    				t.Errorf("GetEncryptionConfigHash() got = %v, want %v", got, tt.wantHash)
    			}
    		})
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 16 16:56:39 UTC 2024
    - 72.3K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/server/options/encryptionconfig/config.go

    	}
    
    	return data, computeEncryptionConfigHash(data), nil
    }
    
    // GetEncryptionConfigHash reads the encryption configuration file at filepath and returns the hash of the file.
    // It does not attempt to decode or load the config, and serves as a cheap check to determine if the file has changed.
    func GetEncryptionConfigHash(filepath string) (string, error) {
    	_, contentHash, err := loadDataAndHash(filepath)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 16 16:56:39 UTC 2024
    - 41.2K bytes
    - Viewed (0)
Back to top