Function TestClusterAdminDescribeUserScramCredentials

admin_test.go:1604–1642

(t *testing.T)

}

func TestClusterAdminDescribeUserScramCredentials(t *testing.T) {
	users := []string{"my_user"}
	describeOK := func(req *request) encoderWithHeader {
		return &DescribeUserScramCredentialsResponse{
			Version: req.body.version(),
			Results: []*DescribeUserScramCredentialsResult{{User: "my_user"}},
		}
	}
	notController := func(req *request) encoderWithHeader {
		return &DescribeUserScramCredentialsResponse{Version: req.body.version(), ErrorCode: ErrNotController}
	}

	t.Run("describes credentials", func(t *testing.T) {
		admin := singleBrokerAdmin(t, V2_7_0_0, map[string]requestHandlerFunc{
			"DescribeUserScramCredentialsRequest": describeOK,
		})

		results, err := admin.DescribeUserScramCredentials(users)
		require.NoError(t, err)
		assert.NotEmpty(t, results)
	})

	t.Run("retries on stale controller", func(t *testing.T) {
		admin, retriedOnNewController := staleControllerAdmin(t, V2_7_0_0, "DescribeUserScramCredentialsRequest", notController, describeOK)

		results, err := admin.DescribeUserScramCredentials(users)
		require.NoError(t, err)
		assert.NotEmpty(t, results)
		assert.True(t, retriedOnNewController(), "expected broker 2 to receive the retried request")
	})

	t.Run("returns error when retries exhausted", func(t *testing.T) {
		admin, _ := staleControllerAdmin(t, V2_7_0_0, "DescribeUserScramCredentialsRequest", notController, notController)

		_, err := admin.DescribeUserScramCredentials(users)
		require.Error(t, err)
		assert.ErrorIs(t, err, ErrNotController)
	})
}

func TestElectLeaders(t *testing.T) {
	broker := NewMockBroker(t, 1)